Interface PartitionedContext
-
- All Superinterfaces:
RuntimeContext
- All Known Implementing Classes:
DefaultPartitionedContext
@Experimental public interface PartitionedContext extends RuntimeContext
On the base ofRuntimeContext
,PartitionedContext
also contains all partition-wise execution information, such as getting state, registering timer, etc.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description ProcessingTimeManager
getProcessingTimeManager()
Get theProcessingTimeManager
of this process function.StateManager
getStateManager()
Get theStateManager
of this process function.-
Methods inherited from interface org.apache.flink.datastream.api.context.RuntimeContext
getJobInfo, getMetricGroup, getTaskInfo
-
-
-
-
Method Detail
-
getStateManager
StateManager getStateManager()
Get theStateManager
of this process function.
-
getProcessingTimeManager
ProcessingTimeManager getProcessingTimeManager()
Get theProcessingTimeManager
of this process function.
-
-