Interface CommitterInitContext
-
- All Superinterfaces:
InitContext
@Public public interface CommitterInitContext extends InitContext
The interface exposes some runtime info for creating aCommitter.
-
-
Field Summary
-
Fields inherited from interface org.apache.flink.api.connector.sink2.InitContext
INITIAL_CHECKPOINT_ID
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description org.apache.flink.metrics.groups.SinkCommitterMetricGroupmetricGroup()-
Methods inherited from interface org.apache.flink.api.connector.sink2.InitContext
getAttemptNumber, getJobId, getJobInfo, getNumberOfParallelSubtasks, getRestoredCheckpointId, getSubtaskId, getTaskInfo
-
-