Uses of Interface
org.apache.flink.streaming.api.operators.KeyContext

Packages that use KeyContext

Package	Description
org.apache.flink.streaming.api.functions.query
org.apache.flink.streaming.api.functions.source
org.apache.flink.streaming.api.operators
org.apache.flink.streaming.api.operators.async
org.apache.flink.streaming.api.operators.co
org.apache.flink.streaming.api.operators.collect
org.apache.flink.streaming.api.operators.sorted.state
org.apache.flink.streaming.runtime.operators	This package contains the operators that perform the stream transformations.
org.apache.flink.streaming.runtime.operators.windowing	This package contains the operators that implement the various window operations on data streams.
org.apache.flink.streaming.runtime.translators

Uses of KeyContext in org.apache.flink.streaming.api.functions.query

Classes in org.apache.flink.streaming.api.functions.query that implement KeyContext

Modifier and Type	Class	Description
class	QueryableAppendingStateOperator<IN>	Internal operator handling queryable AppendingState instances.
class	QueryableValueStateOperator<IN>	Internal operator handling queryable ValueState instances.

Uses of KeyContext in org.apache.flink.streaming.api.functions.source

Classes in org.apache.flink.streaming.api.functions.source that implement KeyContext

Modifier and Type	Class	Description
class	ContinuousFileReaderOperator<OUT,T extends TimestampedInputSplit>	The operator that reads the splits received from the preceding ContinuousFileMonitoringFunction.

Uses of KeyContext in org.apache.flink.streaming.api.operators

Subinterfaces of KeyContext in org.apache.flink.streaming.api.operators

Modifier and Type	Interface	Description
interface	MultipleInputStreamOperator<OUT>	Interface for stream operators with multiple Inputs.
interface	OneInputStreamOperator<IN,OUT>	Interface for stream operators with one input.
interface	StreamOperator<OUT>	Basic interface for stream operators.
interface	TwoInputStreamOperator<IN1,IN2,OUT>	Interface for stream operators with two inputs.

Classes in org.apache.flink.streaming.api.operators that implement KeyContext

Modifier and Type	Class	Description
class	AbstractStreamOperator<OUT>	Base class for all stream operators.
class	AbstractStreamOperatorV2<OUT>	New base class for all stream operators, intended to eventually replace AbstractStreamOperator.
class	AbstractUdfStreamOperator<OUT,F extends org.apache.flink.api.common.functions.Function>	This is used as the base class for operators that have a user-defined function.
class	BatchGroupedReduceOperator<IN,KEY>	A StreamOperator for executing a ReduceFunction on a KeyedStream in a RuntimeExecutionMode.BATCH mode.
class	KeyedProcessOperator<K,IN,OUT>	A StreamOperator for executing KeyedProcessFunctions.
class	LegacyKeyedProcessOperator<K,IN,OUT>	Deprecated. Replaced by KeyedProcessOperator which takes KeyedProcessFunction
class	ProcessOperator<IN,OUT>	A StreamOperator for executing ProcessFunctions.
class	SourceOperator<OUT,SplitT extends org.apache.flink.api.connector.source.SourceSplit>	Base source operator only used for integrating the source reader which is proposed by FLIP-27.
class	StreamFilter<IN>	A StreamOperator for executing FilterFunctions.
class	StreamFlatMap<IN,OUT>	A StreamOperator for executing FlatMapFunctions.
class	StreamGroupedReduceOperator<IN>	A StreamOperator for executing a ReduceFunction on a KeyedStream.
class	StreamMap<IN,OUT>	A StreamOperator for executing MapFunctions.
class	StreamProject<IN,OUT extends org.apache.flink.api.java.tuple.Tuple>	A StreamOperator for executing projections on streams.
class	StreamSink<IN>	A StreamOperator for executing SinkFunctions.
class	StreamSource<OUT,SRC extends SourceFunction<OUT>>	Deprecated. This class is based on the SourceFunction API, which is due to be removed.

Methods in org.apache.flink.streaming.api.operators with parameters of type KeyContext

Modifier and Type	Method	Description
<K> InternalTimeServiceManager<K>	InternalTimeServiceManager.Provider.create(org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> keyedStatedBackend, ClassLoader userClassloader, KeyContext keyContext, ProcessingTimeService processingTimeService, Iterable<org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider> rawKeyedStates, StreamTaskCancellationContext cancellationContext)
static <K> InternalTimeServiceManagerImpl<K>	InternalTimeServiceManagerImpl.create(org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> keyedStateBackend, ClassLoader userClassloader, KeyContext keyContext, ProcessingTimeService processingTimeService, Iterable<org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider> rawKeyedStates, StreamTaskCancellationContext cancellationContext)	A factory method for creating the InternalTimeServiceManagerImpl.
StreamOperatorStateContext	StreamTaskStateInitializer.streamOperatorStateContext(org.apache.flink.runtime.jobgraph.OperatorID operatorID, String operatorClassName, ProcessingTimeService processingTimeService, KeyContext keyContext, org.apache.flink.api.common.typeutils.TypeSerializer<?> keySerializer, org.apache.flink.core.fs.CloseableRegistry streamTaskCloseableRegistry, org.apache.flink.metrics.MetricGroup metricGroup, double managedMemoryFraction, boolean isUsingCustomRawKeyedState)	Returns the StreamOperatorStateContext for an AbstractStreamOperator that runs in the stream task that owns this manager.
StreamOperatorStateContext	StreamTaskStateInitializerImpl.streamOperatorStateContext(org.apache.flink.runtime.jobgraph.OperatorID operatorID, String operatorClassName, ProcessingTimeService processingTimeService, KeyContext keyContext, org.apache.flink.api.common.typeutils.TypeSerializer<?> keySerializer, org.apache.flink.core.fs.CloseableRegistry streamTaskCloseableRegistry, org.apache.flink.metrics.MetricGroup metricGroup, double managedMemoryFraction, boolean isUsingCustomRawKeyedState)

