Package io.github.flink.gcp.connector.base.metrics
package io.github.flink.gcp.connector.base.metrics
-
ClassesClassDescriptionOptional per-destination send counters, as
destination.NAME.recordsSendanddestination.NAME.sendErrorson the writer's metric group, whereNAMEis 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, aserrorClass.CODE.errorson the writer's metric group.Shared boundary handling for connector metric values.