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

Class AbstractSyncStateTopNFunction

java.lang.Object

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

org.apache.flink.streaming.api.functions.KeyedProcessFunction<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>

org.apache.flink.table.runtime.operators.rank.AbstractTopNFunction

org.apache.flink.table.runtime.operators.rank.AbstractSyncStateTopNFunction

All Implemented Interfaces:

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

Direct Known Subclasses:

AppendOnlyFirstNFunction, AppendOnlyTopNFunction, FastTop1Function, RetractableTopNFunction, UpdatableTopNFunction

public abstract class AbstractSyncStateTopNFunction
extends AbstractTopNFunction

Base class for TopN Function with sync state api.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.table.runtime.operators.rank.AbstractTopNFunction

AbstractTopNFunction.AbstractTopNHelper

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

Fields inherited from class org.apache.flink.table.runtime.operators.rank.AbstractTopNFunction

constantRankEnd, hitCount, inputRowType, invalidCounter, isConstantRankEnd, keyContext, outputRankNumber, rankEndFetcher, rankStart, requestCount, sortKeyComparator, sortKeySelector, ttlConfig

Constructor Summary

Constructors

Constructor	Description
AbstractSyncStateTopNFunction(org.apache.flink.api.common.state.StateTtlConfig ttlConfig, InternalTypeInfo<org.apache.flink.table.data.RowData> inputRowType, GeneratedRecordComparator generatedSortKeyComparator, RowDataKeySelector sortKeySelector, RankType rankType, RankRange rankRange, boolean generateUpdateBefore, boolean outputRankNumber)

Method Summary

Modifier and Type	Method	Description
protected void	collectDelete(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out, org.apache.flink.table.data.RowData inputRow, long rank)
protected void	collectInsert(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out, org.apache.flink.table.data.RowData inputRow, long rank)
protected void	collectUpdateAfter(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out, org.apache.flink.table.data.RowData inputRow, long rank)
protected void	collectUpdateBefore(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out, org.apache.flink.table.data.RowData inputRow, long rank)
protected long	initRankEnd(org.apache.flink.table.data.RowData row)	Initialize rank end.
protected boolean	isInRankEnd(long rank)
protected boolean	isInRankRange(long rank)
void	open(org.apache.flink.api.common.functions.OpenContext openContext)

Methods inherited from class org.apache.flink.table.runtime.operators.rank.AbstractTopNFunction

checkSortKeyInBufferRange, collectDelete, collectDelete, collectInsert, collectInsert, collectUpdateAfter, collectUpdateAfter, collectUpdateBefore, collectUpdateBefore, getDefaultTopNSize, hasOffset, isInRankRange, registerMetric, registerMetric, setKeyContext

Methods inherited from class org.apache.flink.streaming.api.functions.KeyedProcessFunction

onTimer, processElement

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

close, getIterationRuntimeContext, getRuntimeContext, setRuntimeContext

Methods inherited from class java.lang.Object

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

Field Detail

rankEnd

protected long rankEnd

Constructor Detail

AbstractSyncStateTopNFunction

public AbstractSyncStateTopNFunction(org.apache.flink.api.common.state.StateTtlConfig ttlConfig,
                                     InternalTypeInfo<org.apache.flink.table.data.RowData> inputRowType,
                                     GeneratedRecordComparator generatedSortKeyComparator,
                                     RowDataKeySelector sortKeySelector,
                                     RankType rankType,
                                     RankRange rankRange,
                                     boolean generateUpdateBefore,
                                     boolean outputRankNumber)

Method Detail

open

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

Specified by:

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

Overrides:

open in class AbstractTopNFunction

Throws:

Exception

initRankEnd

protected long initRankEnd(org.apache.flink.table.data.RowData row)
                    throws Exception

Initialize rank end.

Parameters:

row - input record

Returns:

rank end

Throws:

Exception

isInRankEnd

protected boolean isInRankEnd(long rank)

isInRankRange

protected boolean isInRankRange(long rank)

collectInsert

protected void collectInsert(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out,
                             org.apache.flink.table.data.RowData inputRow,
                             long rank)

collectDelete

protected void collectDelete(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out,
                             org.apache.flink.table.data.RowData inputRow,
                             long rank)

collectUpdateAfter

protected void collectUpdateAfter(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out,
                                  org.apache.flink.table.data.RowData inputRow,
                                  long rank)

collectUpdateBefore

protected void collectUpdateBefore(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out,
                                   org.apache.flink.table.data.RowData inputRow,
                                   long rank)