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

Class FastTop1Helper

java.lang.Object

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

org.apache.flink.table.runtime.operators.rank.utils.FastTop1Helper

public abstract class FastTop1Helper
extends AbstractTopNFunction.AbstractTopNHelper

A helper to help do the logic 'Top-1' in FastTop1Function and AsyncStateFastTop1Function.

Field Summary

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

keyContext, outputRankNumber, sortKeyComparator, sortKeySelector, topNFunction, ttlConfig

Constructor Summary

Constructors

Constructor	Description
FastTop1Helper(AbstractTopNFunction topNFunction, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> inputRowSer, long cacheSize, long topNSize)

Method Summary

Modifier and Type	Method	Description
void	flushAllCacheToState()
abstract void	flushBufferToState(org.apache.flink.table.data.RowData currentKey, org.apache.flink.table.data.RowData value)
org.apache.flink.table.data.RowData	getPrevRowFromCache(org.apache.flink.table.data.RowData currentKey)
void	processAsFirstRow(org.apache.flink.table.data.RowData input, org.apache.flink.table.data.RowData currentKey, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
void	processWithPrevRow(org.apache.flink.table.data.RowData input, org.apache.flink.table.data.RowData currentKey, org.apache.flink.table.data.RowData prevRow, org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
void	registerMetric()

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

accHitCount, accRequestCount, collectDelete, collectDelete, collectInsert, collectInsert, collectUpdateAfter, collectUpdateAfter, collectUpdateBefore, collectUpdateBefore, isInRankEnd, registerMetric

Methods inherited from class java.lang.Object

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

Constructor Detail

FastTop1Helper

public FastTop1Helper(AbstractTopNFunction topNFunction,
                      org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> inputRowSer,
                      long cacheSize,
                      long topNSize)

Method Detail

getPrevRowFromCache

@Nullable
public org.apache.flink.table.data.RowData getPrevRowFromCache(org.apache.flink.table.data.RowData currentKey)

processAsFirstRow

public void processAsFirstRow(org.apache.flink.table.data.RowData input,
                              org.apache.flink.table.data.RowData currentKey,
                              org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)

processWithPrevRow

public void processWithPrevRow(org.apache.flink.table.data.RowData input,
                               org.apache.flink.table.data.RowData currentKey,
                               org.apache.flink.table.data.RowData prevRow,
                               org.apache.flink.util.Collector<org.apache.flink.table.data.RowData> out)
                        throws Exception

Throws:

Exception

flushAllCacheToState

public void flushAllCacheToState()
                          throws Exception

Throws:

Exception

flushBufferToState

public abstract void flushBufferToState(org.apache.flink.table.data.RowData currentKey,
                                        org.apache.flink.table.data.RowData value)
                                 throws Exception

Throws:

Exception

registerMetric

public void registerMetric()