Uses of KeyContext in org.apache.flink.streaming.api.operators.async

Classes in org.apache.flink.streaming.api.operators.async that implement KeyContext

Modifier and Type	Class	Description
class	AsyncWaitOperator<IN,OUT>	The AsyncWaitOperator allows to asynchronously process incoming stream records.

Uses of KeyContext in org.apache.flink.streaming.api.operators.co

Classes in org.apache.flink.streaming.api.operators.co that implement KeyContext

Modifier and Type	Class	Description
class	BatchCoBroadcastWithKeyedOperator<KS,IN1,IN2,OUT>	A TwoInputStreamOperator for executing KeyedBroadcastProcessFunctions in RuntimeExecutionMode.BATCH execution mode.
class	BatchCoBroadcastWithNonKeyedOperator<IN1,IN2,OUT>	A TwoInputStreamOperator for executing BroadcastProcessFunctions in RuntimeExecutionMode.BATCH execution mode.
class	CoBroadcastWithKeyedOperator<KS,IN1,IN2,OUT>	A TwoInputStreamOperator for executing KeyedBroadcastProcessFunctions.
class	CoBroadcastWithNonKeyedOperator<IN1,IN2,OUT>	A TwoInputStreamOperator for executing BroadcastProcessFunctions.
class	CoProcessOperator<IN1,IN2,OUT>	A StreamOperator for executing CoProcessFunctions.
class	CoStreamFlatMap<IN1,IN2,OUT>	StreamOperator for processing CoFlatMapFunctions.
class	CoStreamMap<IN1,IN2,OUT>	StreamOperator for processing CoMapFunctions.
class	IntervalJoinOperator<K,T1,T2,OUT>	An operator to execute time-bounded stream inner joins.
class	KeyedCoProcessOperator<K,IN1,IN2,OUT>	A StreamOperator for executing keyed KeyedCoProcessFunction.
class	LegacyKeyedCoProcessOperator<K,IN1,IN2,OUT>	Deprecated. Replaced by KeyedCoProcessOperator which takes KeyedCoProcessFunction

Uses of KeyContext in org.apache.flink.streaming.api.operators.collect

Classes in org.apache.flink.streaming.api.operators.collect that implement KeyContext

Modifier and Type	Class	Description
class	CollectSinkOperator<IN>	A StreamSink that collects query results and sends them back to the client.

Uses of KeyContext in org.apache.flink.streaming.api.operators.sorted.state

Methods in org.apache.flink.streaming.api.operators.sorted.state with parameters of type KeyContext

Modifier and Type	Method	Description
static <K> InternalTimeServiceManager<K>	BatchExecutionInternalTimeServiceManager.create(org.apache.flink.runtime.state.CheckpointableKeyedStateBackend<K> keyedStatedBackend, ClassLoader userClassloader, KeyContext keyContext, ProcessingTimeService processingTimeService, Iterable<org.apache.flink.runtime.state.KeyGroupStatePartitionStreamProvider> rawKeyedStates, StreamTaskCancellationContext cancellationContext)

Uses of KeyContext in org.apache.flink.streaming.runtime.operators

Classes in org.apache.flink.streaming.runtime.operators that implement KeyContext

Modifier and Type	Class	Description
class	GenericWriteAheadSink<IN>	Generic Sink that emits its input elements into an arbitrary backend.
class	TimestampsAndWatermarksOperator<T>	A stream operator that may do one or both of the following: extract timestamps from events and generate watermarks.

Uses of KeyContext in org.apache.flink.streaming.runtime.operators.windowing

Classes in org.apache.flink.streaming.runtime.operators.windowing that implement KeyContext

Modifier and Type	Class	Description
class	EvictingWindowOperator<K,IN,OUT,W extends Window>	A WindowOperator that also allows an Evictor to be used.
class	WindowOperator<K,IN,ACC,OUT,W extends Window>	An operator that implements the logic for windowing based on a WindowAssigner and Trigger.

Uses of KeyContext in org.apache.flink.streaming.runtime.translators

Classes in org.apache.flink.streaming.runtime.translators that implement KeyContext

Modifier and Type	Class	Description
static class	CacheTransformationTranslator.IdentityStreamOperator<T>	The CacheTransformationTranslator.IdentityStreamOperator acts as a dummy source to consume cached intermediate dataset.
static class	CacheTransformationTranslator.NoOpStreamOperator<T>	The CacheTransformationTranslator.NoOpStreamOperator acts as a dummy sink so that the upstream can produce the intermediate dataset to be cached.