WindowContext.h File Reference

#include "Analyzer/Analyzer.h"
#include "DataMgr/Chunk/Chunk.h"
#include "QueryEngine/JoinHashTable/HashJoin.h"
#include "QueryEngine/Utils/SegmentTree.h"
#include "Shared/sqltypes.h"
#include <functional>
#include <unordered_map>

Include dependency graph for WindowContext.h:

This graph shows which files directly or indirectly include this file:

Go to the source code of this file.

Classes
struct	AggregateTreeForWindowFraming
class	WindowFunctionContext
struct	WindowFunctionContext::AggregateState
class	WindowProjectNodeContext

Functions
bool	window_function_is_value (const SqlWindowFunctionKind kind)
bool	window_function_is_aggregate (const SqlWindowFunctionKind kind)
bool	window_function_requires_peer_handling (const Analyzer::WindowFunction *window_func)

Function Documentation

bool window_function_is_aggregate ( const SqlWindowFunctionKind  kind )

inline

Definition at line 44 of file WindowContext.h.

References AVG, COUNT, MAX, MIN, SUM, and SUM_INTERNAL.

Referenced by WindowFunctionContext::aggregateState(), WindowFunctionContext::aggregateStateCount(), WindowFunctionContext::aggregateStatePendingOutputs(), TargetExprCodegen::codegen(), GroupByAndAggregate::codegenWindowRowPointer(), WindowFunctionContext::compute(), and window_function_requires_peer_handling().

                                                                           {
  switch (kind) {
    case SqlWindowFunctionKind::AVG:
    case SqlWindowFunctionKind::MIN:
    case SqlWindowFunctionKind::MAX:
    case SqlWindowFunctionKind::SUM:
    case SqlWindowFunctionKind::COUNT:
    case SqlWindowFunctionKind::SUM_INTERNAL: {
      return true;
    }
    default: {
      return false;
    }
  }
}

Here is the caller graph for this function:

bool window_function_is_value ( const SqlWindowFunctionKind  kind )

inline

Definition at line 29 of file WindowContext.h.

References FIRST_VALUE, LAG, LAST_VALUE, and LEAD.

Referenced by RelAlgTranslator::translateWindowFunction().

                                                                       {
  switch (kind) {
    case SqlWindowFunctionKind::LAG:
    case SqlWindowFunctionKind::LEAD:
    case SqlWindowFunctionKind::FIRST_VALUE:
    case SqlWindowFunctionKind::LAST_VALUE: {
      return true;
    }
    default: {
      return false;
    }
  }
}

Here is the caller graph for this function:

bool window_function_requires_peer_handling

(

const Analyzer::WindowFunction *

window_func

)

Definition at line 522 of file WindowContext.cpp.

References Analyzer::WindowFunction::getKind(), Analyzer::WindowFunction::getOrderKeys(), MAX, MIN, and window_function_is_aggregate().

Referenced by TargetExprCodegen::codegenAggregate(), WindowFunctionContext::compute(), and WindowFunctionContext::computePartitionBuffer().

                                                                                       {
  if (!window_function_is_aggregate(window_func->getKind())) {
    return false;
  }
  if (window_func->getOrderKeys().empty()) {
    return true;
  }
  switch (window_func->getKind()) {
    case SqlWindowFunctionKind::MIN:
    case SqlWindowFunctionKind::MAX: {
      return false;
    }
    default: {
      return true;
    }
  }
}

Here is the call graph for this function:

Here is the caller graph for this function: