Skip to content

Commit 6c5a3bf

Browse files
committed
Change dimensional time slice crawler and worker metrics to camel case
Convert WorkerPartitionWaitTime and WorkerPartitionProcessLatency metrics to camelCase format (workerPartitionWaitTime and workerPartitionProcessLatency) in TokenPaginationCrawler and DimensionalTimeSliceCrawler for consistency with LeaderOnlyTokenCrawler metrics. Signed-off-by: Nathan Wand <wandna@amazon.com>
1 parent 2bbdfbf commit 6c5a3bf

3 files changed

Lines changed: 6 additions & 6 deletions

File tree

data-prepper-plugins/saas-source-plugins/source-crawler/src/main/java/org/opensearch/dataprepper/plugins/source/source_crawler/base/DimensionalTimeSliceCrawler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -40,8 +40,8 @@ public class DimensionalTimeSliceCrawler implements Crawler<DimensionalTimeSlice
4040
// In general, newly generated events become queryable after 30 ~ 120 second
4141
protected static final long WAIT_SECONDS_BEFORE_PARTITION_CREATION = 300;
4242
private static final String DIMENSIONAL_TIME_SLICE_WORKER_PARTITIONS_CREATED = "DimensionalTimeSliceWorkerPartitionsCreated";
43-
private static final String WORKER_PARTITION_WAIT_TIME = "WorkerPartitionWaitTime";
44-
private static final String WORKER_PARTITION_PROCESS_LATENCY = "WorkerPartitionProcessLatency";
43+
private static final String WORKER_PARTITION_WAIT_TIME = "workerPartitionWaitTime";
44+
private static final String WORKER_PARTITION_PROCESS_LATENCY = "workerPartitionProcessLatency";
4545
private static final Duration HOUR_DURATION = Duration.ofHours(1);
4646

4747
private final CrawlerClient client;

data-prepper-plugins/saas-source-plugins/source-crawler/src/main/java/org/opensearch/dataprepper/plugins/source/source_crawler/base/LeaderOnlyTokenCrawler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -39,8 +39,8 @@ public class LeaderOnlyTokenCrawler implements Crawler<PaginationCrawlerWorkerPr
3939

4040
private static final String METRIC_BATCHES_FAILED = "batchesFailed";
4141
private static final String METRIC_BUFFER_WRITE_TIME = "bufferWriteTime";
42-
private static final String WORKER_PARTITION_WAIT_TIME = "WorkerPartitionWaitTime";
43-
private static final String WORKER_PARTITION_PROCESS_LATENCY = "WorkerPartitionProcessLatency";
42+
private static final String WORKER_PARTITION_WAIT_TIME = "workerPartitionWaitTime";
43+
private static final String WORKER_PARTITION_PROCESS_LATENCY = "workerPartitionProcessLatency";
4444
public static final String ACKNOWLEDGEMENT_SET_SUCCESS_METRIC_NAME = "acknowledgementSetSuccesses";
4545
public static final String ACKNOWLEDGEMENT_SET_FAILURES_METRIC_NAME = "acknowledgementSetFailures";
4646

data-prepper-plugins/saas-source-plugins/source-crawler/src/main/java/org/opensearch/dataprepper/plugins/source/source_crawler/base/TokenPaginationCrawler.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -33,8 +33,8 @@ public class TokenPaginationCrawler implements Crawler<PaginationCrawlerWorkerPr
3333
private static final int batchSize = 50;
3434
private static final String PAGINATION_WORKER_PARTITIONS_CREATED = "paginationWorkerPartitionsCreated";
3535
private static final String INVALID_PAGINATION_ITEMS = "invalidPaginationItems";
36-
private static final String WORKER_PARTITION_WAIT_TIME = "WorkerPartitionWaitTime";
37-
private static final String WORKER_PARTITION_PROCESS_LATENCY = "WorkerPartitionProcessLatency";
36+
private static final String WORKER_PARTITION_WAIT_TIME = "workerPartitionWaitTime";
37+
private static final String WORKER_PARTITION_PROCESS_LATENCY = "workerPartitionProcessLatency";
3838
private final Timer crawlingTimer;
3939
private final Timer partitionWaitTimeTimer;
4040
private final Timer partitionProcessLatencyTimer;

0 commit comments

Comments
 (0)