in src/main/java/org/opensearch/performanceanalyzer/transport/PerformanceAnalyzerTransportChannel.java [55:99]
void set(
TransportChannel original,
long startTime,
String indexName,
int shardId,
int itemCount,
boolean bPrimary) {
this.original = original;
this.id = String.valueOf(UNIQUE_ID.getAndIncrement());
this.indexName = indexName;
this.shardId = shardId;
this.primary = bPrimary;
this.threadID = String.valueOf(ThreadIDUtil.INSTANCE.getNativeCurrentThreadId());
StringBuilder value =
new StringBuilder()
.append(PerformanceAnalyzerMetrics.getCurrentTimeMetric())
.append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor)
.append(ShardBulkMetric.START_TIME.toString())
.append(PerformanceAnalyzerMetrics.sKeyValueDelimitor)
.append(startTime)
.append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor)
.append(ShardBulkMetric.ITEM_COUNT.toString())
.append(PerformanceAnalyzerMetrics.sKeyValueDelimitor)
.append(itemCount)
.append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor)
.append(ShardBulkDimension.INDEX_NAME.toString())
.append(PerformanceAnalyzerMetrics.sKeyValueDelimitor)
.append(indexName)
.append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor)
.append(ShardBulkDimension.SHARD_ID.toString())
.append(PerformanceAnalyzerMetrics.sKeyValueDelimitor)
.append(shardId)
.append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor)
.append(ShardBulkDimension.PRIMARY.toString())
.append(PerformanceAnalyzerMetrics.sKeyValueDelimitor)
.append(bPrimary);
saveMetricValues(
value.toString(),
startTime,
threadID,
id,
PerformanceAnalyzerMetrics.START_FILE_NAME);
}