public class RowTimeUnboundedRangeOver extends RowTimeUnboundedOver
ProcessFunction.Context, ProcessFunction.OnTimerContext
Constructor and Description |
---|
RowTimeUnboundedRangeOver(GeneratedAggregationsFunction genAggregations,
TypeInformation<Row> intermediateType,
TypeInformation<CRow> inputType,
StreamQueryConfig queryConfig) |
Modifier and Type | Method and Description |
---|---|
void |
processElementsWithSameTimestamp(List<Row> curRowList,
Row lastAccumulator,
Collector<CRow> out)
Process the same timestamp datas, the mechanism is different between
rows and range window.
|
function, onTimer, open, output, processElement
cleanupState, initCleanupTimeState, isProcessingTimeTimer, maxRetentionTime, minRetentionTime, needToCleanupState, registerProcessingCleanupTimer, stateCleaningEnabled
close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext
public RowTimeUnboundedRangeOver(GeneratedAggregationsFunction genAggregations, TypeInformation<Row> intermediateType, TypeInformation<CRow> inputType, StreamQueryConfig queryConfig)
public void processElementsWithSameTimestamp(List<Row> curRowList, Row lastAccumulator, Collector<CRow> out)
RowTimeUnboundedOver
processElementsWithSameTimestamp
in class RowTimeUnboundedOver
curRowList
- (undocumented)lastAccumulator
- (undocumented)out
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.