Uses of Interface
org.apache.flink.datastream.api.context.PartitionedContext

Packages that use PartitionedContext

Package	Description
org.apache.flink.datastream.api.function

Uses of PartitionedContext in org.apache.flink.datastream.api.function

Methods in org.apache.flink.datastream.api.function with parameters of type PartitionedContext

Modifier and Type	Method	Description
void	ApplyPartitionFunction.apply(Collector<OUT> collector, PartitionedContext ctx)	The actual method to be applied to each partition.
void	TwoOutputApplyPartitionFunction.apply(Collector<OUT1> firstOutput, Collector<OUT2> secondOutput, PartitionedContext ctx)	The actual method to be applied to each partition.
default void	OneInputStreamProcessFunction.onProcessingTimer(long timestamp, Collector<OUT> output, PartitionedContext ctx)	Callback for processing timer.
default void	TwoInputBroadcastStreamProcessFunction.onProcessingTimer(long timestamp, Collector<OUT> output, PartitionedContext ctx)	Callback for processing timer.
default void	TwoInputNonBroadcastStreamProcessFunction.onProcessingTimer(long timestamp, Collector<OUT> output, PartitionedContext ctx)	Callback for processing timer.
default void	TwoOutputStreamProcessFunction.onProcessingTimer(long timestamp, Collector<OUT1> output1, Collector<OUT2> output2, PartitionedContext ctx)	Callback for processing timer.
void	OneInputStreamProcessFunction.processRecord(IN record, Collector<OUT> output, PartitionedContext ctx)	Process record and emit data through Collector.
void	TwoOutputStreamProcessFunction.processRecord(IN record, Collector<OUT1> output1, Collector<OUT2> output2, PartitionedContext ctx)	Process and emit record to the first/second output through Collectors.
void	TwoInputNonBroadcastStreamProcessFunction.processRecordFromFirstInput(IN1 record, Collector<OUT> output, PartitionedContext ctx)	Process record from the first input and emit data through Collector.
void	TwoInputBroadcastStreamProcessFunction.processRecordFromNonBroadcastInput(IN1 record, Collector<OUT> output, PartitionedContext ctx)	Process record from non-broadcast input and emit data through Collector.
void	TwoInputNonBroadcastStreamProcessFunction.processRecordFromSecondInput(IN2 record, Collector<OUT> output, PartitionedContext ctx)	Process record from the second input and emit data through Collector.