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

Class DestinationMetrics.Counters

java.lang.Object
io.github.flink.gcp.connector.base.metrics.DestinationMetrics.Counters
Enclosing class:
DestinationMetrics
public static final class DestinationMetrics.Counters extends Object
One destination's counters; a no-op instance when per-destination metrics are off.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    recordSent()
    Counts one record handed to the client library for this destination.
    void
    recordsSent(long count)
    Counts the records of one request handed to the client library for this destination — the batching connectors' form of recordSent(), which is the same counter.
    void
    sendFailed()
    Counts one record routed to the failure handler for this destination.

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Method Details

    • recordSent

      public void recordSent()
      Counts one record handed to the client library for this destination.

    • recordsSent

      public void recordsSent(long count)
      Counts the records of one request handed to the client library for this destination — the batching connectors' form of recordSent(), which is the same counter.
      Parameters:
      count - the number of records the request carries

    • sendFailed

      public void sendFailed()
      Counts one record routed to the failure handler for this destination.