You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@druid.apache.org by ab...@apache.org on 2025/12/02 00:55:54 UTC
(druid) branch fix_typo created (now 49f7287e0e6)
This is an automated email from the ASF dual-hosted git repository.
abhishekrb pushed a change to branch fix_typo
in repository https://gitbox.apache.org/repos/asf/druid.git
at 49f7287e0e6 Fix typo: MSQMetriceEventBuilder (rename to MSQMetricEventBuilder)
This branch includes the following new commits:
new 49f7287e0e6 Fix typo: MSQMetriceEventBuilder (rename to MSQMetricEventBuilder)
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org
(druid) 01/01: Fix typo: MSQMetriceEventBuilder (rename to MSQMetricEventBuilder)
Posted by ab...@apache.org.
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 <ab...@gmail.com>
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: commits-unsubscribe@druid.apache.org
For additional commands, e-mail: commits-help@druid.apache.org