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
struct	WindowFrameBoundFuncArgs
struct	WindowPartitionBufferPtrs
class	WindowFunctionContext
struct	WindowFunctionContext::AggregateState
class	WindowProjectNodeContext

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

Function Documentation

bool window_function_conditional_aggregate ( const SqlWindowFunctionKind  kind )

inline

Definition at line 78 of file WindowContext.h.

References COUNT_IF, and SUM_IF.

Referenced by Executor::codegenWindowFunctionAggregateCalls().

                                                                                    {
  switch (kind) {
    case SqlWindowFunctionKind::COUNT_IF:
    case SqlWindowFunctionKind::SUM_IF:
      return true;
    default:
      return false;
  }
}

Here is the caller graph for this function:

bool window_function_is_aggregate ( const SqlWindowFunctionKind  kind )

inline

Definition at line 61 of file WindowContext.h.

References AVG, CONDITIONAL_CHANGE_EVENT, COUNT, COUNT_IF, MAX, MIN, SUM, SUM_IF, 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:
    case SqlWindowFunctionKind::COUNT_IF:
    case SqlWindowFunctionKind::SUM_IF:
    case SqlWindowFunctionKind::CONDITIONAL_CHANGE_EVENT:
      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, FIRST_VALUE_IN_FRAME, LAG, LAG_IN_FRAME, LAST_VALUE, LAST_VALUE_IN_FRAME, LEAD, LEAD_IN_FRAME, NTH_VALUE, and NTH_VALUE_IN_FRAME.

Referenced by RelAlgTranslator::translateWindowFunction().

                                                                       {
  switch (kind) {
    case SqlWindowFunctionKind::LAG:
    case SqlWindowFunctionKind::LEAD:
    case SqlWindowFunctionKind::FIRST_VALUE:
    case SqlWindowFunctionKind::LAST_VALUE:
    case SqlWindowFunctionKind::NTH_VALUE:
    case SqlWindowFunctionKind::LAG_IN_FRAME:
    case SqlWindowFunctionKind::LEAD_IN_FRAME:
    case SqlWindowFunctionKind::FIRST_VALUE_IN_FRAME:
    case SqlWindowFunctionKind::LAST_VALUE_IN_FRAME:
    case SqlWindowFunctionKind::NTH_VALUE_IN_FRAME:
      return true;
    default:
      return false;
  }
}

Here is the caller graph for this function:

bool window_function_is_value_with_frame ( const SqlWindowFunctionKind  kind )

inline

Definition at line 47 of file WindowContext.h.

References FIRST_VALUE_IN_FRAME, LAG_IN_FRAME, LAST_VALUE_IN_FRAME, LEAD_IN_FRAME, and NTH_VALUE_IN_FRAME.

Referenced by RelAlgTranslator::translateWindowFunction().

                                                                                  {
  switch (kind) {
    case SqlWindowFunctionKind::LAG_IN_FRAME:
    case SqlWindowFunctionKind::LEAD_IN_FRAME:
    case SqlWindowFunctionKind::FIRST_VALUE_IN_FRAME:
    case SqlWindowFunctionKind::LAST_VALUE_IN_FRAME:
    case SqlWindowFunctionKind::NTH_VALUE_IN_FRAME:
      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 531 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: