org.apache.flink.streaming.api.operators

Interface KeyContextHandler

All Known Implementing Classes:

AbstractArrowPythonAggregateFunctionOperator, AbstractEmbeddedDataStreamPythonFunctionOperator, AbstractEmbeddedPythonFunctionOperator, AbstractEmbeddedStatelessFunctionOperator, AbstractExternalDataStreamPythonFunctionOperator, AbstractExternalOneInputPythonFunctionOperator, AbstractExternalPythonFunctionOperator, AbstractExternalTwoInputPythonFunctionOperator, AbstractInput, AbstractMapBundleOperator, AbstractOneInputEmbeddedPythonFunctionOperator, AbstractOneInputPythonFunctionOperator, AbstractPythonFunctionOperator, AbstractPythonScalarFunctionOperator, AbstractPythonStreamAggregateOperator, AbstractPythonStreamGroupAggregateOperator, AbstractStatelessFunctionOperator, AbstractStreamArrowPythonBoundedRangeOperator, AbstractStreamArrowPythonBoundedRowsOperator, AbstractStreamArrowPythonOverWindowAggregateFunctionOperator, AbstractStreamingJoinOperator, AbstractStreamingWriter, AbstractStreamOperator, AbstractTwoInputEmbeddedPythonFunctionOperator, AbstractUdfStreamOperator, AggregateWindowOperator, ArrowPythonScalarFunctionOperator, AsyncWaitOperator, BaseTwoInputStreamOperatorWithStateRetention, BatchArrowPythonGroupAggregateFunctionOperator, BatchArrowPythonGroupWindowAggregateFunctionOperator, BatchArrowPythonOverWindowAggregateFunctionOperator, BatchCoBroadcastWithKeyedOperator, BatchCoBroadcastWithNonKeyedOperator, BatchCompactCoordinator, BatchCompactOperator, BatchFileWriter, BatchGroupedReduceOperator, BootstrapStreamTaskRunner, BroadcastStateBootstrapOperator, BufferDataOverWindowOperator, CacheTransformationTranslator.IdentityStreamOperator, CacheTransformationTranslator.NoOpStreamOperator, CepOperator, CoBroadcastWithKeyedOperator, CoBroadcastWithNonKeyedOperator, CollectSinkOperator, CompactCoordinator, CompactCoordinator, CompactCoordinatorStateHandler, CompactFileWriter, CompactOperator, CompactorOperator, CompactorOperatorStateHandler, ConstraintEnforcer, ContinuousFileReaderOperator, CoProcessOperator, CoStreamFlatMap, CoStreamMap, DelegateOperatorTransformation.DelegateOperator, DynamicFilteringDataCollectorOperator, EmbeddedPythonBatchCoBroadcastProcessOperator, EmbeddedPythonBatchKeyedCoBroadcastProcessOperator, EmbeddedPythonCoProcessOperator, EmbeddedPythonKeyedCoProcessOperator, EmbeddedPythonKeyedProcessOperator, EmbeddedPythonProcessOperator, EmbeddedPythonScalarFunctionOperator, EmbeddedPythonTableFunctionOperator, EmbeddedPythonWindowOperator, EvictingWindowOperator, ExternalPythonBatchCoBroadcastProcessOperator, ExternalPythonBatchKeyedCoBroadcastProcessOperator, ExternalPythonCoProcessOperator, ExternalPythonKeyedCoProcessOperator, ExternalPythonKeyedProcessOperator, ExternalPythonProcessOperator, FirstInputOfTwoInput, GenericWriteAheadSink, GroupReduceOperator, HashJoinOperator, HiveScriptTransformOperator, InputBase, InputConversionOperator, IntervalJoinOperator, KeyedCoProcessOperator, KeyedCoProcessOperatorWithWatermarkDelay, KeyedMapBundleOperator, KeyedProcessOperator, KeyedStateBootstrapOperator, LegacyKeyedCoProcessOperator, LegacyKeyedProcessOperator, LimitOperator, LocalSlicingWindowAggOperator, MapBundleOperator, NonBufferOverWindowOperator, OneInput, OutputConversionOperator, PartitionCommitter, ProcessOperator, ProcTimeMiniBatchAssignerOperator, ProcTimeSortOperator, PythonScalarFunctionOperator, PythonStreamGroupAggregateOperator, PythonStreamGroupTableAggregateOperator, PythonStreamGroupWindowAggregateOperator, PythonTableFunctionOperator, QueryableAppendingStateOperator, QueryableValueStateOperator, RankOperator, RowKindSetter, RowTimeMiniBatchAssginerOperator, RowTimeSortOperator, SecondInputOfTwoInput, SinkOperator, SinkUpsertMaterializer, SlicingWindowOperator, SortLimitOperator, SortMergeJoinOperator, SortOperator, SourceOperator, StateBootstrapOperator, StreamArrowPythonGroupWindowAggregateFunctionOperator, StreamArrowPythonProcTimeBoundedRangeOperator, StreamArrowPythonProcTimeBoundedRowsOperator, StreamArrowPythonRowTimeBoundedRangeOperator, StreamArrowPythonRowTimeBoundedRowsOperator, StreamFilter, StreamFlatMap, StreamGroupedReduceOperator, StreamingFileWriter, StreamingJoinOperator, StreamingSemiAntiJoinOperator, StreamMap, StreamProject, StreamRecordTimestampInserter, StreamSink, StreamSortOperator, StreamSource, TableAggregateWindowOperator, TableStreamOperator, TemporalProcessTimeJoinOperator, TemporalRowTimeJoinOperator, TimestampsAndWatermarksOperator, UnionStreamOperator, WatermarkAssignerOperator, WindowJoinOperator, WindowOperator, WindowOperator, WindowTableFunctionOperator

@Internal
public interface KeyContextHandler

This interface is used to optimize the calls of Input.setKeyContextElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN>), StreamOperator.setKeyContextElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?>) and StreamOperator.setKeyContextElement2(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?>). We can decide(at the inputs/operators initialization) whether to omit the calls of "setKeyContextElement" according to the return value of hasKeyContext(). In this way, we can omit the calls of "setKeyContextElement" for inputs/operators that don't have "KeyContext".

All inputs/operators that want to optimize the "setKeyContextElement" calls should implement this interface.

Method Summary

Modifier and Type	Method and Description
default boolean	hasKeyContext() Whether the Input has "KeyContext".
default boolean	hasKeyContext1() Whether the first input of StreamOperator has "KeyContext".
default boolean	hasKeyContext2() Whether the second input of StreamOperator has "KeyContext".

Method Detail

hasKeyContext

default boolean hasKeyContext()

Whether the Input has "KeyContext". If false, we can omit the call of Input.setKeyContextElement(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<IN>) for each record.

Returns:

True if the Input has "KeyContext", false otherwise.

hasKeyContext1

default boolean hasKeyContext1()

Whether the first input of StreamOperator has "KeyContext". If false, we can omit the call of StreamOperator.setKeyContextElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?>) for each record arrived on the first input.

Returns:

True if the first input has "KeyContext", false otherwise.

hasKeyContext2

default boolean hasKeyContext2()

Whether the second input of StreamOperator has "KeyContext". If false, we can omit the call of StreamOperator.setKeyContextElement1(org.apache.flink.streaming.runtime.streamrecord.StreamRecord<?>) for each record arrived on the second input.

Returns:

True if the second input has "KeyContext", false otherwise.