org.apache.flink.api.connector.sink2

Interface CommitterInitContext

All Superinterfaces:

InitContext

@Public
public interface CommitterInitContext
extends InitContext

The interface exposes some runtime info for creating a Committer.

Field Summary

Fields inherited from interface org.apache.flink.api.connector.sink2.InitContext

INITIAL_CHECKPOINT_ID

Method Summary

Modifier and Type	Method and Description
SinkCommitterMetricGroup	metricGroup()

Methods inherited from interface org.apache.flink.api.connector.sink2.InitContext

getAttemptNumber, getJobId, getJobInfo, getNumberOfParallelSubtasks, getRestoredCheckpointId, getSubtaskId, getTaskInfo

Method Detail

metricGroup

SinkCommitterMetricGroup metricGroup()

Returns:

The metric group this committer belongs to.