Package io.github.flink.gcp.connector.spanner

Class SpannerMetricNames

java.lang.Object
io.github.flink.gcp.connector.spanner.SpannerMetricNames
@Internal public final class SpannerMetricNames extends Object
Every metric name this connector registers, in one place.

Counters name the event that happened (recordsSkipped), gauges name the state they read (bufferedCells), and no name takes Flink's num prefix — a name meaning the same thing in another connector of this project is spelled the same way there.

Deliberately absent: the names Flink itself provides through SinkWriterMetricGroup (numRecordsSend, numBytesSend, numRecordsSendErrors) and through the source's own groups (numRecordsIn, unassignedSplits), and the templated leaves of the shared base.metrics subgroups (errorClass.CODE.errors) — none of them is this connector's to name.

  • Field Details

    • BUFFERED_MUTATIONS

      public static final String BUFFERED_MUTATIONS
      Mutations held in the writer's batch, waiting for the next flush.
      See Also:

    • BUFFERED_CELLS

      public static final String BUFFERED_CELLS
      Mutation cells held in the writer's batch, counted the way Spanner counts a mutation — index entries included.
      See Also:

    • BUFFERED_BYTES

      public static final String BUFFERED_BYTES
      Estimated bytes of the mutations held in the writer's batch.
      See Also:

    • RECORDS_SKIPPED

      public static final String RECORDS_SKIPPED
      Records the sink serializer skipped or source inputs whose deserializer emitted nothing.
      See Also:

    • MUTATIONS_RETRIED

      public static final String MUTATIONS_RETRIED
      Mutations re-sent after a transient failure. Counted per re-send, so one mutation retried three times contributes three — the question it answers is how much work the retry loop is doing, not how many mutations were unlucky.
      See Also:

    • BATCHES_SENT

      public static final String BATCHES_SENT
      Batch write requests the writer sent, first attempts and re-sends alike.
      See Also:

    • SPLITS_ASSIGNED

      public static final String SPLITS_ASSIGNED
      Partition splits handed to a reader.
      See Also:

    • SPLITS_RETURNED

      public static final String SPLITS_RETURNED
      Partition splits a failed reader gave back, to be handed out again.
      See Also:

    • CHANGE_STREAM_PARTITIONS_DISCOVERED

      public static final String CHANGE_STREAM_PARTITIONS_DISCOVERED
      Child partition tokens first accepted into the Change Streams coordinator ledger.
      See Also:

    • UNASSIGNED_CHANGE_STREAM_PARTITION_LAG_MILLIS

      public static final String UNASSIGNED_CHANGE_STREAM_PARTITION_LAG_MILLIS
      Lag of the oldest scheduled Change Streams partition no reader owns yet.
      See Also:

    • CHANGE_STREAM_PARTITION_LEDGER_ENTRIES

      public static final String CHANGE_STREAM_PARTITION_LEDGER_ENTRIES
      Unfinished partition entries held in the Change Streams coordinator ledger.
      See Also:

    • CHANGE_STREAM_FINISHED_PARENT_PROOFS

      public static final String CHANGE_STREAM_FINISHED_PARENT_PROOFS
      Finished parent IDs retained while a Change Streams child awaits another parent.
      See Also:

    • READS_PLANNED

      public static final String READS_PLANNED
      Reads planned into partitions. One per job at most: a restored enumerator plans nothing, so this reads 1 on a fresh run and 0 on a restored one.
      See Also:

    • ROWS_READ

      public static final String ROWS_READ
      Input rows accepted from a partition into fetch batches.
      See Also:

    • PARTITIONS_REREAD

      public static final String PARTITIONS_REREAD
      Partitions opened again from their start after a wake-up cancelled them part-way, delivering the rows they had already handed on a second time.
      See Also:

    • CHANGE_STREAM_QUERIES_STARTED

      public static final String CHANGE_STREAM_QUERIES_STARTED
      Change Streams TVF partition queries opened, including restored reopens.
      See Also:

    • ACTIVE_CHANGE_STREAM_QUERIES

      public static final String ACTIVE_CHANGE_STREAM_QUERIES
      Change Streams TVF partition queries currently open in one reader subtask.
      See Also:

    • QUEUED_CHANGE_STREAM_PARTITIONS

      public static final String QUEUED_CHANGE_STREAM_PARTITIONS
      Assigned Change Streams partitions waiting for a query slot in one reader subtask.
      See Also:

    • QUEUED_CHANGE_STREAM_PARTITION_LAG_MILLIS

      public static final String QUEUED_CHANGE_STREAM_PARTITION_LAG_MILLIS
      Lag of the oldest assigned Change Streams partition waiting for a query slot.
      See Also:

    • MISSED_HEARTBEAT_INTERVALS

      public static final String MISSED_HEARTBEAT_INTERVALS
      Maximum whole heartbeat intervals missed by any active non-initial partition query.
      See Also:

    • LAST_CHANGE_STREAM_RECORD_WAIT_MILLIS

      public static final String LAST_CHANGE_STREAM_RECORD_WAIT_MILLIS
      Wait for the most recently returned non-heartbeat Change Streams result.
      See Also:

    • LONGEST_CHANGE_STREAM_RECORD_WAIT_MILLIS

      public static final String LONGEST_CHANGE_STREAM_RECORD_WAIT_MILLIS
      Longest wait for a returned non-heartbeat Change Streams result in this task attempt.
      See Also:

    • CHANGE_STREAM_RECORDS_FILTERED_BY_TABLE

      public static final String CHANGE_STREAM_RECORDS_FILTERED_BY_TABLE
      Data-change records removed by a Change Streams table filter.
      See Also:

    • CHANGE_STREAM_RECORDS_SKIPPED_WITHOUT_CHANGE

      public static final String CHANGE_STREAM_RECORDS_SKIPPED_WITHOUT_CHANGE
      Data-change records skipped after column projection left no reported non-key values.
      See Also:

    • CHANGE_STREAM_COLUMN_OCCURRENCES_FILTERED

      public static final String CHANGE_STREAM_COLUMN_OCCURRENCES_FILTERED
      Column metadata and value occurrences removed from records delivered to the deserializer.
      See Also: