| 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 |
|