This is an automated email from the ASF dual-hosted git repository. abhishekrb pushed a commit to branch fix_typo in repository https://gitbox.apache.org/repos/asf/druid.git
commit 49f7287e0e6a69a96f73ca43150299dc6c322302 Author: Abhishek Balaji Radhakrishnan <[email protected]> AuthorDate: Mon Dec 1 16:55:20 2025 -0800 Fix typo: MSQMetriceEventBuilder (rename to MSQMetricEventBuilder) --- .../org/apache/druid/msq/dart/controller/DartControllerContext.java | 4 ++-- .../java/org/apache/druid/msq/dart/worker/DartWorkerContext.java | 4 ++-- .../src/main/java/org/apache/druid/msq/exec/ControllerContext.java | 4 ++-- .../src/main/java/org/apache/druid/msq/exec/ControllerImpl.java | 6 +++--- .../{MSQMetriceEventBuilder.java => MSQMetricEventBuilder.java} | 2 +- .../src/main/java/org/apache/druid/msq/exec/WorkerContext.java | 4 ++-- .../src/main/java/org/apache/druid/msq/exec/WorkerImpl.java | 2 +- .../org/apache/druid/msq/indexing/IndexerControllerContext.java | 4 ++-- .../java/org/apache/druid/msq/indexing/IndexerWorkerContext.java | 4 ++-- .../java/org/apache/druid/msq/test/MSQTestControllerContext.java | 4 ++-- .../test/java/org/apache/druid/msq/test/MSQTestWorkerContext.java | 4 ++-- .../apache/druid/msq/test/TestDartControllerContextFactoryImpl.java | 4 ++-- 12 files changed, 23 insertions(+), 23 deletions(-) diff --git a/multi-stage-query/src/main/java/org/apache/druid/msq/dart/controller/DartControllerContext.java b/multi-stage-query/src/main/java/org/apache/druid/msq/dart/controller/DartControllerContext.java index 24637eb54e8..9276c11916b 100644 --- a/multi-stage-query/src/main/java/org/apache/druid/msq/dart/controller/DartControllerContext.java +++ b/multi-stage-query/src/main/java/org/apache/druid/msq/dart/controller/DartControllerContext.java @@ -32,7 +32,7 @@ import org.apache.druid.msq.dart.worker.WorkerId; import org.apache.druid.msq.exec.Controller; import org.apache.druid.msq.exec.ControllerContext; import org.apache.druid.msq.exec.ControllerMemoryParameters; -import org.apache.druid.msq.exec.MSQMetriceEventBuilder; +import org.apache.druid.msq.exec.MSQMetricEventBuilder; import org.apache.druid.msq.exec.MemoryIntrospector; import org.apache.druid.msq.exec.SegmentSource; import org.apache.druid.msq.exec.WorkerFailureListener; @@ -175,7 +175,7 @@ public class DartControllerContext implements ControllerContext } @Override - public void emitMetric(MSQMetriceEventBuilder metricBuilder) + public void emitMetric(MSQMetricEventBuilder metricBuilder) { metricBuilder.setDartDimensions(context); metricBuilder.setDimension(QueryContexts.CTX_DART_QUERY_ID, context.get(QueryContexts.CTX_DART_QUERY_ID)); diff --git a/multi-stage-query/src/main/java/org/apache/druid/msq/dart/worker/DartWorkerContext.java b/multi-stage-query/src/main/java/org/apache/druid/msq/dart/worker/DartWorkerContext.java index 0bfd79e999f..64f3884810a 100644 --- a/multi-stage-query/src/main/java/org/apache/druid/msq/dart/worker/DartWorkerContext.java +++ b/multi-stage-query/src/main/java/org/apache/druid/msq/dart/worker/DartWorkerContext.java @@ -32,7 +32,7 @@ import org.apache.druid.msq.exec.ControllerClient; import org.apache.druid.msq.exec.DataServerQueryHandlerFactory; import org.apache.druid.msq.exec.FrameContext; import org.apache.druid.msq.exec.FrameWriterSpec; -import org.apache.druid.msq.exec.MSQMetriceEventBuilder; +import org.apache.druid.msq.exec.MSQMetricEventBuilder; import org.apache.druid.msq.exec.MemoryIntrospector; import org.apache.druid.msq.exec.ProcessingBuffersProvider; import org.apache.druid.msq.exec.ProcessingBuffersSet; @@ -183,7 +183,7 @@ public class DartWorkerContext implements WorkerContext } @Override - public void emitMetric(MSQMetriceEventBuilder metricBuilder) + public void emitMetric(MSQMetricEventBuilder metricBuilder) { metricBuilder.setDartDimensions(queryContext); metricBuilder.setDimension(QueryContexts.CTX_DART_QUERY_ID, queryId()); diff --git a/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerContext.java b/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerContext.java index a25c944cf63..008aae55818 100644 --- a/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerContext.java +++ b/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerContext.java @@ -64,10 +64,10 @@ public interface ControllerContext ObjectMapper jsonMapper(); /** - * Emit the metric in the {@link MSQMetriceEventBuilder} using a {@link ServiceEmitter}. Might sets up addtional + * Emit the metric in the {@link MSQMetricEventBuilder} using a {@link ServiceEmitter}. Might sets up addtional * context dependant dimensions. */ - void emitMetric(MSQMetriceEventBuilder metricBuilder); + void emitMetric(MSQMetricEventBuilder metricBuilder); /** * Provides a way for tasks to request injectable objects. Useful because tasks are not able to request injection diff --git a/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerImpl.java b/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerImpl.java index 57b142303a3..b8238b81b16 100644 --- a/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerImpl.java +++ b/multi-stage-query/src/main/java/org/apache/druid/msq/exec/ControllerImpl.java @@ -589,7 +589,7 @@ public class ControllerImpl implements Controller long startTime = DateTimeUtils.getInstantMillis(MultiStageQueryContext.getStartTime(querySpec.getContext())); - final MSQMetriceEventBuilder metricBuilder = new MSQMetriceEventBuilder(); + final MSQMetricEventBuilder metricBuilder = new MSQMetricEventBuilder(); metricBuilder.setDimension(DruidMetrics.DATASOURCE, DefaultQueryMetrics.getTableNamesAsString(datasources)) .setDimension(DruidMetrics.INTERVAL, DefaultQueryMetrics.getIntervalsAsStringArray(intervals)) .setDimension(DruidMetrics.DURATION, BaseQuery.calculateDuration(intervals)) @@ -634,7 +634,7 @@ public class ControllerImpl implements Controller log.debug("Processed bytes[%d] for query[%s].", totalProcessedBytes, querySpec.getId()); - final MSQMetriceEventBuilder metricBuilder = new MSQMetriceEventBuilder(); + final MSQMetricEventBuilder metricBuilder = new MSQMetricEventBuilder(); metricBuilder.setMetric("ingest/input/bytes", totalProcessedBytes); context.emitMetric(metricBuilder); } @@ -1571,7 +1571,7 @@ public class ControllerImpl implements Controller ); } - MSQMetriceEventBuilder metricBuilder = new MSQMetriceEventBuilder(); + MSQMetricEventBuilder metricBuilder = new MSQMetricEventBuilder(); metricBuilder.setMetric("ingest/tombstones/count", numTombstones); context.emitMetric(metricBuilder); diff --git a/multi-stage-query/src/main/java/org/apache/druid/msq/exec/MSQMetriceEventBuilder.java b/multi-stage-query/src/main/java/org/apache/druid/msq/exec/MSQMetricEventBuilder.java similarity index 97% rename from multi-stage-query/src/main/java/org/apache/druid/msq/exec/MSQMetriceEventBuilder.java rename to multi-stage-query/src/main/java/org/apache/druid/msq/exec/MSQMetricEventBuilder.java index ad1284197df..6d60d6fe38c 100644 --- a/multi-stage-query/src/main/java/org/apache/druid/msq/exec/MSQMetriceEventBuilder.java +++ b/multi-stage-query/src/main/java/org/apache/druid/msq/exec/MSQMetricEventBuilder.java @@ -32,7 +32,7 @@ import java.util.Map; /** * Service metric event builder for MSQ. */ -public class MSQMetriceEventBuilder extends ServiceMetricEvent.Builder +public class MSQMetricEventBuilder extends ServiceMetricEvent.Builder { /** * Value to emit for {@link DruidMetrics#TYPE} in query metrics. diff --git a/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerContext.java b/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerContext.java index ceac7728c07..61c1dd9654e 100644 --- a/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerContext.java +++ b/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerContext.java @@ -58,10 +58,10 @@ public interface WorkerContext extends Closeable Injector injector(); /** - * Emit the metric in the {@link MSQMetriceEventBuilder} using a {@link ServiceEmitter}. Might sets up addtional + * Emit the metric in the {@link MSQMetricEventBuilder} using a {@link ServiceEmitter}. Might sets up addtional * context dependant dimensions. */ - void emitMetric(MSQMetriceEventBuilder metricBuilder); + void emitMetric(MSQMetricEventBuilder metricBuilder); /** * Callback from the worker implementation to "register" the worker. Used in diff --git a/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerImpl.java b/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerImpl.java index af2f145e527..ffd64dbe088 100644 --- a/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerImpl.java +++ b/multi-stage-query/src/main/java/org/apache/druid/msq/exec/WorkerImpl.java @@ -232,7 +232,7 @@ public class WorkerImpl implements Worker final Set<String> datasources = (Set<String>) queryMetricDimensions.get(DruidMetrics.DATASOURCE); final Set<Interval> intervals = (Set<Interval>) queryMetricDimensions.get(DruidMetrics.INTERVAL); - final MSQMetriceEventBuilder metricBuilder = new MSQMetriceEventBuilder(); + final MSQMetricEventBuilder metricBuilder = new MSQMetricEventBuilder(); metricBuilder.setDimension(DruidMetrics.DATASOURCE, DefaultQueryMetrics.getTableNamesAsString(datasources)) .setDimension(DruidMetrics.INTERVAL, DefaultQueryMetrics.getIntervalsAsStringArray(intervals)) .setDimension(DruidMetrics.DURATION, BaseQuery.calculateDuration(intervals)) diff --git a/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerControllerContext.java b/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerControllerContext.java index 86966a92236..2d7f958aca4 100644 --- a/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerControllerContext.java +++ b/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerControllerContext.java @@ -34,7 +34,7 @@ import org.apache.druid.java.util.common.logger.Logger; import org.apache.druid.msq.exec.Controller; import org.apache.druid.msq.exec.ControllerContext; import org.apache.druid.msq.exec.ControllerMemoryParameters; -import org.apache.druid.msq.exec.MSQMetriceEventBuilder; +import org.apache.druid.msq.exec.MSQMetricEventBuilder; import org.apache.druid.msq.exec.MemoryIntrospector; import org.apache.druid.msq.exec.SegmentSource; import org.apache.druid.msq.exec.WorkerClient; @@ -147,7 +147,7 @@ public class IndexerControllerContext implements ControllerContext } @Override - public void emitMetric(MSQMetriceEventBuilder metricBuilder) + public void emitMetric(MSQMetricEventBuilder metricBuilder) { // Attach task specific dimensions metricBuilder.setTaskDimensions(task, taskQuerySpecContext); diff --git a/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerWorkerContext.java b/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerWorkerContext.java index 873a0619c04..beec439ea19 100644 --- a/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerWorkerContext.java +++ b/multi-stage-query/src/main/java/org/apache/druid/msq/indexing/IndexerWorkerContext.java @@ -32,7 +32,7 @@ import org.apache.druid.java.util.common.logger.Logger; import org.apache.druid.msq.exec.ControllerClient; import org.apache.druid.msq.exec.FrameContext; import org.apache.druid.msq.exec.FrameWriterSpec; -import org.apache.druid.msq.exec.MSQMetriceEventBuilder; +import org.apache.druid.msq.exec.MSQMetricEventBuilder; import org.apache.druid.msq.exec.MemoryIntrospector; import org.apache.druid.msq.exec.ProcessingBuffersProvider; import org.apache.druid.msq.exec.ProcessingBuffersSet; @@ -208,7 +208,7 @@ public class IndexerWorkerContext implements WorkerContext } @Override - public void emitMetric(MSQMetriceEventBuilder metricBuilder) + public void emitMetric(MSQMetricEventBuilder metricBuilder) { // Attach task specific dimensions metricBuilder.setTaskDimensions(task, QueryContext.of(task.getContext())); diff --git a/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestControllerContext.java b/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestControllerContext.java index 6587703dfef..22afb0154e9 100644 --- a/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestControllerContext.java +++ b/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestControllerContext.java @@ -49,7 +49,7 @@ import org.apache.druid.msq.dart.controller.DartControllerContextFactory; import org.apache.druid.msq.exec.Controller; import org.apache.druid.msq.exec.ControllerContext; import org.apache.druid.msq.exec.ControllerMemoryParameters; -import org.apache.druid.msq.exec.MSQMetriceEventBuilder; +import org.apache.druid.msq.exec.MSQMetricEventBuilder; import org.apache.druid.msq.exec.SegmentSource; import org.apache.druid.msq.exec.Worker; import org.apache.druid.msq.exec.WorkerClient; @@ -293,7 +293,7 @@ public class MSQTestControllerContext implements ControllerContext, DartControll } @Override - public void emitMetric(MSQMetriceEventBuilder metricBuilder) + public void emitMetric(MSQMetricEventBuilder metricBuilder) { serviceEmitter.emit( metricBuilder.setDimension( diff --git a/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestWorkerContext.java b/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestWorkerContext.java index 3652f40da9c..0b745b620d8 100644 --- a/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestWorkerContext.java +++ b/multi-stage-query/src/test/java/org/apache/druid/msq/test/MSQTestWorkerContext.java @@ -32,7 +32,7 @@ import org.apache.druid.msq.exec.ControllerClient; import org.apache.druid.msq.exec.DataServerQueryHandlerFactory; import org.apache.druid.msq.exec.FrameContext; import org.apache.druid.msq.exec.FrameWriterSpec; -import org.apache.druid.msq.exec.MSQMetriceEventBuilder; +import org.apache.druid.msq.exec.MSQMetricEventBuilder; import org.apache.druid.msq.exec.ProcessingBuffers; import org.apache.druid.msq.exec.Worker; import org.apache.druid.msq.exec.WorkerClient; @@ -120,7 +120,7 @@ public class MSQTestWorkerContext implements WorkerContext } @Override - public void emitMetric(MSQMetriceEventBuilder metricBuilder) + public void emitMetric(MSQMetricEventBuilder metricBuilder) { serviceEmitter.emit( metricBuilder.setDimension( diff --git a/multi-stage-query/src/test/java/org/apache/druid/msq/test/TestDartControllerContextFactoryImpl.java b/multi-stage-query/src/test/java/org/apache/druid/msq/test/TestDartControllerContextFactoryImpl.java index 8f3fbe66988..56aeb232cdb 100644 --- a/multi-stage-query/src/test/java/org/apache/druid/msq/test/TestDartControllerContextFactoryImpl.java +++ b/multi-stage-query/src/test/java/org/apache/druid/msq/test/TestDartControllerContextFactoryImpl.java @@ -40,7 +40,7 @@ import org.apache.druid.msq.dart.controller.DartControllerContextFactoryImpl; import org.apache.druid.msq.dart.worker.DartWorkerClient; import org.apache.druid.msq.exec.Controller; import org.apache.druid.msq.exec.ControllerContext; -import org.apache.druid.msq.exec.MSQMetriceEventBuilder; +import org.apache.druid.msq.exec.MSQMetricEventBuilder; import org.apache.druid.msq.exec.MemoryIntrospector; import org.apache.druid.msq.exec.Worker; import org.apache.druid.msq.exec.WorkerImpl; @@ -104,7 +104,7 @@ public class TestDartControllerContextFactoryImpl extends DartControllerContextF } @Override - public void emitMetric(MSQMetriceEventBuilder metricBuilder) + public void emitMetric(MSQMetricEventBuilder metricBuilder) { serviceEmitter.emit(metricBuilder.build("controller", queryId())); } --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
