Interface NonPartitionedContext<OUT>
-
- All Superinterfaces:
RuntimeContext
- All Known Implementing Classes:
DefaultNonPartitionedContext
@Experimental public interface NonPartitionedContext<OUT> extends RuntimeContext
This interface represents the context associated with all operations must be applied to all partitions.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
applyToAllPartitions(ApplyPartitionFunction<OUT> 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(ApplyPartitionFunction<OUT> 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
-
-