AggregateAggFunction(GeneratedAggregationsFunction genAggregations) |
DataSetAggFunction(GeneratedAggregationsFunction genAggregations) |
DataSetFinalAggFunction(GeneratedAggregationsFunction genAggregations) |
DataSetPreAggFunction(GeneratedAggregationsFunction genAggregations) |
DataSetSessionWindowAggReduceGroupFunction(GeneratedAggregationsFunction genAggregations,
int keysAndAggregatesArity,
scala.Option<Object> finalRowWindowStartPos,
scala.Option<Object> finalRowWindowEndPos,
long gap,
boolean isInputCombined) |
DataSetSessionWindowAggregatePreProcessor(GeneratedAggregationsFunction genAggregations,
int keysAndAggregatesArity,
long gap,
TypeInformation<Row> intermediateRowType) |
DataSetSlideTimeWindowAggReduceGroupFunction(GeneratedAggregationsFunction genAggregations,
int keysAndAggregatesArity,
long windowSize,
long windowSlide,
TypeInformation<Row> returnType) |
DataSetSlideWindowAggReduceCombineFunction(GeneratedAggregationsFunction genPreAggregations,
GeneratedAggregationsFunction genFinalAggregations,
int keysAndAggregatesArity,
scala.Option<Object> finalRowWindowStartPos,
scala.Option<Object> finalRowWindowEndPos,
long windowSize) |
DataSetSlideWindowAggReduceGroupFunction(GeneratedAggregationsFunction genAggregations,
int keysAndAggregatesArity,
scala.Option<Object> finalRowWindowStartPos,
scala.Option<Object> finalRowWindowEndPos,
long windowSize) |
DataSetTumbleCountWindowAggReduceGroupFunction(GeneratedAggregationsFunction genAggregations,
long windowSize) |
DataSetTumbleTimeWindowAggReduceCombineFunction(GeneratedAggregationsFunction genPreAggregations,
GeneratedAggregationsFunction genFinalAggregations,
long windowSize,
scala.Option<Object> windowStartPos,
scala.Option<Object> windowEndPos,
int keysAndAggregatesArity) |
DataSetTumbleTimeWindowAggReduceGroupFunction(GeneratedAggregationsFunction genAggregations,
long windowSize,
scala.Option<Object> windowStartPos,
scala.Option<Object> windowEndPos,
int keysAndAggregatesArity) |
DataSetWindowAggMapFunction(GeneratedAggregationsFunction genAggregations,
int timeFieldPos,
scala.Option<Object> tumbleTimeWindowSize,
TypeInformation<Row> returnType) |
GroupAggProcessFunction(GeneratedAggregationsFunction genAggregations,
RowTypeInfo aggregationStateType,
boolean generateRetraction,
StreamQueryConfig queryConfig) |
ProcTimeBoundedRangeOver(GeneratedAggregationsFunction genAggregations,
long precedingTimeBoundary,
RowTypeInfo aggregatesTypeInfo,
TypeInformation<CRow> inputType,
StreamQueryConfig queryConfig) |
ProcTimeBoundedRowsOver(GeneratedAggregationsFunction genAggregations,
long precedingOffset,
RowTypeInfo aggregatesTypeInfo,
TypeInformation<CRow> inputType,
StreamQueryConfig queryConfig) |
ProcTimeUnboundedOver(GeneratedAggregationsFunction genAggregations,
RowTypeInfo aggregationStateType,
StreamQueryConfig queryConfig) |
RowTimeBoundedRangeOver(GeneratedAggregationsFunction genAggregations,
RowTypeInfo aggregationStateType,
CRowTypeInfo inputRowType,
long precedingOffset,
StreamQueryConfig queryConfig) |
RowTimeBoundedRowsOver(GeneratedAggregationsFunction genAggregations,
RowTypeInfo aggregationStateType,
CRowTypeInfo inputRowType,
long precedingOffset,
StreamQueryConfig queryConfig) |
RowTimeUnboundedOver(GeneratedAggregationsFunction genAggregations,
TypeInformation<Row> intermediateType,
TypeInformation<CRow> inputType,
StreamQueryConfig queryConfig) |
RowTimeUnboundedRangeOver(GeneratedAggregationsFunction genAggregations,
TypeInformation<Row> intermediateType,
TypeInformation<CRow> inputType,
StreamQueryConfig queryConfig) |
RowTimeUnboundedRowsOver(GeneratedAggregationsFunction genAggregations,
TypeInformation<Row> intermediateType,
TypeInformation<CRow> inputType,
StreamQueryConfig queryConfig) |