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


package io.github.flink.gcp.connector.base.metrics
  • Classes
    Class
    Description
    Optional per-destination send counters, as destination.NAME.recordsSend and destination.NAME.sendErrors on the writer's metric group, where NAME is the destination as the connector's docs page spells it.
    One destination's counters; a no-op instance when per-destination metrics are off.
    Counts a sink's failures by the status code that caused them, as errorClass.CODE.errors on the writer's metric group.
    Shared boundary handling for connector metric values.