public class RowTimeRangeUnboundedPrecedingFunction<K> extends AbstractRowTimeUnboundedPrecedingOver<K>
E.g.: SELECT rowtime, b, c, min(c) OVER (PARTITION BY b ORDER BY rowtime RANGE BETWEEN UNBOUNDED preceding AND CURRENT ROW), max(c) OVER (PARTITION BY b ORDER BY rowtime RANGE BETWEEN UNBOUNDED preceding AND CURRENT ROW) FROM T.
KeyedProcessFunction.Context, KeyedProcessFunction.OnTimerContext
function, output
stateCleaningEnabled
Constructor and Description |
---|
RowTimeRangeUnboundedPrecedingFunction(long minRetentionTime,
long maxRetentionTime,
GeneratedAggsHandleFunction genAggsHandler,
LogicalType[] accTypes,
LogicalType[] inputFieldTypes,
int rowTimeIdx) |
Modifier and Type | Method and Description |
---|---|
void |
processElementsWithSameTimestamp(List<RowData> curRowList,
Collector<RowData> out)
Process the same timestamp datas, the mechanism is different between rows and range window.
|
close, getCounter, onTimer, open, processElement
cleanupState, initCleanupTimeState, isProcessingTimeTimer, needToCleanupState, registerProcessingCleanupTimer
getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
registerProcessingCleanupTimer
public RowTimeRangeUnboundedPrecedingFunction(long minRetentionTime, long maxRetentionTime, GeneratedAggsHandleFunction genAggsHandler, LogicalType[] accTypes, LogicalType[] inputFieldTypes, int rowTimeIdx)
public void processElementsWithSameTimestamp(List<RowData> curRowList, Collector<RowData> out) throws Exception
AbstractRowTimeUnboundedPrecedingOver
processElementsWithSameTimestamp
in class AbstractRowTimeUnboundedPrecedingOver<K>
Exception
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.