BasePartitionEvaluator |
This class is mostly used for RANGE windowing type to do some optimization.
|
BasePartitionEvaluator.AvgPartitionDoubleEvaluator |
|
BasePartitionEvaluator.AvgPartitionEvaluator<ResultType extends org.apache.hadoop.io.Writable> |
The partition evalulator for average function
|
BasePartitionEvaluator.AvgPartitionHiveDecimalEvaluator |
|
BasePartitionEvaluator.Range |
Internal class to represent a window range in a partition by searching the
relative position (ROWS) or relative value (RANGE) of the current row
|
BasePartitionEvaluator.SumPartitionDoubleEvaluator |
|
BasePartitionEvaluator.SumPartitionEvaluator<ResultType extends org.apache.hadoop.io.Writable> |
The base type for sum operator evaluator when a partition data is available
and streaming process is not possible.
|
BasePartitionEvaluator.SumPartitionHiveDecimalEvaluator |
|
BasePartitionEvaluator.SumPartitionLongEvaluator |
|
MatchPath |
return rows that meet a specified pattern.
|
MatchPath.Chain |
|
MatchPath.MatchPathResolver |
|
MatchPath.Plus |
|
MatchPath.ResultExpressionParser |
|
MatchPath.ResultExprInfo |
|
MatchPath.Star |
|
MatchPath.Symbol |
|
MatchPath.SymbolFunction |
|
MatchPath.SymbolFunctionResult |
|
MatchPath.SymbolParser |
|
Noop |
|
Noop.NoopResolver |
|
NoopStreaming |
|
NoopStreaming.NoopStreamingResolver |
|
NoopWithMap |
|
NoopWithMap.NoopWithMapResolver |
|
NoopWithMapStreaming |
|
NoopWithMapStreaming.NoopWithMapStreamingResolver |
|
TableFunctionEvaluator |
|
TableFunctionResolver |
|
ValueBoundaryScanner |
|
WindowingTableFunction |
|
WindowingTableFunction.SameList<E> |
|
WindowingTableFunction.WindowingTableFunctionResolver |
|