in iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/metric/receiver/PipeDataNodeReceiverMetrics.java [145:306]
private void bindToTimer(final AbstractMetricService metricService) {
handshakeDatanodeV1Timer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"handshakeDataNodeV1");
handshakeDatanodeV2Timer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"handshakeDataNodeV2");
transferTabletInsertNodeTimer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferTabletInsertNode");
transferTabletInsertNodeV2Timer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferTabletInsertNodeV2");
transferTabletRawTimer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferTabletRaw");
transferTabletRawV2Timer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferTabletRawV2");
transferTabletBinaryTimer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferTabletBinary");
transferTabletBinaryV2Timer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferTabletBinaryV2");
transferTabletBatchTimer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferTabletBatch");
transferTabletBatchV2Timer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferTabletBatchV2");
transferTsFilePieceTimer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferTsFilePiece");
transferTsFileSealTimer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferTsFileSeal");
transferTsFilePieceWithModTimer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferTsFilePieceWithMod");
transferTsFileSealWithModTimer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferTsFileSealWithMod");
transferSchemaPlanTimer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferSchemaPlan");
transferSchemaSnapshotPieceTimer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferSchemaSnapshotPiece");
transferSchemaSnapshotSealTimer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferSchemaSnapshotSeal");
transferConfigPlanTimer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferConfigPlan");
transferCompressedTimer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferCompressed");
transferSliceTimer =
metricService.getOrCreateTimer(
Metric.PIPE_DATANODE_RECEIVER.toString(),
MetricLevel.IMPORTANT,
Tag.NAME.toString(),
RECEIVER,
Tag.TYPE.toString(),
"transferSlice");
}