Interface CommitterInitContext

  • All Superinterfaces:
    InitContext

    @PublicEvolving
    public interface CommitterInitContext
    extends InitContext
    The interface exposes some runtime info for creating a Committer.
    • Method Detail

      • metricGroup

        org.apache.flink.metrics.groups.SinkCommitterMetricGroup metricGroup()
        Returns:
        The metric group this committer belongs to.