Interface TwoOutputNonPartitionedContext<OUT1,OUT2>
-
- All Superinterfaces:
RuntimeContext
@Experimental public interface TwoOutputNonPartitionedContext<OUT1,OUT2> extends RuntimeContext
This interface represents the context associated with all operations must be applied to all partitions with two outputs.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voidapplyToAllPartitions(TwoOutputApplyPartitionFunction<OUT1,OUT2> applyPartitionFunction)Apply a function to all partitions.-
Methods inherited from interface org.apache.flink.datastream.api.context.RuntimeContext
getJobInfo, getMetricGroup, getTaskInfo
-
-
-
-
Method Detail
-
applyToAllPartitions
void applyToAllPartitions(TwoOutputApplyPartitionFunction<OUT1,OUT2> applyPartitionFunction) throws Exception
Apply a function to all partitions. For keyed stream, it will apply to all keys. For non-keyed stream, it will apply to single partition.- Throws:
Exception
-
-