Package org.apache.flink.table.runtime.operators.over

Class AbstractRowTimeUnboundedPrecedingOver<K>

java.lang.Object

org.apache.flink.api.common.functions.AbstractRichFunction

org.apache.flink.streaming.api.functions.KeyedProcessFunction<K,IN,OUT>

org.apache.flink.table.runtime.functions.KeyedProcessFunctionWithCleanupState<K,org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>

org.apache.flink.table.runtime.operators.over.AbstractRowTimeUnboundedPrecedingOver<K>

All Implemented Interfaces:

Serializable, org.apache.flink.api.common.functions.Function, org.apache.flink.api.common.functions.RichFunction, CleanupState

Direct Known Subclasses:

RowTimeRangeUnboundedPrecedingFunction, RowTimeRowsUnboundedPrecedingFunction

public abstract class AbstractRowTimeUnboundedPrecedingOver<K>
extends KeyedProcessFunctionWithCleanupState<K,org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>

A basic implementation to support unbounded event-time over-window.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.streaming.api.functions.KeyedProcessFunction

org.apache.flink.streaming.api.functions.KeyedProcessFunction.Context, org.apache.flink.streaming.api.functions.KeyedProcessFunction.OnTimerContext

Field Summary

Fields

Modifier and Type	Field	Description
protected AggsHandleFunction	function
protected org.apache.flink.table.data.utils.JoinedRowData	output

Fields inherited from class org.apache.flink.table.runtime.functions.KeyedProcessFunctionWithCleanupState

stateCleaningEnabled

Constructor Summary

Constructors

Constructor	Description
AbstractRowTimeUnboundedPrecedingOver(long minRetentionTime, long maxRetentionTime, GeneratedAggsHandleFunction genAggsHandler, org.apache.flink.table.types.logical.LogicalType[] accTypes, org.apache.flink.table.types.logical.LogicalType[] inputFieldTypes, int rowTimeIdx)

Method Summary

Modifier and Type	Method	Description
void	close()
protected org.apache.flink.metrics.Counter	getCounter()
void	onTimer(long timestamp, org.apache.flink.streaming.api.functions.KeyedProcessFunction.OnTimerContext ctx, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
void	open(org.apache.flink.api.common.functions.OpenContext openContext)
void	processElement(org.apache.flink.table.data.RowData input, org.apache.flink.streaming.api.functions.KeyedProcessFunction.Context ctx, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)	Puts an element from the input stream into state if it is not late.
protected abstract void	processElementsWithSameTimestamp(List<org.apache.flink.table.data.RowData> curRowList, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)	Process the same timestamp datas, the mechanism is different between rows and range window.

Methods inherited from class org.apache.flink.table.runtime.functions.KeyedProcessFunctionWithCleanupState

cleanupState, initCleanupTimeState, isProcessingTimeTimer, needToCleanupState, registerProcessingCleanupTimer

Methods inherited from class org.apache.flink.api.common.functions.AbstractRichFunction

getIterationRuntimeContext, getRuntimeContext, open, setRuntimeContext

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.flink.table.runtime.functions.CleanupState

registerProcessingCleanupTimer

Field Detail

output

protected transient org.apache.flink.table.data.utils.JoinedRowData output

function

protected transient AggsHandleFunction function

Constructor Detail

AbstractRowTimeUnboundedPrecedingOver

public AbstractRowTimeUnboundedPrecedingOver(long minRetentionTime,
                                             long maxRetentionTime,
                                             GeneratedAggsHandleFunction genAggsHandler,
                                             org.apache.flink.table.types.logical.LogicalType[] accTypes,
                                             org.apache.flink.table.types.logical.LogicalType[] inputFieldTypes,
                                             int rowTimeIdx)

Method Detail

getCounter

@VisibleForTesting
protected org.apache.flink.metrics.Counter getCounter()

open

public void open(org.apache.flink.api.common.functions.OpenContext openContext)
          throws Exception

Throws:

Exception

processElement

public void processElement(org.apache.flink.table.data.RowData input,
                           org.apache.flink.streaming.api.functions.KeyedProcessFunction.Context ctx,
                           org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
                    throws Exception

Puts an element from the input stream into state if it is not late. Registers a timer for the next watermark.

Specified by:

processElement in class org.apache.flink.streaming.api.functions.KeyedProcessFunction<K,org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>

Parameters:

input - The input value.

ctx - A KeyedProcessFunction.Context that allows querying the timestamp of the element and getting TimerService for registering timers and querying the time. The context is only valid during the invocation of this method, do not store it.

out - The collector for returning result values.

Throws:

Exception

onTimer

public void onTimer(long timestamp,
                    org.apache.flink.streaming.api.functions.KeyedProcessFunction.OnTimerContext ctx,
                    org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
             throws Exception

Overrides:

onTimer in class org.apache.flink.streaming.api.functions.KeyedProcessFunction<K,org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>

Throws:

Exception

processElementsWithSameTimestamp

protected abstract void processElementsWithSameTimestamp(List<org.apache.flink.table.data.RowData> curRowList,
                                                         org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
                                                  throws Exception

Process the same timestamp datas, the mechanism is different between rows and range window.

Throws:

Exception

close

public void close()
           throws Exception

Specified by:

close in interface org.apache.flink.api.common.functions.RichFunction

Overrides:

close in class org.apache.flink.api.common.functions.AbstractRichFunction

Throws:

Exception