...
Page properties |
---|
Current state: Accepted
|
...
...
...
|
...
|
...
|
Please keep the discussion on the mailing list rather than commenting on the wiki (wiki discussions get unwieldy fast).
...
- A connector implementation does not have to report all the defined metrics. But if a connector reports a metric of the same semantic defined below, the implementation should follow the convention.
- The following metric convention is not a complete list. More conventional metric will be added over time.
- The histogram metrics are usually very expensive. Due to its performance impact, we intentionally excluded them in this FLIP. Please see future work section for more details.
...
Sink Metrics
Name | Type | Unit | Description |
numBytesOutnumBytesSend | Counter | Bytes | The total number of output bytes since the source started. Count towards the numBytesOut in TaskIOMetricsGroup Predefined, updated by sink implementations. |
numBytesOutPerSecondnumBytesSendPerSecond | Meter | Bytes/Sec | The output bytes per second Predefined, associated with numBytesOutnumBytesSend. |
numRecordsOutnumRecordsSend | Counter | Records | (Existing operator metric) The total number of output records since the source startedThe Sink implementation should reused this existing operator metric instead of creating a new one.sink started Predefined, updated by sink implementations. |
numRecordsOutPerSecondnumRecordsSendPerSecond | Meter | Records/Sec | (Existing operator metric) The output records per second The Sink implementation should reused this existing operator metric instead of creating a new one. Predefined, associated with numBytesOutnumBytesSend. |
numRecordsOutErrorsnumRecordsSendErrors | Counter | Record | The total number of records failed to send Predefined, updated by sink implementations. |
currentSendTime | Gauge | ms | The time it takes to send the last record. This metric is an instantaneous value recorded for the last processed record. Optional, updated by sink implementations. |
...