Package io.github.flink.gcp.connector.base.failure

Interface FailureHandlerContext

All Known Implementing Classes:
DefaultFailureHandlerContext
@Public public interface FailureHandlerContext
What a FailureHandler or DeadLetterQueue learns about its surroundings when it is opened: enough to stamp per-subtask output and to register its own metrics, and nothing more.

  • Method Summary

    Modifier and Type
    Method
    Description
    org.apache.flink.metrics.MetricGroup
    getMetricGroup()
    Returns the sink writer's metric group, for handler-registered counters and gauges.
    int
    getSubtaskIndex()
    Returns the index of the sink writer subtask driving the handler.

  • Method Details

    • getSubtaskIndex

      int getSubtaskIndex()
      Returns the index of the sink writer subtask driving the handler.

    • getMetricGroup

      org.apache.flink.metrics.MetricGroup getMetricGroup()
      Returns the sink writer's metric group, for handler-registered counters and gauges.