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

Class DeduplicateFunctionBase<T,K,IN,OUT>

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.operators.deduplicate.DeduplicateFunctionBase<T,K,IN,OUT>

Type Parameters:

T - Type of the value in the state.

K - Type of the key.

IN - Type of the input elements.

OUT - Type of the returned elements.

All Implemented Interfaces:

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

Direct Known Subclasses:

AsyncStateRowTimeDeduplicateFunction, ProcTimeDeduplicateKeepFirstRowFunction, ProcTimeDeduplicateKeepLastRowFunction, RowTimeDeduplicateFunction

public abstract class DeduplicateFunctionBase<T,K,IN,OUT>
extends org.apache.flink.streaming.api.functions.KeyedProcessFunction<K,IN,OUT>

Base class for deduplicate function.

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 org.apache.flink.api.common.typeutils.TypeSerializer<OUT>	serializer
protected long	stateRetentionTime
protected org.apache.flink.api.common.typeinfo.TypeInformation<T>	typeInfo

Constructor Summary

Constructors

Constructor	Description
DeduplicateFunctionBase(org.apache.flink.api.common.typeinfo.TypeInformation<T> typeInfo, org.apache.flink.api.common.typeutils.TypeSerializer<OUT> serializer, long stateRetentionTime)

Method Summary

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, open, setRuntimeContext

Methods inherited from class java.lang.Object

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

Field Detail

typeInfo

protected final org.apache.flink.api.common.typeinfo.TypeInformation<T> typeInfo

stateRetentionTime

protected final long stateRetentionTime

serializer

protected final org.apache.flink.api.common.typeutils.TypeSerializer<OUT> serializer

Constructor Detail

DeduplicateFunctionBase

public DeduplicateFunctionBase(org.apache.flink.api.common.typeinfo.TypeInformation<T> typeInfo,
                               org.apache.flink.api.common.typeutils.TypeSerializer<OUT> serializer,
                               long stateRetentionTime)