Page History

public interface SinkWriterMetricGroupSinkCommitterMetricGroup extends OperatorMetricGroup {

    /** The total number of committables arrived. */
    Counter getNumCommittablesTotalCounter();

    /**
     * The total number of committable failures.
     */
    Counter getNumCommittableErrorsCounter();

    /**
     * The total number of successful committables.
     */
    Counter getNumCommittableSuccessCounter();

    /**
     * The pending committables.
     */
    Gauge getNumPendingCommittablesGauge();
}