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

Class AbstractTopNFunction.AbstractTopNHelper

java.lang.Object

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

Direct Known Subclasses:

AppendOnlyTopNHelper, FastTop1Helper

Enclosing class:

AbstractTopNFunction

public abstract static class AbstractTopNFunction.AbstractTopNHelper
extends Object

An abstract helper to do the logic Top-n used for all top-n functions.

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.flink.streaming.api.operators.KeyContext	keyContext
protected boolean	outputRankNumber
protected Comparator<org.apache.flink.table.data.RowData>	sortKeyComparator
protected org.apache.flink.api.java.functions.KeySelector<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData>	sortKeySelector
protected AbstractTopNFunction	topNFunction
protected org.apache.flink.api.common.state.StateTtlConfig	ttlConfig

Constructor Summary

Constructors

Constructor	Description
AbstractTopNHelper(AbstractTopNFunction topNFunction)

Method Summary

Modifier and Type	Method	Description
void	accHitCount()
void	accRequestCount()
protected void	collectDelete(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out, org.apache.flink.table.data.RowData inputRow)
protected void	collectDelete(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out, org.apache.flink.table.data.RowData inputRow, long rank, long rankEnd)
protected void	collectInsert(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out, org.apache.flink.table.data.RowData inputRow)
protected void	collectInsert(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out, org.apache.flink.table.data.RowData inputRow, long rank, long rankEnd)
protected void	collectUpdateAfter(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out, org.apache.flink.table.data.RowData inputRow)
protected void	collectUpdateAfter(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out, org.apache.flink.table.data.RowData inputRow, long rank, long rankEnd)
protected void	collectUpdateBefore(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out, org.apache.flink.table.data.RowData inputRow)
protected void	collectUpdateBefore(org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out, org.apache.flink.table.data.RowData inputRow, long rank, long rankEnd)
protected boolean	isInRankEnd(long rank, long rankEnd)
protected void	registerMetric(long heapSize)

Methods inherited from class java.lang.Object

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

Field Detail

topNFunction

protected final AbstractTopNFunction topNFunction

ttlConfig

protected final org.apache.flink.api.common.state.StateTtlConfig ttlConfig

sortKeySelector

protected final org.apache.flink.api.java.functions.KeySelector<org.apache.flink.table.data.RowData,org.apache.flink.table.data.RowData> sortKeySelector

sortKeyComparator

protected final Comparator<org.apache.flink.table.data.RowData> sortKeyComparator

outputRankNumber

protected final boolean outputRankNumber

keyContext

protected final org.apache.flink.streaming.api.operators.KeyContext keyContext

Constructor Detail

AbstractTopNHelper

public AbstractTopNHelper(AbstractTopNFunction topNFunction)

Method Detail

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

collectInsert

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

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

collectDelete

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

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

collectUpdateAfter

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

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

collectUpdateBefore

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

isInRankEnd

protected boolean isInRankEnd(long rank,
                              long rankEnd)

accRequestCount

public void accRequestCount()

accHitCount

public void accHitCount()

registerMetric

protected void registerMetric(long heapSize)