This is an automated email from the ASF dual-hosted git repository.
FrankChen021 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/druid.git
The following commit(s) were added to refs/heads/master by this push:
new b9d6c6faf02 build: upgrade Checkstyle to 14.3.0 (#20592)
b9d6c6faf02 is described below
commit b9d6c6faf02da43012de57a40fee5de42e920845
Author: Andreas Maechler <[email protected]>
AuthorDate: Wed Oct 14 19:56:41 2026 -0600
build: upgrade Checkstyle to 14.3.0 (#20592)
* build(deps): bump com.puppycrawl.tools:checkstyle from 12.3.1 to 14.3.0
Bumps
[com.puppycrawl.tools:checkstyle](https://github.com/checkstyle/checkstyle)
from 12.3.1 to 14.3.0.
- [Release notes](https://github.com/checkstyle/checkstyle/releases)
-
[Commits](https://github.com/checkstyle/checkstyle/compare/checkstyle-12.3.1...checkstyle-14.3.0)
---
updated-dependencies:
- dependency-name: com.puppycrawl.tools:checkstyle
dependency-version: 14.3.0
dependency-type: direct:production
update-type: version-update:semver-major
...
Signed-off-by: dependabot[bot] <[email protected]>
* Fix Javadoc that Checkstyle 14 cannot parse
Checkstyle 13 and later use a stricter Javadoc parser, and the UnusedImports
check reports every comment it cannot parse (and treats imports referenced
only from such comments as unused). Fix the malformed {@link}, @see and
@throws syntax, unbalanced {@code} braces, stray or mistyped HTML tags, and
unescaped generics and line-leading annotations in the affected comments.
* Point GuavaUtils.firstNonNull Javadoc link at MoreObjects
Guava's Objects#firstNonNull no longer exists, and javadoc cannot resolve
the
(T, T) parameter list. Link to MoreObjects#firstNonNull(Object, Object).
---------
Signed-off-by: dependabot[bot] <[email protected]>
Co-authored-by: dependabot[bot]
<49699333+dependabot[bot]@users.noreply.github.com>
---
.../ambari/metrics/SendAllTimelineEventConverter.java | 2 +-
.../WhiteListBasedDruidToTimelineEventConverter.java | 1 -
.../ArrayCompressedBigDecimalTest.java | 4 ++--
.../emitter/graphite/SendAllGraphiteEventConverter.java | 2 +-
.../druid/emitter/graphite/WhiteListBasedConverter.java | 1 -
.../druid/grpc/server/AnonymousAuthServerInterceptor.java | 2 +-
.../apache/druid/grpc/server/GrpcEndpointInitializer.java | 2 +-
.../org/apache/druid/emitter/kafka/KafkaEmitterTest.java | 1 -
.../org/apache/druid/catalog/http/CatalogResource.java | 2 +-
.../apache/druid/catalog/storage/sql/CatalogManager.java | 2 +-
.../apache/druid/catalog/sync/CatalogUpdateListener.java | 2 +-
.../druid/storage/google/GoogleStorageDruidModule.java | 2 +-
.../apache/druid/k8s/discovery/K8sDruidNodeAnnouncer.java | 4 ++--
.../java/org/apache/druid/data/input/MapPopulator.java | 2 +-
.../org/apache/druid/data/input/orc/OrcReaderTest.java | 2 +-
.../druid/catalog/model/table/S3InputSourceDefn.java | 2 +-
.../appenderator/SegmentAllocateActionGenerator.java | 4 ++--
.../indexing/common/actions/SegmentAllocateAction.java | 2 +-
.../apache/druid/indexing/input/DruidSegmentReader.java | 4 ++--
.../org/apache/druid/indexing/overlord/CriticalAction.java | 2 +-
.../seekablestream/SeekableStreamIndexTaskRunner.java | 2 +-
.../druid/indexing/seekablestream/SequenceMetadata.java | 2 +-
.../supervisor/SeekableStreamSupervisor.java | 2 +-
.../druid/indexing/worker/http/TaskManagementResource.java | 4 ++--
.../java/org/apache/druid/msq/exec/ControllerImpl.java | 2 +-
.../apache/druid/msq/exec/SegmentLoadStatusFetcher.java | 2 +-
.../java/org/apache/druid/msq/kernel/StageDefinition.java | 8 ++++----
.../druid/msq/kernel/controller/ControllerQueryKernel.java | 2 +-
.../msq/kernel/controller/ControllerStageTracker.java | 14 +++++++-------
.../org/apache/druid/msq/util/MSQTaskQueryMakerUtils.java | 2 +-
.../org/apache/druid/msq/util/MultiStageQueryContext.java | 6 +++---
pom.xml | 2 +-
.../java/org/apache/druid/common/guava/GuavaUtils.java | 4 ++--
.../org/apache/druid/extendedset/intset/ConciseSet.java | 2 +-
.../org/apache/druid/frame/util/DurableStorageUtils.java | 2 +-
.../java/org/apache/druid/guice/ConditionalMultibind.java | 2 +-
.../java/org/apache/druid/guice/JsonConfigProvider.java | 4 ++--
.../druid/java/util/common/HumanReadableBytesRange.java | 2 +-
.../util/common/guava/ParallelMergeCombiningSequence.java | 2 +-
.../util/common/parsers/CloseableIteratorWithMetadata.java | 2 +-
.../org/apache/druid/math/expr/ExpressionProcessing.java | 2 +-
.../apache/druid/query/aggregation/BufferAggregator.java | 2 +-
.../apache/druid/query/aggregation/VectorAggregator.java | 2 +-
.../org/apache/druid/query/context/ResponseContext.java | 2 +-
.../org/apache/druid/query/dimension/DimensionSpec.java | 2 +-
.../java/org/apache/druid/query/filter/ValueMatcher.java | 2 +-
.../druid/query/filter/vector/ReadableVectorMatch.java | 2 +-
.../druid/query/filter/vector/VectorValueMatcher.java | 2 +-
.../org/apache/druid/segment/ColumnSelectorFactory.java | 2 +-
.../src/main/java/org/apache/druid/segment/Cursor.java | 2 +-
.../java/org/apache/druid/segment/DimensionSelector.java | 4 ++--
.../java/org/apache/druid/segment/data/ReadableOffset.java | 2 +-
.../druid/segment/join/filter/JoinFilterAnalyzer.java | 8 ++++----
.../org/apache/druid/segment/join/table/IndexedTable.java | 2 +-
.../druid/segment/nested/StructuredDataProcessor.java | 6 +++---
.../java/org/apache/druid/segment/serde/Serializer.java | 2 +-
.../org/apache/druid/segment/serde/cell/CellReader.java | 2 +-
.../druid/segment/vector/ConcatenatingVectorCursor.java | 4 ++--
.../segment/vector/MultiValueDimensionVectorSelector.java | 4 ++--
.../apache/druid/segment/vector/ReadableVectorOffset.java | 4 ++--
.../segment/vector/SingleValueDimensionVectorSelector.java | 4 ++--
.../java/org/apache/druid/segment/vector/VectorCursor.java | 2 +-
.../java/org/apache/druid/segment/vector/VectorOffset.java | 2 +-
.../apache/druid/segment/vector/VectorValueSelector.java | 2 +-
.../apache/druid/segment/virtual/ExpressionSelectors.java | 2 +-
.../virtual/RowBasedExpressionColumnValueSelector.java | 2 +-
.../org/apache/druid/timeline/SegmentStatusInCluster.java | 2 +-
.../java/org/apache/druid/catalog/model/ResolvedTable.java | 2 +-
.../java/org/apache/druid/catalog/model/TableMetadata.java | 2 +-
.../druid/catalog/model/table/BaseInputSourceDefn.java | 2 +-
.../druid/catalog/model/table/BaseTableFunction.java | 2 +-
.../druid/catalog/model/table/HttpInputSourceDefn.java | 1 +
.../apache/druid/catalog/model/table/InputSourceDefn.java | 2 +-
.../druid/catalog/model/table/ResolvedExternalTable.java | 2 +-
.../apache/druid/catalog/model/table/TableFunction.java | 2 +-
.../org/apache/druid/client/BaseBrokerViewOfConfig.java | 6 ++++--
.../org/apache/druid/client/ImmutableDruidDataSource.java | 4 ++--
.../realtime/appenderator/AppenderatorDriverAddResult.java | 2 +-
.../druid/server/compaction/ReindexingDataSchemaRule.java | 2 +-
.../coordinator/duty/MarkEternityTombstonesAsUnused.java | 1 -
.../druid/server/emitter/ExtraServiceDimensions.java | 2 ++
.../apache/druid/server/http/SegmentListerResource.java | 4 ++--
.../server/listener/resource/AbstractListenerHandler.java | 2 +-
.../lookup/cache/LookupExtractorFactoryMapContainer.java | 2 +-
.../org/apache/druid/server/security/Authenticator.java | 2 +-
.../druid/client/cache/BackgroundCachePopulatorTest.java | 2 +-
.../src/main/java/org/apache/druid/cli/PeonTaskHolder.java | 2 +-
.../org/apache/druid/guice/AbstractDruidServiceModule.java | 4 ++--
.../apache/druid/sql/calcite/external/ExtendOperator.java | 2 +-
.../org/apache/druid/sql/calcite/planner/QueryHandler.java | 2 +-
.../org/apache/druid/sql/calcite/table/RowSignatures.java | 4 ++--
.../apache/druid/sql/calcite/MultiComponentSupplier.java | 2 +-
.../java/org/apache/druid/sql/calcite/NotYetSupported.java | 2 +-
.../apache/druid/sql/calcite/SqlTestFrameworkConfig.java | 2 +-
94 files changed, 126 insertions(+), 125 deletions(-)
diff --git
a/extensions-contrib/ambari-metrics-emitter/src/main/java/org/apache/druid/emitter/ambari/metrics/SendAllTimelineEventConverter.java
b/extensions-contrib/ambari-metrics-emitter/src/main/java/org/apache/druid/emitter/ambari/metrics/SendAllTimelineEventConverter.java
index 6467418468b..064f84a5627 100644
---
a/extensions-contrib/ambari-metrics-emitter/src/main/java/org/apache/druid/emitter/ambari/metrics/SendAllTimelineEventConverter.java
+++
b/extensions-contrib/ambari-metrics-emitter/src/main/java/org/apache/druid/emitter/ambari/metrics/SendAllTimelineEventConverter.java
@@ -35,7 +35,7 @@ import
org.apache.hadoop.metrics2.sink.timeline.TimelineMetric;
* All the dimensions will be retained and lexicographically order using
dimensions name.
* <p>
* The metric name of the timeline event is:
- * <namespacePrefix>.<druid service name>.<dimensions values ordered by
dimension's name>.<metric>
+ * {@code <namespacePrefix>.<druid service name>.<dimensions values ordered by
dimension's name>.<metric>}
* <p>
* Note that this name will be sanitized by replacing all the `.` or `space`
to `_` {@link AmbariMetricsEmitter#sanitize(String)}
*/
diff --git
a/extensions-contrib/ambari-metrics-emitter/src/main/java/org/apache/druid/emitter/ambari/metrics/WhiteListBasedDruidToTimelineEventConverter.java
b/extensions-contrib/ambari-metrics-emitter/src/main/java/org/apache/druid/emitter/ambari/metrics/WhiteListBasedDruidToTimelineEventConverter.java
index aa0def755c1..de904b9d6f9 100644
---
a/extensions-contrib/ambari-metrics-emitter/src/main/java/org/apache/druid/emitter/ambari/metrics/WhiteListBasedDruidToTimelineEventConverter.java
+++
b/extensions-contrib/ambari-metrics-emitter/src/main/java/org/apache/druid/emitter/ambari/metrics/WhiteListBasedDruidToTimelineEventConverter.java
@@ -174,7 +174,6 @@ public class WhiteListBasedDruidToTimelineEventConverter
implements DruidToTimel
* <p/>
* The order of the dimension is the order returned by {@code
getOrderedDimValues()}
* Note that this name will be sanitized by replacing all the `.` or space
by `_` {@link AmbariMetricsEmitter#sanitize(String)}
- * </p>
*/
@Override
diff --git
a/extensions-contrib/compressed-bigdecimal/src/test/java/org/apache/druid/compressedbigdecimal/ArrayCompressedBigDecimalTest.java
b/extensions-contrib/compressed-bigdecimal/src/test/java/org/apache/druid/compressedbigdecimal/ArrayCompressedBigDecimalTest.java
index a49e0bbd0e4..48ab5e2d700 100644
---
a/extensions-contrib/compressed-bigdecimal/src/test/java/org/apache/druid/compressedbigdecimal/ArrayCompressedBigDecimalTest.java
+++
b/extensions-contrib/compressed-bigdecimal/src/test/java/org/apache/druid/compressedbigdecimal/ArrayCompressedBigDecimalTest.java
@@ -505,7 +505,7 @@ public class ArrayCompressedBigDecimalTest
}
/**
- * Test method for {@link ArrayCompressedBigDecimal#setArrayEntry
+ * Test method for {@link ArrayCompressedBigDecimal#setArrayEntry}
*/
@Test
public void testSetArrayEntry()
@@ -580,7 +580,7 @@ public class ArrayCompressedBigDecimalTest
}
/**
- * Test method for {@link CompressedBigDecimalObjectStrategy
+ * Test method for {@link CompressedBigDecimalObjectStrategy}
*/
@Test
public void testCompressedBigDecimalObjectStrategy()
diff --git
a/extensions-contrib/graphite-emitter/src/main/java/org/apache/druid/emitter/graphite/SendAllGraphiteEventConverter.java
b/extensions-contrib/graphite-emitter/src/main/java/org/apache/druid/emitter/graphite/SendAllGraphiteEventConverter.java
index 23d79ded7c5..d0fab3f65e2 100644
---
a/extensions-contrib/graphite-emitter/src/main/java/org/apache/druid/emitter/graphite/SendAllGraphiteEventConverter.java
+++
b/extensions-contrib/graphite-emitter/src/main/java/org/apache/druid/emitter/graphite/SendAllGraphiteEventConverter.java
@@ -36,7 +36,7 @@ import java.util.concurrent.TimeUnit;
* All the dimensions will be retained and lexicographically order using
dimensions name.
* <p>
* The metric path of the graphite event is:
- * <namespacePrefix>.[<druid service name>].[<druid hostname>].<dimensions
values ordered by dimension's name>.<metric>
+ * {@code <namespacePrefix>.[<druid service name>].[<druid
hostname>].<dimensions values ordered by dimension's name>.<metric>}
* <p>
* Note that this path will be sanitized by replacing all the `.` or `space`
to `_` {@link GraphiteEmitter#sanitize(String)}
*/
diff --git
a/extensions-contrib/graphite-emitter/src/main/java/org/apache/druid/emitter/graphite/WhiteListBasedConverter.java
b/extensions-contrib/graphite-emitter/src/main/java/org/apache/druid/emitter/graphite/WhiteListBasedConverter.java
index 8027e237e91..843645b5feb 100644
---
a/extensions-contrib/graphite-emitter/src/main/java/org/apache/druid/emitter/graphite/WhiteListBasedConverter.java
+++
b/extensions-contrib/graphite-emitter/src/main/java/org/apache/druid/emitter/graphite/WhiteListBasedConverter.java
@@ -201,7 +201,6 @@ public class WhiteListBasedConverter implements
DruidToGraphiteEventConverter
* <p/>
* The order of the dimension is the order returned by {@code
getOrderedDimValues()}
* Note that this path will be sanitized by replacing all the `.` or space
by `_` {@link GraphiteEmitter#sanitize(String)}
- * </p>
*/
@Override
diff --git
a/extensions-contrib/grpc-query/src/main/java/org/apache/druid/grpc/server/AnonymousAuthServerInterceptor.java
b/extensions-contrib/grpc-query/src/main/java/org/apache/druid/grpc/server/AnonymousAuthServerInterceptor.java
index 3059c603d47..e3e1895b728 100644
---
a/extensions-contrib/grpc-query/src/main/java/org/apache/druid/grpc/server/AnonymousAuthServerInterceptor.java
+++
b/extensions-contrib/grpc-query/src/main/java/org/apache/druid/grpc/server/AnonymousAuthServerInterceptor.java
@@ -36,7 +36,7 @@ import javax.inject.Inject;
* authorization result in the context. Use this form for either of Druid's
* "allow all" authorizers.
*
- * @see {@link BasicAuthServerInterceptor} for details
+ * @see BasicAuthServerInterceptor for details
*/
public class AnonymousAuthServerInterceptor implements ServerInterceptor
{
diff --git
a/extensions-contrib/grpc-query/src/main/java/org/apache/druid/grpc/server/GrpcEndpointInitializer.java
b/extensions-contrib/grpc-query/src/main/java/org/apache/druid/grpc/server/GrpcEndpointInitializer.java
index ed69719c2fd..5e81062f246 100644
---
a/extensions-contrib/grpc-query/src/main/java/org/apache/druid/grpc/server/GrpcEndpointInitializer.java
+++
b/extensions-contrib/grpc-query/src/main/java/org/apache/druid/grpc/server/GrpcEndpointInitializer.java
@@ -39,7 +39,7 @@ import java.io.IOException;
/**
* Initializes the gRPC endpoint (server). This version uses a Netty-based
server
* separate from Druid's primary Jetty-based server. We may want to consider a
- * <link
a="https://github.com/grpc/grpc-java/tree/master/examples/example-servlet";>
+ * <a
href="https://github.com/grpc/grpc-java/tree/master/examples/example-servlet";>
* recent addition to the gRPC examples</a> to run gRPC as a servlet. However,
trying
* that turned out to incur many issues, including the fact that there was no
way
* to pass the AuthenticationResult down through the many layers of gRPC into
the
diff --git
a/extensions-contrib/kafka-emitter/src/test/java/org/apache/druid/emitter/kafka/KafkaEmitterTest.java
b/extensions-contrib/kafka-emitter/src/test/java/org/apache/druid/emitter/kafka/KafkaEmitterTest.java
index 4505a845aac..0f6f91df1c6 100644
---
a/extensions-contrib/kafka-emitter/src/test/java/org/apache/druid/emitter/kafka/KafkaEmitterTest.java
+++
b/extensions-contrib/kafka-emitter/src/test/java/org/apache/druid/emitter/kafka/KafkaEmitterTest.java
@@ -419,7 +419,6 @@ public class KafkaEmitterTest
* Unit test to validate the handling of {@link ServiceMetricEvent}s and
{@link TestEvent}s.
* The default event types (alerts and metrics) are subscribed in the
config, so the expectation is that only
* {@link ServiceMetricEvent} is expected to be emitted, while dropping all
unknown {@link TestEvent}s.
- * </p>
*/
@Test
@Timeout(value = 10_000, unit = TimeUnit.MILLISECONDS)
diff --git
a/extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/http/CatalogResource.java
b/extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/http/CatalogResource.java
index c11cfb9a315..6a75d74bb68 100644
---
a/extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/http/CatalogResource.java
+++
b/extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/http/CatalogResource.java
@@ -70,7 +70,7 @@ import java.util.stream.Collectors;
* etc. Operations occur at the global level (all schemas), the schema level,
or the
* table level.
*
- * @see {@link CatalogListenerResource} for the broker-side API.
+ * @see CatalogListenerResource for the broker-side API.
*/
@Path(CatalogResource.ROOT_PATH)
public class CatalogResource
diff --git
a/extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/storage/sql/CatalogManager.java
b/extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/storage/sql/CatalogManager.java
index cb1733b54f0..5dd098bd02b 100644
---
a/extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/storage/sql/CatalogManager.java
+++
b/extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/storage/sql/CatalogManager.java
@@ -74,7 +74,7 @@ public interface CatalogManager
* @return the version of the newly created table. Call
* {@link TableMetadata#asUpdate(long)} if you want a new
* {@link TableMetadata} with the new version.
- * @throws {@link DuplicateKeyException} if the row is a duplicate
+ * @throws DuplicateKeyException if the row is a duplicate
* (schema, name) pair. This generally indicates a code error,
* or since our code is perfect, a race condition or a DB
* update outside of Druid. In any event, the error is not
diff --git
a/extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/sync/CatalogUpdateListener.java
b/extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/sync/CatalogUpdateListener.java
index 553ed49c00f..eb91128d047 100644
---
a/extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/sync/CatalogUpdateListener.java
+++
b/extensions-core/druid-catalog/src/main/java/org/apache/druid/catalog/sync/CatalogUpdateListener.java
@@ -22,7 +22,7 @@ package org.apache.druid.catalog.sync;
/**
* Generic interface for changes to the catalog at the storage level.
* Implemented by the catalog sync mechanism to send update events
- * to the Broker. Note that these events are about the <i>catalog</li>,
+ * to the Broker. Note that these events are about the <i>catalog</i>,
* not about the physical storage of tables (i.e. datasources.)
*/
public interface CatalogUpdateListener
diff --git
a/extensions-core/google-extensions/src/main/java/org/apache/druid/storage/google/GoogleStorageDruidModule.java
b/extensions-core/google-extensions/src/main/java/org/apache/druid/storage/google/GoogleStorageDruidModule.java
index d951abde6b2..da5659ea61f 100644
---
a/extensions-core/google-extensions/src/main/java/org/apache/druid/storage/google/GoogleStorageDruidModule.java
+++
b/extensions-core/google-extensions/src/main/java/org/apache/druid/storage/google/GoogleStorageDruidModule.java
@@ -116,7 +116,7 @@ public class GoogleStorageDruidModule implements DruidModule
}
/**
- * Returns a GoogleStorage that lazily initialize {@link {@link Storage}}.
+ * Returns a GoogleStorage that lazily initialize {@link Storage}.
* This is to avoid immediate config validation but defer it until you
actually use the client.
*/
@Provides
diff --git
a/extensions-core/kubernetes-extensions/src/main/java/org/apache/druid/k8s/discovery/K8sDruidNodeAnnouncer.java
b/extensions-core/kubernetes-extensions/src/main/java/org/apache/druid/k8s/discovery/K8sDruidNodeAnnouncer.java
index f47fcfc0c9a..909ee69d82e 100644
---
a/extensions-core/kubernetes-extensions/src/main/java/org/apache/druid/k8s/discovery/K8sDruidNodeAnnouncer.java
+++
b/extensions-core/kubernetes-extensions/src/main/java/org/apache/druid/k8s/discovery/K8sDruidNodeAnnouncer.java
@@ -40,12 +40,12 @@ import java.util.Map;
* Announcement creates following in the pod def...
*
* Labels -
- * druidDiscoveryAnnouncement-<nodeRole.getJsonName()> = true
+ * druidDiscoveryAnnouncement-{@code <nodeRole.getJsonName()>} = true
* druidDiscoveryAnnouncement-id-hash =
hashEncodeStringForLabelValue(host:port)
* druidDiscoveryAnnouncement-cluster-identifier = <clusterIdentifier>
*
* Annotation -
- * druidNodeInfo-<nodeRole.getJsonName()> = json_serialize(DiscoveryDruidNode)
+ * druidNodeInfo-{@code <nodeRole.getJsonName()>} =
json_serialize(DiscoveryDruidNode)
*
* Note that, a node can have multiple roles e.g. coordinator can take up
overlord's role as well.
*/
diff --git
a/extensions-core/lookups-cached-global/src/main/java/org/apache/druid/data/input/MapPopulator.java
b/extensions-core/lookups-cached-global/src/main/java/org/apache/druid/data/input/MapPopulator.java
index a0b591f2122..435ff2ad3bb 100644
---
a/extensions-core/lookups-cached-global/src/main/java/org/apache/druid/data/input/MapPopulator.java
+++
b/extensions-core/lookups-cached-global/src/main/java/org/apache/druid/data/input/MapPopulator.java
@@ -34,7 +34,7 @@ import java.util.Iterator;
import java.util.Map;
/**
- * Simple class that takes a `ByteSource` and uses a `Parser<K, V>` to
populate a `Map<K, V>`
+ * Simple class that takes a `ByteSource` and uses a {@code Parser<K, V>} to
populate a {@code Map<K, V>}
* The `ByteSource` must be UTF-8 encoded
* <p>
* If this is handy for other use cases pleaes move this class into a common
module
diff --git
a/extensions-core/orc-extensions/src/test/java/org/apache/druid/data/input/orc/OrcReaderTest.java
b/extensions-core/orc-extensions/src/test/java/org/apache/druid/data/input/orc/OrcReaderTest.java
index 71f73117b13..52a73320f0a 100644
---
a/extensions-core/orc-extensions/src/test/java/org/apache/druid/data/input/orc/OrcReaderTest.java
+++
b/extensions-core/orc-extensions/src/test/java/org/apache/druid/data/input/orc/OrcReaderTest.java
@@ -264,7 +264,7 @@ public class OrcReaderTest extends
InitializedNullHandlingTest
}
/**
- * schema: struct<string1:string, list:array<int>, ts:timestamp>
+ * schema: {@code struct<string1:string, list:array<int>, ts:timestamp>}
* data: {"dim1","[7,8,9]","2000-03-12 15:00:00"}
*/
@Test
diff --git
a/extensions-core/s3-extensions/src/main/java/org/apache/druid/catalog/model/table/S3InputSourceDefn.java
b/extensions-core/s3-extensions/src/main/java/org/apache/druid/catalog/model/table/S3InputSourceDefn.java
index ca84236d14a..65506d0be7e 100644
---
a/extensions-core/s3-extensions/src/main/java/org/apache/druid/catalog/model/table/S3InputSourceDefn.java
+++
b/extensions-core/s3-extensions/src/main/java/org/apache/druid/catalog/model/table/S3InputSourceDefn.java
@@ -66,7 +66,7 @@ import java.util.Map;
* and the {@code format}. The user must provide the list of columns.</li>
* </ul>
*
- * @see {@link S3InputSource} for details on the meaning of the various
properties, and the rules
+ * @see S3InputSource for details on the meaning of the various properties,
and the rules
* about valid combinations
*/
public class S3InputSourceDefn extends FormattedInputSourceDefn
diff --git
a/indexing-service/src/main/java/org/apache/druid/indexing/appenderator/SegmentAllocateActionGenerator.java
b/indexing-service/src/main/java/org/apache/druid/indexing/appenderator/SegmentAllocateActionGenerator.java
index 07d3f30d4c5..1a1ca2e321d 100644
---
a/indexing-service/src/main/java/org/apache/druid/indexing/appenderator/SegmentAllocateActionGenerator.java
+++
b/indexing-service/src/main/java/org/apache/druid/indexing/appenderator/SegmentAllocateActionGenerator.java
@@ -26,8 +26,8 @@ import
org.apache.druid.segment.realtime.appenderator.SegmentIdWithShardSpec;
/**
* This class is used in {@link ActionBasedSegmentAllocator} and expected to
generate a
- * {@link TaskAction< SegmentIdWithShardSpec >} which is submitted to
overlords to allocate a new segment.
- * The {@link #generate} method can return any implementation of {@link
TaskAction< SegmentIdWithShardSpec >}.
+ * {@link TaskAction<SegmentIdWithShardSpec>} which is submitted to overlords
to allocate a new segment.
+ * The {@link #generate} method can return any implementation of {@link
TaskAction<SegmentIdWithShardSpec>}.
*
* @see org.apache.druid.indexing.common.actions.SegmentAllocateAction
* @see org.apache.druid.indexing.common.actions.SurrogateAction
diff --git
a/indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentAllocateAction.java
b/indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentAllocateAction.java
index 859d60bdd16..35467611bdf 100644
---
a/indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentAllocateAction.java
+++
b/indexing-service/src/main/java/org/apache/druid/indexing/common/actions/SegmentAllocateAction.java
@@ -68,7 +68,7 @@ import java.util.concurrent.ThreadLocalRandom;
* <p/>
* If this action cannot acquire an appropriate task lock, or if it cannot
expand an existing segment set, it returns
* null.
- * </p>
+ * <p/>
* Do NOT allocate WEEK granularity segments unless the preferred segment
granularity is WEEK.
*/
public class SegmentAllocateAction implements
TaskAction<SegmentIdWithShardSpec>
diff --git
a/indexing-service/src/main/java/org/apache/druid/indexing/input/DruidSegmentReader.java
b/indexing-service/src/main/java/org/apache/druid/indexing/input/DruidSegmentReader.java
index 2e4d64799aa..fabc2eb7dcf 100644
---
a/indexing-service/src/main/java/org/apache/druid/indexing/input/DruidSegmentReader.java
+++
b/indexing-service/src/main/java/org/apache/druid/indexing/input/DruidSegmentReader.java
@@ -168,7 +168,7 @@ public class DruidSegmentReader extends
IntermediateRowParsingReader<Map<String,
/**
* Given a {@link Cursor} create a {@link Sequence} that returns the rows of
the cursor as
- * Map<String, Object> intermediate rows, selecting the dimensions and
metrics of this segment reader.
+ * {@code Map<String, Object>} intermediate rows, selecting the dimensions
and metrics of this segment reader.
*
* @param cursor A cursor
*
@@ -292,7 +292,7 @@ public class DruidSegmentReader extends
IntermediateRowParsingReader<Map<String,
/**
* Given a {@link Cursor}, a list of dimension names, and a list of metric
names, this iterator
- * returns the rows of the cursor as Map<String, Object> intermediate rows.
+ * returns the rows of the cursor as {@code Map<String, Object>}
intermediate rows.
*/
private static class IntermediateRowFromCursorIterator implements
Iterator<Map<String, Object>>
{
diff --git
a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/CriticalAction.java
b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/CriticalAction.java
index 70aeb5abb91..11a4972d9c9 100644
---
a/indexing-service/src/main/java/org/apache/druid/indexing/overlord/CriticalAction.java
+++
b/indexing-service/src/main/java/org/apache/druid/indexing/overlord/CriticalAction.java
@@ -27,7 +27,7 @@ import org.joda.time.Interval;
* This class represents a critical action must be done while the task's lock
is guaranteed to not be revoked in the
* middle of the action.
*
- * Implementations must not change the lock state by calling {@link
GlobalTaskLockbox#lock)}, {@link GlobalTaskLockbox#tryLock)},
+ * Implementations must not change the lock state by calling {@link
GlobalTaskLockbox#lock}, {@link GlobalTaskLockbox#tryLock},
* or {@link GlobalTaskLockbox#unlock(Task, Interval)}.
*
* Also, implementations should be finished as soon as possible because all
methods in {@link GlobalTaskLockbox} are blocked
diff --git
a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java
b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java
index 99a6d02dc37..1239f9f1c7e 100644
---
a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java
+++
b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SeekableStreamIndexTaskRunner.java
@@ -2260,7 +2260,7 @@ public abstract class
SeekableStreamIndexTaskRunner<PartitionIdType, SequenceOff
protected abstract boolean isEndOfShard(SequenceOffsetType seqNum);
/**
- * deserializes the checkpoints into of Map<sequenceId, Map<PartitionIdType,
SequenceOffsetType>>
+ * deserializes the checkpoints into of {@code Map<sequenceId,
Map<PartitionIdType, SequenceOffsetType>>}
*
* @param toolbox task toolbox
* @param checkpointsString the json-serialized checkpoint string
diff --git
a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SequenceMetadata.java
b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SequenceMetadata.java
index 678e8bff5c8..6d6337ac2cb 100644
---
a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SequenceMetadata.java
+++
b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/SequenceMetadata.java
@@ -63,7 +63,7 @@ public class SequenceMetadata<PartitionIdType,
SequenceOffsetType>
private final boolean sentinel;
/**
* Lock for accessing {@link #endOffsets} and {@link #checkpointed}. This
lock is required because
- * {@link #setEndOffsets)} can be called by both the main thread and the
HTTP thread.
+ * {@link #setEndOffsets} can be called by both the main thread and the HTTP
thread.
*/
private final ReentrantLock lock = new ReentrantLock();
diff --git
a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java
b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java
index 35eed987a51..f37ecca4ff8 100644
---
a/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java
+++
b/indexing-service/src/main/java/org/apache/druid/indexing/seekablestream/supervisor/SeekableStreamSupervisor.java
@@ -3557,7 +3557,7 @@ public abstract class
SeekableStreamSupervisor<PartitionIdType, SequenceOffsetTy
/**
* Converts a map with string keys from BoundedStreamConfig to a properly
typed map.
- * The BoundedStreamConfig uses Map<?, ?> which Jackson deserializes as
Map<String, Object>.
+ * The BoundedStreamConfig uses {@code Map<?, ?>} which Jackson deserializes
as {@code Map<String, Object>}.
* This method converts string keys to partition IDs and offset values to
the appropriate types.
*
* @param rawMap the raw map from BoundedStreamConfig
diff --git
a/indexing-service/src/main/java/org/apache/druid/indexing/worker/http/TaskManagementResource.java
b/indexing-service/src/main/java/org/apache/druid/indexing/worker/http/TaskManagementResource.java
index 5cb22cbc9e2..63d30f06d0a 100644
---
a/indexing-service/src/main/java/org/apache/druid/indexing/worker/http/TaskManagementResource.java
+++
b/indexing-service/src/main/java/org/apache/druid/indexing/worker/http/TaskManagementResource.java
@@ -85,10 +85,10 @@ public class TaskManagementResource
* Here is how, this is used.
*
* (1) Client sends first request
/druid/internal/v1/worker?counter=-1&timeout=<timeout>
- * Server responds with current list of running/completed tasks and
metadata. And, a <counter,hash> pair.
+ * Server responds with current list of running/completed tasks and
metadata. And, a {@code <counter,hash>} pair.
*
* (2) Client sends subsequent requests
/druid/internal/v1/worker?counter=<counter>&hash=<hash>&timeout=<timeout>
- * Where <counter,hash> values are used from the last response. Server
responds with changes since then.
+ * Where {@code <counter,hash>} values are used from the last response.
Server responds with changes since then.
*
* This endpoint makes the client wait till either there is some update or
given timeout elapses.
*
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 17a729f2348..bd87333e532 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
@@ -849,7 +849,7 @@ public class ControllerImpl implements Controller
/**
* Adds the work orders for worker to {@link
ControllerImpl#workOrdersToRetry} if the {@link ControllerQueryKernel}
determines that there
* are work orders which needs reprocessing.
- * <br></br>
+ * <br>
* This method is not thread safe, so it should always be called inside the
main controller thread.
*/
private void addToRetryQueue(ControllerQueryKernel kernel, int worker,
MSQFault fault)
diff --git
a/multi-stage-query/src/main/java/org/apache/druid/msq/exec/SegmentLoadStatusFetcher.java
b/multi-stage-query/src/main/java/org/apache/druid/msq/exec/SegmentLoadStatusFetcher.java
index 32058d161f2..a2770e79949 100644
---
a/multi-stage-query/src/main/java/org/apache/druid/msq/exec/SegmentLoadStatusFetcher.java
+++
b/multi-stage-query/src/main/java/org/apache/druid/msq/exec/SegmentLoadStatusFetcher.java
@@ -131,7 +131,7 @@ public class SegmentLoadStatusFetcher implements
AutoCloseable
}
/**
- * Uses broker client to check if all segments created by the ingestion have
been loaded and updates the {@link #status)}
+ * Uses broker client to check if all segments created by the ingestion have
been loaded and updates the {@link #status}
* periodically.
* <br>
* If an exception is thrown during operation, this will log the exception
and return without failing the task,
diff --git
a/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/StageDefinition.java
b/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/StageDefinition.java
index 7fc3db19f1a..73d44687590 100644
---
a/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/StageDefinition.java
+++
b/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/StageDefinition.java
@@ -368,13 +368,13 @@ public class StageDefinition
/**
* Returns true, if the shuffling stage requires key statistics from the
workers.
- * <br></br>
+ * <br>
* Returns false, if the stage does not shuffle.
- * <br></br>
- * <br></br>
+ * <br>
+ * <br>
* It's possible we're shuffling using partition boundaries that are known
ahead of time
* For eg: we know there's exactly one partition in query shapes like
`select with limit`.
- * <br></br>
+ * <br>
* In such cases, we return a false.
*/
public boolean mustGatherResultKeyStatistics()
diff --git
a/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernel.java
b/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernel.java
index 7356daef89a..be4bf51bcae 100644
---
a/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernel.java
+++
b/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerQueryKernel.java
@@ -138,7 +138,7 @@ public class ControllerQueryKernel
private final Set<StageId> effectivelyFinishedStages = new HashSet<>();
/**
- * Map<StageId, Map <WorkerNumber, WorkOrder>>
+ * {@code Map<StageId, Map <WorkerNumber, WorkOrder>>}
* Stores the work order per worker per stage so that we can retrieve that
in case of worker retry
*/
private final Map<StageId, Int2ObjectMap<WorkOrder>> stageWorkOrders = new
HashMap<>();
diff --git
a/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerStageTracker.java
b/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerStageTracker.java
index 0a084986a47..74664878cdd 100644
---
a/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerStageTracker.java
+++
b/multi-stage-query/src/main/java/org/apache/druid/msq/kernel/controller/ControllerStageTracker.java
@@ -527,10 +527,10 @@ class ControllerStageTracker
* Merges the {@link ClusterByStatisticsSnapshot} for the worker, time
chunk with the stage {@link ClusterByStatisticsCollector} being
* tracked at {@link #timeChunkToCollector} for the same time chunk. This
method is called when
* {@link ClusterStatisticsMergeMode#SEQUENTIAL} is chosen eventually.
- * <br></br>
- * <br></br>
+ * <br>
+ * <br>
* If all the stats from the worker are merged, we transition the worker to
{@link
ControllerWorkerStagePhase#PRESHUFFLE_WAITING_FOR_RESULT_PARTITION_BOUNDARIES};
- * <br></br>
+ * <br>
* If all the stats from all the workers are merged, we transition the stage
to {@link ControllerStagePhase#POST_READING}
*/
void mergeClusterByStatisticsCollectorForTimeChunk(
@@ -664,10 +664,10 @@ class ControllerStageTracker
* Merges the entire {@link ClusterByStatisticsSnapshot} for the worker with
the stage {@link ClusterByStatisticsCollector} being
* tracked at {@link #timeChunkToCollector} with key {@link
ControllerStageTracker#STATIC_TIME_CHUNK_FOR_PARALLEL_MERGE}. This method is
called when
* {@link ClusterStatisticsMergeMode#PARALLEL} is chosen eventually.
- * <br></br>
- * <br></br>
+ * <br>
+ * <br>
* If all the stats from the worker are merged, we transition the worker to
{@link
ControllerWorkerStagePhase#PRESHUFFLE_WAITING_FOR_RESULT_PARTITION_BOUNDARIES}.
- * <br></br>
+ * <br>
* If all the stats from all the workers are merged, we transition the stage
to {@link ControllerStagePhase#POST_READING}.
*/
@@ -1144,7 +1144,7 @@ class ControllerStageTracker
}
/**
- * Transitions the worker to {@link
ControllerWorkerStagePhase#PRESHUFFLE_FETCHING_ALL_KEY_STATS) indicating
fetching has begun.
+ * Transitions the worker to {@link
ControllerWorkerStagePhase#PRESHUFFLE_FETCHING_ALL_KEY_STATS} indicating
fetching has begun.
*/
public void startFetchingStatsFromWorker(int worker)
{
diff --git
a/multi-stage-query/src/main/java/org/apache/druid/msq/util/MSQTaskQueryMakerUtils.java
b/multi-stage-query/src/main/java/org/apache/druid/msq/util/MSQTaskQueryMakerUtils.java
index 955bc3483c1..e00aa701cdf 100644
---
a/multi-stage-query/src/main/java/org/apache/druid/msq/util/MSQTaskQueryMakerUtils.java
+++
b/multi-stage-query/src/main/java/org/apache/druid/msq/util/MSQTaskQueryMakerUtils.java
@@ -55,7 +55,7 @@ public class MSQTaskQueryMakerUtils
/**
* This method masks the sensitive json keys that might be present in the
SQL query matching the regex
* {@code key(\s)+:(\s)+{sensitive_data}}
- * The regex pattern matches a json entry of form "key":{value} and replaces
it with "key":\<masked\>
+ * The regex pattern matches a json entry of form "key":{value} and replaces
it with {@code "key":<masked>}
* It checks the sensitive keys for the match, greedily matches the first
occuring brace pair ("{" and "}")
* into a regex group named "sensitive" and performs a string replace on the
group. The whitespaces are accounted
* for in the regex.
diff --git
a/multi-stage-query/src/main/java/org/apache/druid/msq/util/MultiStageQueryContext.java
b/multi-stage-query/src/main/java/org/apache/druid/msq/util/MultiStageQueryContext.java
index 525010787eb..280a6058d89 100644
---
a/multi-stage-query/src/main/java/org/apache/druid/msq/util/MultiStageQueryContext.java
+++
b/multi-stage-query/src/main/java/org/apache/druid/msq/util/MultiStageQueryContext.java
@@ -72,16 +72,16 @@ import java.util.stream.Collectors;
* One of the design goals for MSQ is to have less turning parameters. If a
parameter is not expected to change the result
* of a job, but only how the job runs, it's a parameter we can skip
documenting in external docs.
* </p>
- * <br></br>
+ * <br>
* List of context parameters not present in external docs:
- * <br></br>
+ * <br>
* <ol>
*
* <li><b>maxInputBytesPerWorker</b>: Should be used in conjunction with
taskAssignment `auto` mode. When dividing the
* input of a stage among the workers, this parameter determines the maximum
size in bytes that are given to a single worker
* before the next worker is chosen.This parameter is only used as a guideline
during input slicing, and does not guarantee
* that a the input cannot be larger.
- * <br></br>
+ * <br>
* For example, we have 3 files. 3, 7, 12 GB each. then we would end up using
2 worker: worker 1 -> 3, 7 and worker 2 -> 12.
* This value is used for all stages in a query. Default valus is:
<b>10737418240</b></li>
*
diff --git a/pom.xml b/pom.xml
index 43d08b318a3..3be71e3f91c 100644
--- a/pom.xml
+++ b/pom.xml
@@ -1740,7 +1740,7 @@
<dependency>
<groupId>com.puppycrawl.tools</groupId>
<artifactId>checkstyle</artifactId>
- <version>12.3.1</version>
+ <version>14.3.0</version>
</dependency>
</dependencies>
<executions>
diff --git
a/processing/src/main/java/org/apache/druid/common/guava/GuavaUtils.java
b/processing/src/main/java/org/apache/druid/common/guava/GuavaUtils.java
index 6b1ccbaae4a..20a06af13a5 100644
--- a/processing/src/main/java/org/apache/druid/common/guava/GuavaUtils.java
+++ b/processing/src/main/java/org/apache/druid/common/guava/GuavaUtils.java
@@ -71,7 +71,7 @@ public class GuavaUtils
/**
* If first argument is not null, return it, else return the other argument.
- * Sort of like {@link <T> com.google.common.base.Objects#firstNonNull(T, T)}
+ * Sort of like {@link
com.google.common.base.MoreObjects#firstNonNull(Object, Object)}
* except will not explode if both arguments are null.
*/
@Nullable
@@ -87,7 +87,7 @@ public class GuavaUtils
* Cancel futures manually, because sometime we can't cancel all futures in
* {code com.google.common.util.concurrent.Futures.CombinedFuture}
* automatically. Especially when we call
- * {@link static <V> ListenableFuture<List<V>>
com.google.common.util.concurrent.Futures#allAsList(Iterable<? extends
ListenableFuture <? extends V>> futures)}
+ * {@link com.google.common.util.concurrent.Futures#allAsList(Iterable)}
* to create a batch of future.
* @param mayInterruptIfRunning {@code true} if the thread executing this
* task should be interrupted; otherwise, in-progress tasks are allowed
diff --git
a/processing/src/main/java/org/apache/druid/extendedset/intset/ConciseSet.java
b/processing/src/main/java/org/apache/druid/extendedset/intset/ConciseSet.java
index c197da823d0..b2379bac2a8 100755
---
a/processing/src/main/java/org/apache/druid/extendedset/intset/ConciseSet.java
+++
b/processing/src/main/java/org/apache/druid/extendedset/intset/ConciseSet.java
@@ -413,7 +413,7 @@ public class ConciseSet extends AbstractIntSet implements
Serializable
* string. The bit <i>must</i> be appendable, that is it must represent an
* integer that is strictly greater than the maximum integer in the set.
* Note that the parameter range check is performed by the public method
- * {@link #add)} and <i>not</i> in this method.
+ * {@link #add} and <i>not</i> in this method.
* <p/>
* <b>NOTE:</b> This method assumes that the last element of {@link #words}
* (i.e. <code>getLastWord()</code>) <i>must</i> be one of the
diff --git
a/processing/src/main/java/org/apache/druid/frame/util/DurableStorageUtils.java
b/processing/src/main/java/org/apache/druid/frame/util/DurableStorageUtils.java
index 6f3f1686475..8a389e33bbf 100644
---
a/processing/src/main/java/org/apache/druid/frame/util/DurableStorageUtils.java
+++
b/processing/src/main/java/org/apache/druid/frame/util/DurableStorageUtils.java
@@ -222,7 +222,7 @@ public class DurableStorageUtils
/**
* Tries to parse out the most top level directory from the path. Returns
null if there is no such directory.
- * <br></br>
+ * <br>
* For eg:
* <br/>
* <ul>
diff --git
a/processing/src/main/java/org/apache/druid/guice/ConditionalMultibind.java
b/processing/src/main/java/org/apache/druid/guice/ConditionalMultibind.java
index 654732c9a7d..5830d7c74e5 100644
--- a/processing/src/main/java/org/apache/druid/guice/ConditionalMultibind.java
+++ b/processing/src/main/java/org/apache/druid/guice/ConditionalMultibind.java
@@ -43,7 +43,7 @@ import java.util.Properties;
* add a binding to Cat.class. If the value is "dog", it will add a binding to
Dog.class.
*
* At injection time, you will get the items that satisfy their corresponding
predicates by calling
- * injector.getInstance(Key.get(new TypeLiteral<Set<Animal>>(){}))
+ * {@code injector.getInstance(Key.get(new TypeLiteral<Set<Animal>>(){}))}
*/
@PublicApi
public class ConditionalMultibind<T>
diff --git
a/processing/src/main/java/org/apache/druid/guice/JsonConfigProvider.java
b/processing/src/main/java/org/apache/druid/guice/JsonConfigProvider.java
index f3cc1860bdc..be035b64903 100644
--- a/processing/src/main/java/org/apache/druid/guice/JsonConfigProvider.java
+++ b/processing/src/main/java/org/apache/druid/guice/JsonConfigProvider.java
@@ -58,8 +58,8 @@ import java.util.Properties;
* <pre>
* public class DruidServerConfig
* {
- * @JsonProperty @NotNull public String hostname = null;
- * @JsonProperty @Min(1025) public int port = 8080;
+ * @JsonProperty @NotNull public String hostname = null;
+ * @JsonProperty @Min(1025) public int port = 8080;
* }
* </pre>
*
diff --git
a/processing/src/main/java/org/apache/druid/java/util/common/HumanReadableBytesRange.java
b/processing/src/main/java/org/apache/druid/java/util/common/HumanReadableBytesRange.java
index 58f044a7b44..07007bdd906 100644
---
a/processing/src/main/java/org/apache/druid/java/util/common/HumanReadableBytesRange.java
+++
b/processing/src/main/java/org/apache/druid/java/util/common/HumanReadableBytesRange.java
@@ -38,7 +38,7 @@ import java.lang.annotation.Target;
*
* <code>
* class Size {
- * @HumanReadableBytesRange( min = 5, max = 1024 )
+ * @HumanReadableBytesRange( min = 5, max = 1024 )
* private HumanReadableBytes size;
* }
* </code>
diff --git
a/processing/src/main/java/org/apache/druid/java/util/common/guava/ParallelMergeCombiningSequence.java
b/processing/src/main/java/org/apache/druid/java/util/common/guava/ParallelMergeCombiningSequence.java
index abf6e29ae8f..8d1f419ed1e 100644
---
a/processing/src/main/java/org/apache/druid/java/util/common/guava/ParallelMergeCombiningSequence.java
+++
b/processing/src/main/java/org/apache/druid/java/util/common/guava/ParallelMergeCombiningSequence.java
@@ -951,7 +951,7 @@ public class ParallelMergeCombiningSequence<T> extends
YieldingSequenceBase<T>
}
/**
- * {@link ForkJoinPool} friendly conversion of {@link Sequence} to {@link
Yielder< ResultBatch >}
+ * {@link ForkJoinPool} friendly conversion of {@link Sequence} to {@link
Yielder<ResultBatch>}
*/
static class SequenceBatcher<E> implements ForkJoinPool.ManagedBlocker
{
diff --git
a/processing/src/main/java/org/apache/druid/java/util/common/parsers/CloseableIteratorWithMetadata.java
b/processing/src/main/java/org/apache/druid/java/util/common/parsers/CloseableIteratorWithMetadata.java
index 0a26d2ba535..66576aff3c3 100644
---
a/processing/src/main/java/org/apache/druid/java/util/common/parsers/CloseableIteratorWithMetadata.java
+++
b/processing/src/main/java/org/apache/druid/java/util/common/parsers/CloseableIteratorWithMetadata.java
@@ -26,7 +26,7 @@ import java.util.Collections;
import java.util.Map;
/**
- * Like {@link CloseableIterator}, but has a currentMetadata() method, which
returns "metadata", which is effectively a Map<String, Object>
+ * Like {@link CloseableIterator}, but has a currentMetadata() method, which
returns "metadata", which is effectively a {@code Map<String, Object>}
* about the source of last value returned by next()
*
* The returned metadata is read-only and cannot be modified.
diff --git
a/processing/src/main/java/org/apache/druid/math/expr/ExpressionProcessing.java
b/processing/src/main/java/org/apache/druid/math/expr/ExpressionProcessing.java
index 860cb37dd12..ae64d3a8196 100644
---
a/processing/src/main/java/org/apache/druid/math/expr/ExpressionProcessing.java
+++
b/processing/src/main/java/org/apache/druid/math/expr/ExpressionProcessing.java
@@ -29,7 +29,7 @@ public class ExpressionProcessing
{
/**
* INSTANCE is injected using static injection to avoid adding JacksonInject
annotations all over the code.
- * @see {@link ExpressionProcessingModule} for details.
+ * @see ExpressionProcessingModule for details.
*
* It does not take effect in all unit tests since we don't use Guice
Injection. Use {@link #initializeForTests}
* when modules are not available.
diff --git
a/processing/src/main/java/org/apache/druid/query/aggregation/BufferAggregator.java
b/processing/src/main/java/org/apache/druid/query/aggregation/BufferAggregator.java
index 20d13491b0f..f82a609bce1 100644
---
a/processing/src/main/java/org/apache/druid/query/aggregation/BufferAggregator.java
+++
b/processing/src/main/java/org/apache/druid/query/aggregation/BufferAggregator.java
@@ -38,7 +38,7 @@ import java.nio.ByteBuffer;
* Unlike {@link Aggregator}, BufferAggregators are never used by multiple
threads at once. Implementations are not
* required to be thread safe.
*
- * @see VectorAggregator, the vectorized version
+ * @see VectorAggregator the vectorized version
*/
@ExtensionPoint
public interface BufferAggregator extends HotLoopCallee
diff --git
a/processing/src/main/java/org/apache/druid/query/aggregation/VectorAggregator.java
b/processing/src/main/java/org/apache/druid/query/aggregation/VectorAggregator.java
index a3e506e59c8..18603e15bcd 100644
---
a/processing/src/main/java/org/apache/druid/query/aggregation/VectorAggregator.java
+++
b/processing/src/main/java/org/apache/druid/query/aggregation/VectorAggregator.java
@@ -34,7 +34,7 @@ import java.nio.ByteBuffer;
* Unlike {@link Aggregator}, VectorAggregators are never used by multiple
threads at once. Implementations are not
* required to be thread safe.
*
- * @see BufferAggregator, the vectorized version.
+ * @see BufferAggregator the vectorized version.
*/
public interface VectorAggregator
{
diff --git
a/processing/src/main/java/org/apache/druid/query/context/ResponseContext.java
b/processing/src/main/java/org/apache/druid/query/context/ResponseContext.java
index 4a7868445be..f2b2ed2ff0c 100644
---
a/processing/src/main/java/org/apache/druid/query/context/ResponseContext.java
+++
b/processing/src/main/java/org/apache/druid/query/context/ResponseContext.java
@@ -299,7 +299,7 @@ public abstract class ResponseContext
* EXTENSION_KEY_2
* });
* }
- * }</pre>
+ * }}</pre>
* Make sure all extension keys are added with the {@link #registerKey(Key)}
or
* {@link #registerKeys(Key[])} methods.
* <p>
diff --git
a/processing/src/main/java/org/apache/druid/query/dimension/DimensionSpec.java
b/processing/src/main/java/org/apache/druid/query/dimension/DimensionSpec.java
index 541e6d8da28..637d8ea6372 100644
---
a/processing/src/main/java/org/apache/druid/query/dimension/DimensionSpec.java
+++
b/processing/src/main/java/org/apache/druid/query/dimension/DimensionSpec.java
@@ -79,7 +79,7 @@ public interface DimensionSpec extends Cacheable
}
/**
- * Vectorized analog of {@link #decorate(DimensionSelector) for {@link
MultiValueDimensionVectorSelector}, most likely
+ * Vectorized analog of {@link #decorate(DimensionSelector)} for {@link
MultiValueDimensionVectorSelector}, most likely
* produced with
* {@link
org.apache.druid.segment.vector.VectorColumnSelectorFactory#makeMultiValueDimensionSelector(DimensionSpec)}
*
diff --git
a/processing/src/main/java/org/apache/druid/query/filter/ValueMatcher.java
b/processing/src/main/java/org/apache/druid/query/filter/ValueMatcher.java
index 2b2aa628ae8..5628ef66527 100644
--- a/processing/src/main/java/org/apache/druid/query/filter/ValueMatcher.java
+++ b/processing/src/main/java/org/apache/druid/query/filter/ValueMatcher.java
@@ -27,7 +27,7 @@ import
org.apache.druid.query.monomorphicprocessing.HotLoopCallee;
* of this interface is that it is returned by the {@link Filter}
"makeMatcher" method, where it is used to identify
* selected rows for filtered cursors and filtered aggregators.
*
- * @see org.apache.druid.query.filter.vector.VectorValueMatcher, the
vectorized version
+ * @see org.apache.druid.query.filter.vector.VectorValueMatcher the vectorized
version
*/
public interface ValueMatcher extends HotLoopCallee
{
diff --git
a/processing/src/main/java/org/apache/druid/query/filter/vector/ReadableVectorMatch.java
b/processing/src/main/java/org/apache/druid/query/filter/vector/ReadableVectorMatch.java
index 88cbbf3aaa0..9a9e80290f7 100644
---
a/processing/src/main/java/org/apache/druid/query/filter/vector/ReadableVectorMatch.java
+++
b/processing/src/main/java/org/apache/druid/query/filter/vector/ReadableVectorMatch.java
@@ -24,7 +24,7 @@ import javax.annotation.Nullable;
/**
* The result of calling {@link VectorValueMatcher#match}.
*
- * @see VectorMatch, the implementation, which also adds some extra mutation
methods.
+ * @see VectorMatch the implementation, which also adds some extra mutation
methods.
*/
public interface ReadableVectorMatch
{
diff --git
a/processing/src/main/java/org/apache/druid/query/filter/vector/VectorValueMatcher.java
b/processing/src/main/java/org/apache/druid/query/filter/vector/VectorValueMatcher.java
index 9a2812f5913..c00dd83674f 100644
---
a/processing/src/main/java/org/apache/druid/query/filter/vector/VectorValueMatcher.java
+++
b/processing/src/main/java/org/apache/druid/query/filter/vector/VectorValueMatcher.java
@@ -36,7 +36,7 @@ import javax.annotation.Nullable;
* of this interface is that it is returned by the {@link Filter}
"makeVectorMatcher" method, where it is used to
* identify selected rows for filtered cursors and filtered aggregators.
*
- * @see org.apache.druid.query.filter.ValueMatcher, the non-vectorized version
+ * @see org.apache.druid.query.filter.ValueMatcher the non-vectorized version
*/
public interface VectorValueMatcher extends VectorSizeInspector
{
diff --git
a/processing/src/main/java/org/apache/druid/segment/ColumnSelectorFactory.java
b/processing/src/main/java/org/apache/druid/segment/ColumnSelectorFactory.java
index 82d9b0a5149..c837ed6aac0 100644
---
a/processing/src/main/java/org/apache/druid/segment/ColumnSelectorFactory.java
+++
b/processing/src/main/java/org/apache/druid/segment/ColumnSelectorFactory.java
@@ -28,7 +28,7 @@ import javax.annotation.Nullable;
/**
* Factory class for MetricSelectors
*
- * @see org.apache.druid.segment.vector.VectorColumnSelectorFactory, the
vectorized version
+ * @see org.apache.druid.segment.vector.VectorColumnSelectorFactory the
vectorized version
*/
@PublicApi
public interface ColumnSelectorFactory extends ColumnInspector
diff --git a/processing/src/main/java/org/apache/druid/segment/Cursor.java
b/processing/src/main/java/org/apache/druid/segment/Cursor.java
index eb7c72b09e9..4911f82585d 100644
--- a/processing/src/main/java/org/apache/druid/segment/Cursor.java
+++ b/processing/src/main/java/org/apache/druid/segment/Cursor.java
@@ -50,7 +50,7 @@ import
org.apache.druid.segment.incremental.IncrementalIndexCursorHolder;
* rather than query execution (as Cursor). If those abstractions could be
collapsed (and if it is worthwhile) is yet to
* be determined.
*
- * @see org.apache.druid.segment.vector.VectorCursor, the vectorized version
+ * @see org.apache.druid.segment.vector.VectorCursor the vectorized version
*/
public interface Cursor
{
diff --git
a/processing/src/main/java/org/apache/druid/segment/DimensionSelector.java
b/processing/src/main/java/org/apache/druid/segment/DimensionSelector.java
index 9989d745f36..ebd65cb06d2 100644
--- a/processing/src/main/java/org/apache/druid/segment/DimensionSelector.java
+++ b/processing/src/main/java/org/apache/druid/segment/DimensionSelector.java
@@ -42,8 +42,8 @@ import java.util.stream.Collectors;
* Selector for a string-typed column, either single- or multi-valued. This is
named a "dimension" selector for legacy
* reasons: in the past, all Druid dimensions were string-typed.
*
- * @see org.apache.druid.segment.vector.SingleValueDimensionVectorSelector, a
vectorized version
- * @see org.apache.druid.segment.vector.MultiValueDimensionVectorSelector,
another vectorized version
+ * @see org.apache.druid.segment.vector.SingleValueDimensionVectorSelector a
vectorized version
+ * @see org.apache.druid.segment.vector.MultiValueDimensionVectorSelector
another vectorized version
*/
@PublicApi
public interface DimensionSelector extends ColumnValueSelector<Object>,
DimensionDictionarySelector, HotLoopCallee
diff --git
a/processing/src/main/java/org/apache/druid/segment/data/ReadableOffset.java
b/processing/src/main/java/org/apache/druid/segment/data/ReadableOffset.java
index 1373574c7e6..ca00e2b4002 100644
--- a/processing/src/main/java/org/apache/druid/segment/data/ReadableOffset.java
+++ b/processing/src/main/java/org/apache/druid/segment/data/ReadableOffset.java
@@ -29,7 +29,7 @@ import
org.apache.druid.query.monomorphicprocessing.HotLoopCallee;
* given to classes (e.g. FloatColumnSelector objects) by something which
keeps a reference to the base Offset object
* and increments it.
*
- * @see org.apache.druid.segment.vector.ReadableVectorOffset, the vectorized
version.
+ * @see org.apache.druid.segment.vector.ReadableVectorOffset the vectorized
version.
*/
public interface ReadableOffset extends HotLoopCallee
{
diff --git
a/processing/src/main/java/org/apache/druid/segment/join/filter/JoinFilterAnalyzer.java
b/processing/src/main/java/org/apache/druid/segment/join/filter/JoinFilterAnalyzer.java
index bb380a92ad2..24d2384d445 100644
---
a/processing/src/main/java/org/apache/druid/segment/join/filter/JoinFilterAnalyzer.java
+++
b/processing/src/main/java/org/apache/druid/segment/join/filter/JoinFilterAnalyzer.java
@@ -159,7 +159,7 @@ public class JoinFilterAnalyzer
}
/**
- * @param joinFilterPreAnalysis The pre-analysis computed by {@link
#computeJoinFilterPreAnalysis)}
+ * @param joinFilterPreAnalysis The pre-analysis computed by {@link
#computeJoinFilterPreAnalysis}
* @param baseFilter - Filter on base table that was specified in the query
itself
*
* @return A JoinFilterSplit indicating what parts of the filter should be
applied pre-join and post-join
@@ -223,7 +223,7 @@ public class JoinFilterAnalyzer
* The clause is expected to be an OR filter or a leaf filter.
*
* @param filterClause Individual filter clause (an OR
filter or a leaf filter) from a filter that is in CNF
- * @param joinFilterPreAnalysis The pre-analysis computed by
{@link #computeJoinFilterPreAnalysis)}
+ * @param joinFilterPreAnalysis The pre-analysis computed by
{@link #computeJoinFilterPreAnalysis}
* @param pushDownVirtualColumnsForLhsExprs Used when there are LHS
expressions in the join equiconditions.
* If we rewrite an RHS filter such
that it applies to the LHS expression instead,
* because the expression existed
only in the equicondition, we must create a virtual column
@@ -346,7 +346,7 @@ public class JoinFilterAnalyzer
* the base table.
*
* @param orFilter OrFilter to be rewritten
- * @param joinFilterPreAnalysis The pre-analysis computed by
{@link #computeJoinFilterPreAnalysis)}
+ * @param joinFilterPreAnalysis The pre-analysis computed by
{@link #computeJoinFilterPreAnalysis}
* @param pushDownVirtualColumnsForLhsExprs See comments on {@link
#analyzeJoinFilterClause}
*
* @return A JoinFilterAnalysis indicating how to handle the potentially
rewritten filter
@@ -412,7 +412,7 @@ public class JoinFilterAnalyzer
* Rewrites a selector filter on a join table into an IN filter on the base
table.
*
* @param selectorFilter SelectorFilter to be rewritten
- * @param joinFilterPreAnalysis The pre-analysis computed by
{@link #computeJoinFilterPreAnalysis)}
+ * @param joinFilterPreAnalysis The pre-analysis computed by
{@link #computeJoinFilterPreAnalysis}
* @param pushDownVirtualColumnsForLhsExprs See comments on {@link
#analyzeJoinFilterClause}
*
* @return A JoinFilterAnalysis that indicates how to handle the potentially
rewritten filter
diff --git
a/processing/src/main/java/org/apache/druid/segment/join/table/IndexedTable.java
b/processing/src/main/java/org/apache/druid/segment/join/table/IndexedTable.java
index f675b70940b..97541e9bdc0 100644
---
a/processing/src/main/java/org/apache/druid/segment/join/table/IndexedTable.java
+++
b/processing/src/main/java/org/apache/druid/segment/join/table/IndexedTable.java
@@ -96,7 +96,7 @@ public interface IndexedTable extends
ReferenceCountedObjectProvider<Closeable>,
*
* @return the byte array for cache key
*
- * @throws {@link IAE} if caching is not supported
+ * @throws IAE if caching is not supported
*/
default byte[] computeCacheKey()
{
diff --git
a/processing/src/main/java/org/apache/druid/segment/nested/StructuredDataProcessor.java
b/processing/src/main/java/org/apache/druid/segment/nested/StructuredDataProcessor.java
index f148c37c34d..dc638d1b0ac 100644
---
a/processing/src/main/java/org/apache/druid/segment/nested/StructuredDataProcessor.java
+++
b/processing/src/main/java/org/apache/druid/segment/nested/StructuredDataProcessor.java
@@ -37,12 +37,12 @@ public abstract class StructuredDataProcessor
}
/**
- * process a value that is definitely not a {@link Map}, {@link List}, or
{@link Object[]}
+ * process a value that is definitely not a {@link Map}, {@link List}, or
{@code Object[]}
*/
public abstract ProcessedValue<?> processField(ArrayList<NestedPathPart>
fieldPath, @Nullable Object fieldValue);
/**
- * Process a {@link List} or {@link Object[]} returning a {@link
ProcessedValue} if no further processing should
+ * Process a {@link List} or {@code Object[]} returning a {@link
ProcessedValue} if no further processing should
* be performed by the {@link StructuredDataProcessor}, else a return value
of null indicates that each element
* of the array will be processed separately as a new {@link
NestedPathArrayElement} part.
*/
@@ -55,7 +55,7 @@ public abstract class StructuredDataProcessor
* {@link ProcessedValue} during processing, represented as an ordered
sequence of {@link NestedPathPart}.
*
* This method processes plain java objects, for each {@link Map} it adds a
{@link MapField} to the path, for
- * {@link List} a {@link ArrayField}, {@link Object[]} a {@link ArrayField},
and so on. {@link ArrayField} and
+ * {@link List} a {@link ArrayField}, {@code Object[]} a {@link ArrayField},
and so on. {@link ArrayField} and
* {@link ArrayField} will be processed by {@link
#processArrayField(ArrayList, List)}
*/
public ProcessResults processFields(Object raw)
diff --git
a/processing/src/main/java/org/apache/druid/segment/serde/Serializer.java
b/processing/src/main/java/org/apache/druid/segment/serde/Serializer.java
index 8833ed99057..3959a701754 100644
--- a/processing/src/main/java/org/apache/druid/segment/serde/Serializer.java
+++ b/processing/src/main/java/org/apache/druid/segment/serde/Serializer.java
@@ -37,7 +37,7 @@ public interface Serializer
/**
* Writes the serialized form of this object. The entire object may be
written to the provided channel, or the object
- * may be split over the provided channel and files added to the {@link
SegmentFileBuilder], where additional channels
+ * may be split over the provided channel and files added to the {@link
SegmentFileBuilder}, where additional channels
* can be created via {@link SegmentFileBuilder#addWithChannel(String, long)
}. The latter approach is useful when the
* serialized form of the object is too large for a single smoosh container.
At the time this javadoc was written,
* the max smoosh container size is limit to the max {@link
java.nio.ByteBuffer} size.
diff --git
a/processing/src/main/java/org/apache/druid/segment/serde/cell/CellReader.java
b/processing/src/main/java/org/apache/druid/segment/serde/cell/CellReader.java
index 678920e6d29..64c830000d6 100644
---
a/processing/src/main/java/org/apache/druid/segment/serde/cell/CellReader.java
+++
b/processing/src/main/java/org/apache/druid/segment/serde/cell/CellReader.java
@@ -56,7 +56,7 @@ import java.nio.ByteOrder;
* processPayload(payload); // may deserialize and peform work
* }
* }
- * </pre>
+ * }</pre>
*
* While you may allocate your own 64k buffers, it is recommended you use
{@code NativeClearedByteBufferProvider}
* which provides direct 64k ByteBuffers from a pool, wrapped in a
ResourceHolder. These objects may be
diff --git
a/processing/src/main/java/org/apache/druid/segment/vector/ConcatenatingVectorCursor.java
b/processing/src/main/java/org/apache/druid/segment/vector/ConcatenatingVectorCursor.java
index 12ce0e19f0a..cf71fb2be0d 100644
---
a/processing/src/main/java/org/apache/druid/segment/vector/ConcatenatingVectorCursor.java
+++
b/processing/src/main/java/org/apache/druid/segment/vector/ConcatenatingVectorCursor.java
@@ -35,8 +35,8 @@ import java.util.Map;
* table. Vector boundaries do not align with cluster-group boundaries; the
last vector of each group is naturally
* partial (its {@link #getCurrentVectorSize()} returns less than max), and
the next {@link #advance()} swaps in the
* next group's vector cursor without trying to merge across groups.
- * <p/
- * >On each group transition the wrapper {@link
ClusteringVectorColumnSelectorFactory} updates its underlying
+ * <p/>
+ * On each group transition the wrapper {@link
ClusteringVectorColumnSelectorFactory} updates its underlying
* delegate and clustering values, so previously-acquired delegating vector
selectors observe the new group's data via
* generation-counter cache invalidation.
* <p/>
diff --git
a/processing/src/main/java/org/apache/druid/segment/vector/MultiValueDimensionVectorSelector.java
b/processing/src/main/java/org/apache/druid/segment/vector/MultiValueDimensionVectorSelector.java
index baacb3be28b..3c4f41d00fe 100644
---
a/processing/src/main/java/org/apache/druid/segment/vector/MultiValueDimensionVectorSelector.java
+++
b/processing/src/main/java/org/apache/druid/segment/vector/MultiValueDimensionVectorSelector.java
@@ -25,8 +25,8 @@ import org.apache.druid.segment.data.IndexedInts;
/**
* Vectorized selector for a multi-valued string-typed column.
*
- * @see org.apache.druid.segment.DimensionSelector, the non-vectorized version.
- * @see SingleValueDimensionVectorSelector, the singly-valued version.
+ * @see org.apache.druid.segment.DimensionSelector the non-vectorized version.
+ * @see SingleValueDimensionVectorSelector the singly-valued version.
*/
public interface MultiValueDimensionVectorSelector extends
DimensionDictionarySelector, VectorSizeInspector
{
diff --git
a/processing/src/main/java/org/apache/druid/segment/vector/ReadableVectorOffset.java
b/processing/src/main/java/org/apache/druid/segment/vector/ReadableVectorOffset.java
index 9076e099eca..3b88d2da49d 100644
---
a/processing/src/main/java/org/apache/druid/segment/vector/ReadableVectorOffset.java
+++
b/processing/src/main/java/org/apache/druid/segment/vector/ReadableVectorOffset.java
@@ -25,8 +25,8 @@ package org.apache.druid.segment.vector;
* A ReadableVectorOffset should be given to classes (e.g. column selector
objects) by something which keeps a
* reference to the base VectorOffset object and increments it.
*
- * @see VectorOffset, the movable version.
- * @see org.apache.druid.segment.data.ReadableOffset, the non-vectorized
version.
+ * @see VectorOffset the movable version.
+ * @see org.apache.druid.segment.data.ReadableOffset the non-vectorized
version.
*/
public interface ReadableVectorOffset extends ReadableVectorInspector
{
diff --git
a/processing/src/main/java/org/apache/druid/segment/vector/SingleValueDimensionVectorSelector.java
b/processing/src/main/java/org/apache/druid/segment/vector/SingleValueDimensionVectorSelector.java
index f9fd484ad38..e4241b7b3bc 100644
---
a/processing/src/main/java/org/apache/druid/segment/vector/SingleValueDimensionVectorSelector.java
+++
b/processing/src/main/java/org/apache/druid/segment/vector/SingleValueDimensionVectorSelector.java
@@ -25,8 +25,8 @@ import org.apache.druid.segment.DimensionDictionarySelector;
* Vectorized selector for a singly-valued string-typed column. Unlike the
non-vectorized version, this is done as
* a separate interface, which is useful since it allows "getRowVector" to be
a primitive int array.
*
- * @see org.apache.druid.segment.DimensionSelector, the non-vectorized version.
- * @see MultiValueDimensionVectorSelector, the multi-valued version.
+ * @see org.apache.druid.segment.DimensionSelector the non-vectorized version.
+ * @see MultiValueDimensionVectorSelector the multi-valued version.
*/
public interface SingleValueDimensionVectorSelector extends
DimensionDictionarySelector, VectorSizeInspector
{
diff --git
a/processing/src/main/java/org/apache/druid/segment/vector/VectorCursor.java
b/processing/src/main/java/org/apache/druid/segment/vector/VectorCursor.java
index 4771605583b..e88c3fa95b1 100644
--- a/processing/src/main/java/org/apache/druid/segment/vector/VectorCursor.java
+++ b/processing/src/main/java/org/apache/druid/segment/vector/VectorCursor.java
@@ -43,7 +43,7 @@ import org.apache.druid.segment.CursorFactory;
* }
* </pre>
*
- * @see org.apache.druid.segment.Cursor, the non-vectorized version.
+ * @see org.apache.druid.segment.Cursor the non-vectorized version.
*/
public interface VectorCursor extends VectorSizeInspector
{
diff --git
a/processing/src/main/java/org/apache/druid/segment/vector/VectorOffset.java
b/processing/src/main/java/org/apache/druid/segment/vector/VectorOffset.java
index e2aefc8d97b..6b3605cde9b 100644
--- a/processing/src/main/java/org/apache/druid/segment/vector/VectorOffset.java
+++ b/processing/src/main/java/org/apache/druid/segment/vector/VectorOffset.java
@@ -22,7 +22,7 @@ package org.apache.druid.segment.vector;
/**
* The movable version of ReadableVectorOffset.
*
- * @see org.apache.druid.segment.data.Offset, the non-vectorized version.
+ * @see org.apache.druid.segment.data.Offset the non-vectorized version.
*/
public interface VectorOffset extends ReadableVectorOffset
{
diff --git
a/processing/src/main/java/org/apache/druid/segment/vector/VectorValueSelector.java
b/processing/src/main/java/org/apache/druid/segment/vector/VectorValueSelector.java
index 216967cc930..48c5d2b0041 100644
---
a/processing/src/main/java/org/apache/druid/segment/vector/VectorValueSelector.java
+++
b/processing/src/main/java/org/apache/druid/segment/vector/VectorValueSelector.java
@@ -24,7 +24,7 @@ import javax.annotation.Nullable;
/**
* Vectorized selector for primitive columns.
*
- * @see org.apache.druid.segment.ColumnValueSelector, the non-vectorized
version.
+ * @see org.apache.druid.segment.ColumnValueSelector the non-vectorized
version.
*/
public interface VectorValueSelector extends VectorSizeInspector
{
diff --git
a/processing/src/main/java/org/apache/druid/segment/virtual/ExpressionSelectors.java
b/processing/src/main/java/org/apache/druid/segment/virtual/ExpressionSelectors.java
index 66e49c2b707..7f95d3446c6 100644
---
a/processing/src/main/java/org/apache/druid/segment/virtual/ExpressionSelectors.java
+++
b/processing/src/main/java/org/apache/druid/segment/virtual/ExpressionSelectors.java
@@ -491,7 +491,7 @@ public class ExpressionSelectors
/**
* Wraps a {@link ColumnValueSelector<ExprEval>} and calls {@link
ExprEval#value()} on the output of
- * {@link #baseSelector#getObject()} in {@link #getObject()}.
+ * {@code baseSelector.getObject()} in {@link #getObject()}.
*/
private static class EvalUnwrappingColumnValueSelector implements
ColumnValueSelector
{
diff --git
a/processing/src/main/java/org/apache/druid/segment/virtual/RowBasedExpressionColumnValueSelector.java
b/processing/src/main/java/org/apache/druid/segment/virtual/RowBasedExpressionColumnValueSelector.java
index 0ca0394f966..b71fad31bf1 100644
---
a/processing/src/main/java/org/apache/druid/segment/virtual/RowBasedExpressionColumnValueSelector.java
+++
b/processing/src/main/java/org/apache/druid/segment/virtual/RowBasedExpressionColumnValueSelector.java
@@ -35,7 +35,7 @@ import java.util.stream.Collectors;
* Expression column value selector that examines a set of 'unknown' type
input bindings on a row by row basis,
* transforming the expression to handle multi-value list typed inputs as they
are encountered.
*
- * Currently, string dimensions are the only bindings which might appear as a
{@link String} or a {@link Object[]}, so
+ * Currently, string dimensions are the only bindings which might appear as a
{@link String} or a {@code Object[]}, so
* numbers are eliminated from the set of 'unknown' bindings to check as they
are encountered.
*/
public class RowBasedExpressionColumnValueSelector extends
BaseExpressionColumnValueSelector
diff --git
a/processing/src/main/java/org/apache/druid/timeline/SegmentStatusInCluster.java
b/processing/src/main/java/org/apache/druid/timeline/SegmentStatusInCluster.java
index b550a9c8d42..9bcfec893b8 100644
---
a/processing/src/main/java/org/apache/druid/timeline/SegmentStatusInCluster.java
+++
b/processing/src/main/java/org/apache/druid/timeline/SegmentStatusInCluster.java
@@ -35,7 +35,7 @@ import java.util.Objects;
* <li>number of rows in the segment</li>
* <li>if the segment is realtime</li>
* </ul>
- * <br></br>
+ * <br>
* Objects of this class are used to sync the state of segments from the
Coordinator to different services, typically the Broker.
* The {@link #compareTo} method considers only the {@link SegmentId}.
*/
diff --git
a/server/src/main/java/org/apache/druid/catalog/model/ResolvedTable.java
b/server/src/main/java/org/apache/druid/catalog/model/ResolvedTable.java
index 764fa752f32..a0e3297f301 100644
--- a/server/src/main/java/org/apache/druid/catalog/model/ResolvedTable.java
+++ b/server/src/main/java/org/apache/druid/catalog/model/ResolvedTable.java
@@ -29,7 +29,7 @@ import java.util.Map;
* This class provides the semantic view of the table specification,
* without the operational aspects such as version, name, etc.
*
- * @see {@link TableMetadata} for the operational representation
+ * @see TableMetadata for the operational representation
*/
public class ResolvedTable extends ObjectFacade
{
diff --git
a/server/src/main/java/org/apache/druid/catalog/model/TableMetadata.java
b/server/src/main/java/org/apache/druid/catalog/model/TableMetadata.java
index 1a09171f81d..97301f010bd 100644
--- a/server/src/main/java/org/apache/druid/catalog/model/TableMetadata.java
+++ b/server/src/main/java/org/apache/druid/catalog/model/TableMetadata.java
@@ -40,7 +40,7 @@ import java.util.Objects;
* the object. (Providing partial information avoids the need to query
* the DB for information that won't actually be used.)
*
- * @see {@link ResolvedTable} for the semantic representation.
+ * @see ResolvedTable for the semantic representation.
*/
@PublicApi
public class TableMetadata
diff --git
a/server/src/main/java/org/apache/druid/catalog/model/table/BaseInputSourceDefn.java
b/server/src/main/java/org/apache/druid/catalog/model/table/BaseInputSourceDefn.java
index b5e47e99b11..12a80745335 100644
---
a/server/src/main/java/org/apache/druid/catalog/model/table/BaseInputSourceDefn.java
+++
b/server/src/main/java/org/apache/druid/catalog/model/table/BaseInputSourceDefn.java
@@ -37,7 +37,7 @@ import java.util.Map;
/**
* Base class for input source definitions.
*
- * @see {@link FormattedInputSourceDefn} for the base class for (most) input
formats
+ * @see FormattedInputSourceDefn for the base class for (most) input formats
* which take an input format.
*/
public abstract class BaseInputSourceDefn implements InputSourceDefn
diff --git
a/server/src/main/java/org/apache/druid/catalog/model/table/BaseTableFunction.java
b/server/src/main/java/org/apache/druid/catalog/model/table/BaseTableFunction.java
index 0f4c7315c79..05279af64f4 100644
---
a/server/src/main/java/org/apache/druid/catalog/model/table/BaseTableFunction.java
+++
b/server/src/main/java/org/apache/druid/catalog/model/table/BaseTableFunction.java
@@ -27,7 +27,7 @@ import java.util.List;
/**
* Base implementation for a table function definition.
*
- * @see {@link TableFunction}
+ * @see TableFunction
*/
public abstract class BaseTableFunction implements TableFunction
{
diff --git
a/server/src/main/java/org/apache/druid/catalog/model/table/HttpInputSourceDefn.java
b/server/src/main/java/org/apache/druid/catalog/model/table/HttpInputSourceDefn.java
index e6272e2de4b..7f200695f20 100644
---
a/server/src/main/java/org/apache/druid/catalog/model/table/HttpInputSourceDefn.java
+++
b/server/src/main/java/org/apache/druid/catalog/model/table/HttpInputSourceDefn.java
@@ -53,6 +53,7 @@ import java.util.stream.Collectors;
* {@code uriTemplate} table property in the table spec, then provides the
partial URLs
* in a table function to use for that one query. The final URIs are created
by combining
* the template and the arguments. Example:
+ * <ul>
* <li>{@code uriTemplate} property):
"http://example.com/data/kttm-{}.json";</li>
* <li>{@code uris} function argument: "22-Nov-21, 22-Nov-22"</li>
* </ul>
diff --git
a/server/src/main/java/org/apache/druid/catalog/model/table/InputSourceDefn.java
b/server/src/main/java/org/apache/druid/catalog/model/table/InputSourceDefn.java
index a5071d46c23..063d70d923e 100644
---
a/server/src/main/java/org/apache/druid/catalog/model/table/InputSourceDefn.java
+++
b/server/src/main/java/org/apache/druid/catalog/model/table/InputSourceDefn.java
@@ -52,7 +52,7 @@ import org.apache.druid.catalog.model.TableDefnRegistry;
* sources were not designed for this use case, we can't do a simple mapping:
some creativity
* is required in each case.
*
- * @see {@link ExternalTableDefn} for a detailed explanation.
+ * @see ExternalTableDefn for a detailed explanation.
*/
public interface InputSourceDefn
{
diff --git
a/server/src/main/java/org/apache/druid/catalog/model/table/ResolvedExternalTable.java
b/server/src/main/java/org/apache/druid/catalog/model/table/ResolvedExternalTable.java
index c9c9702c612..e3d98193b96 100644
---
a/server/src/main/java/org/apache/druid/catalog/model/table/ResolvedExternalTable.java
+++
b/server/src/main/java/org/apache/druid/catalog/model/table/ResolvedExternalTable.java
@@ -52,7 +52,7 @@ public class ResolvedExternalTable
* Note: does <i>not</i> resolve the input source and input format
* definitions: that is done as a separate step when needed.
*
- * @see {@link #resolve(TableDefnRegistry)}.
+ * @see #resolve(TableDefnRegistry).
*/
public ResolvedExternalTable(final ResolvedTable table)
{
diff --git
a/server/src/main/java/org/apache/druid/catalog/model/table/TableFunction.java
b/server/src/main/java/org/apache/druid/catalog/model/table/TableFunction.java
index 9498a746440..364f78a5f2a 100644
---
a/server/src/main/java/org/apache/druid/catalog/model/table/TableFunction.java
+++
b/server/src/main/java/org/apache/druid/catalog/model/table/TableFunction.java
@@ -36,7 +36,7 @@ import java.util.Map;
* The parameters tell Calcite the allowed parameters. Functions created from
* this class are most useful when used with named arguments:<code><pre>
* SELECT ... FROM TABLE(thisFn(foo -> "bar", answer -> 42))
- * </pre</code>
+ * </pre></code>
* <p>
* Calcite provides actual arguments as an array, with null values for
arguments
* which the user did not provide. That form is not helpful for this use case.
diff --git
a/server/src/main/java/org/apache/druid/client/BaseBrokerViewOfConfig.java
b/server/src/main/java/org/apache/druid/client/BaseBrokerViewOfConfig.java
index 3a5b5b76f30..c24e9f2217e 100644
--- a/server/src/main/java/org/apache/druid/client/BaseBrokerViewOfConfig.java
+++ b/server/src/main/java/org/apache/druid/client/BaseBrokerViewOfConfig.java
@@ -26,8 +26,10 @@ import org.apache.druid.java.util.common.logger.Logger;
/**
* Base class for broker's view of dynamic configuration fetched from the
Coordinator.
* Subclasses must implement:
- * {@link #fetchConfigFromClient()} to fetch configuration from their specific
client</li>
- * {@link #getConfigTypeName()} for logging purposes</li>
+ * <ul>
+ * <li>{@link #fetchConfigFromClient()} to fetch configuration from their
specific client</li>
+ * <li>{@link #getConfigTypeName()} for logging purposes</li>
+ * </ul>
*
* @param <DynamicConfig> the type of dynamic configuration (e.g.,
CoordinatorDynamicConfig, BrokerDynamicConfig)
*/
diff --git
a/server/src/main/java/org/apache/druid/client/ImmutableDruidDataSource.java
b/server/src/main/java/org/apache/druid/client/ImmutableDruidDataSource.java
index e855ca8f1fc..5ae02e2f477 100644
--- a/server/src/main/java/org/apache/druid/client/ImmutableDruidDataSource.java
+++ b/server/src/main/java/org/apache/druid/client/ImmutableDruidDataSource.java
@@ -157,7 +157,7 @@ public class ImmutableDruidDataSource
* ImmutableDruidDataSource should be considered a container, not a data
class. The idea is the same as behind
* prohibiting/limiting equals() (and therefore usage as HashSet/HashMap
keys) of DataSegment: see
* https://github.com/apache/druid/issues/6358. When somebody wants to
deduplicate ImmutableDruidDataSource
- * objects, they would need to put them into a Map<String,
ImmutableDruidDataSource> and resolve conflicts by name
+ * objects, they would need to put them into a {@code Map<String,
ImmutableDruidDataSource>} and resolve conflicts by name
* manually.
*
* See https://github.com/apache/druid/issues/7858
@@ -172,7 +172,7 @@ public class ImmutableDruidDataSource
* ImmutableDruidDataSource should be considered a container, not a data
class. The idea is the same as behind
* prohibiting/limiting hashCode() (and therefore usage as HashSet/HashMap
keys) of DataSegment: see
* https://github.com/apache/druid/issues/6358. When somebody wants to
deduplicate ImmutableDruidDataSource
- * objects, they would need to put them into a Map<String,
ImmutableDruidDataSource> and resolve conflicts by name
+ * objects, they would need to put them into a {@code Map<String,
ImmutableDruidDataSource>} and resolve conflicts by name
* manually.
*
* See https://github.com/apache/druid/issues/7858
diff --git
a/server/src/main/java/org/apache/druid/segment/realtime/appenderator/AppenderatorDriverAddResult.java
b/server/src/main/java/org/apache/druid/segment/realtime/appenderator/AppenderatorDriverAddResult.java
index 92641e3178b..510bceb6275 100644
---
a/server/src/main/java/org/apache/druid/segment/realtime/appenderator/AppenderatorDriverAddResult.java
+++
b/server/src/main/java/org/apache/druid/segment/realtime/appenderator/AppenderatorDriverAddResult.java
@@ -22,7 +22,7 @@ package org.apache.druid.segment.realtime.appenderator;
import javax.annotation.Nullable;
/**
- * Result of {@link BaseAppenderatorDriver#append)}. It contains the
identifier of the
+ * Result of {@link BaseAppenderatorDriver#append}. It contains the
identifier of the
* segment which the InputRow is added to, the number of rows in that segment
and if persist is required because either
* maxRowsInMemory or intermediate persist period threshold is hit.
*/
diff --git
a/server/src/main/java/org/apache/druid/server/compaction/ReindexingDataSchemaRule.java
b/server/src/main/java/org/apache/druid/server/compaction/ReindexingDataSchemaRule.java
index 534f8f0b802..6e558993d23 100644
---
a/server/src/main/java/org/apache/druid/server/compaction/ReindexingDataSchemaRule.java
+++
b/server/src/main/java/org/apache/druid/server/compaction/ReindexingDataSchemaRule.java
@@ -48,7 +48,7 @@ import java.util.Objects;
* "olderThan": "P30D",
* "queryGranularity": "HOUR",
* "rollup": true
- * }</pre>
+ * }}</pre>
*/
public class ReindexingDataSchemaRule extends AbstractReindexingRule
{
diff --git
a/server/src/main/java/org/apache/druid/server/coordinator/duty/MarkEternityTombstonesAsUnused.java
b/server/src/main/java/org/apache/druid/server/coordinator/duty/MarkEternityTombstonesAsUnused.java
index 64c70c3a826..5b544546aee 100644
---
a/server/src/main/java/org/apache/druid/server/coordinator/duty/MarkEternityTombstonesAsUnused.java
+++
b/server/src/main/java/org/apache/druid/server/coordinator/duty/MarkEternityTombstonesAsUnused.java
@@ -122,7 +122,6 @@ public class MarkEternityTombstonesAsUnused implements
CoordinatorDuty
* <li> If there is no overlap, add the candidate segment to the eternity
segments result set. </li>
* There can at most be two such candidate tombstones per datasource -- one
that starts at {@link DateTimes#MIN}
* and another that ends at {@link DateTimes#MAX}. </li>
- * </p>
*
* @param dataSourcesSnapshot the datasources snapshot for segments timeline
* @return Map from datasource to set of non-overshadowed eternity tombstones
diff --git
a/server/src/main/java/org/apache/druid/server/emitter/ExtraServiceDimensions.java
b/server/src/main/java/org/apache/druid/server/emitter/ExtraServiceDimensions.java
index 3deeef56459..865f824d84a 100644
---
a/server/src/main/java/org/apache/druid/server/emitter/ExtraServiceDimensions.java
+++
b/server/src/main/java/org/apache/druid/server/emitter/ExtraServiceDimensions.java
@@ -32,9 +32,11 @@ import java.lang.annotation.Target;
*
* For example, write this in a body of {@link
com.google.inject.Module#configure} of your extension module):
*
+ * <pre>{@code
* MapBinder<String, String> extraDims =
* MapBinder.newMapBinder(binder, String.class, String.class,
ExtraServiceDimensions.class);
* extraDims.addBinding("foo").toInstance("bar");
+ * }</pre>
*/
@Target(ElementType.PARAMETER)
@Retention(RetentionPolicy.RUNTIME)
diff --git
a/server/src/main/java/org/apache/druid/server/http/SegmentListerResource.java
b/server/src/main/java/org/apache/druid/server/http/SegmentListerResource.java
index 9a402fddf3e..20c18942ad4 100644
---
a/server/src/main/java/org/apache/druid/server/http/SegmentListerResource.java
+++
b/server/src/main/java/org/apache/druid/server/http/SegmentListerResource.java
@@ -95,10 +95,10 @@ public class SegmentListerResource
* Here is how, this is used.
*
* (1) Client sends first request
/druid/internal/v1/segments?counter=-1&timeout=<timeout>
- * Server responds with list of segments currently served and a
<counter,hash> pair.
+ * Server responds with list of segments currently served and a {@code
<counter,hash>} pair.
*
* (2) Client sends subsequent requests
/druid/internal/v1/segments?counter=<counter>&hash=<hash>&timeout=<timeout>
- * Where <counter,hash> values are used from the last response. Server
responds with list of segment updates
+ * Where {@code <counter,hash>} values are used from the last response.
Server responds with list of segment updates
* since given counter.
*
* This endpoint makes the client wait till either there is some segment
update or given timeout elapses.
diff --git
a/server/src/main/java/org/apache/druid/server/listener/resource/AbstractListenerHandler.java
b/server/src/main/java/org/apache/druid/server/listener/resource/AbstractListenerHandler.java
index 1f89fb3f356..0bca2de6d32 100644
---
a/server/src/main/java/org/apache/druid/server/listener/resource/AbstractListenerHandler.java
+++
b/server/src/main/java/org/apache/druid/server/listener/resource/AbstractListenerHandler.java
@@ -41,7 +41,7 @@ import java.util.Map;
*
* Empty maps `{}` are taken care of at this level and never passed down to
the subclass's handle method.
*
- * @param <ObjType> A List of this type is expected in the input stream as
JSON. Must be able to be converted to/from Map<String, Object>
+ * @param <ObjType> A List of this type is expected in the input stream as
JSON. Must be able to be converted to/from {@code Map<String, Object>}
*/
public abstract class AbstractListenerHandler<ObjType> implements
ListenerHandler
{
diff --git
a/server/src/main/java/org/apache/druid/server/lookup/cache/LookupExtractorFactoryMapContainer.java
b/server/src/main/java/org/apache/druid/server/lookup/cache/LookupExtractorFactoryMapContainer.java
index cabbb0b3d1a..9e3cfd13de9 100644
---
a/server/src/main/java/org/apache/druid/server/lookup/cache/LookupExtractorFactoryMapContainer.java
+++
b/server/src/main/java/org/apache/druid/server/lookup/cache/LookupExtractorFactoryMapContainer.java
@@ -29,7 +29,7 @@ import java.util.Objects;
/**
* This is same as {@link
org.apache.druid.query.lookup.LookupExtractorFactoryContainer } except it uses
- * Map<String, Object> instead of LookupExtractorFactory for referencing
lookup spec so that lookup extensions are not
+ * {@code Map<String, Object>} instead of LookupExtractorFactory for
referencing lookup spec so that lookup extensions are not
* required to be loaded at the Coordinator.
*/
public class LookupExtractorFactoryMapContainer
diff --git
a/server/src/main/java/org/apache/druid/server/security/Authenticator.java
b/server/src/main/java/org/apache/druid/server/security/Authenticator.java
index ef73cb186ed..04e837b5216 100644
--- a/server/src/main/java/org/apache/druid/server/security/Authenticator.java
+++ b/server/src/main/java/org/apache/druid/server/security/Authenticator.java
@@ -52,7 +52,7 @@ public interface Authenticator extends ServletFilterHolder
* If the authentication succeeds, the Filter should set the
"Druid-Authentication-Result" attribute in the request,
* containing an AuthenticationResult that represents the authenticated
identity of the requester, along with
* the name of the Authorizer instance that should authorize the request. An
Authenticator may choose to
- * add a Map<String, Object> context to the authentication result,
containing additional information to be
+ * add a {@code Map<String, Object>} context to the authentication result,
containing additional information to be
* used by the Authorizer. The contents of this map are left for
Authenticator/Authorizer implementors to decide.
* <p>
* If the "Druid-Authentication-Result" attribute is already set (i.e.,
request has been authenticated by an
diff --git
a/server/src/test/java/org/apache/druid/client/cache/BackgroundCachePopulatorTest.java
b/server/src/test/java/org/apache/druid/client/cache/BackgroundCachePopulatorTest.java
index 64485fc646e..a3f8ae69a59 100644
---
a/server/src/test/java/org/apache/druid/client/cache/BackgroundCachePopulatorTest.java
+++
b/server/src/test/java/org/apache/druid/client/cache/BackgroundCachePopulatorTest.java
@@ -180,7 +180,7 @@ public class BackgroundCachePopulatorTest
/**
*
- * Method: wrap(final Sequence<T> sequence, final Function<T, CacheType>
cacheFn, final Cache cache, final Cache.NamedKey cacheKey)
+ * Method: {@code wrap(final Sequence<T> sequence, final Function<T,
CacheType> cacheFn, final Cache cache, final Cache.NamedKey cacheKey)}
*
*/
@Test
diff --git a/services/src/main/java/org/apache/druid/cli/PeonTaskHolder.java
b/services/src/main/java/org/apache/druid/cli/PeonTaskHolder.java
index 74ce547ed90..1e3aceb8c7e 100644
--- a/services/src/main/java/org/apache/druid/cli/PeonTaskHolder.java
+++ b/services/src/main/java/org/apache/druid/cli/PeonTaskHolder.java
@@ -79,7 +79,7 @@ public class PeonTaskHolder implements TaskHolder
* @return a map of all task-specific dimensions applicable to this peon.
* The task ID ({@link TaskHolder#getTaskId()}) is added to both {@link
DruidMetrics#TASK_ID}
* {@link DruidMetrics#ID} dimensions to the map for backward compatibility.
{@link DruidMetrics#ID} is
- * deprecated because it's ambiguous and can be removed in a future
release.</p>
+ * deprecated because it's ambiguous and can be removed in a future release.
*/
@Override
public Map<String, String> getMetricDimensions()
diff --git
a/services/src/main/java/org/apache/druid/guice/AbstractDruidServiceModule.java
b/services/src/main/java/org/apache/druid/guice/AbstractDruidServiceModule.java
index 0638d090901..d6530c479e1 100644
---
a/services/src/main/java/org/apache/druid/guice/AbstractDruidServiceModule.java
+++
b/services/src/main/java/org/apache/druid/guice/AbstractDruidServiceModule.java
@@ -41,8 +41,8 @@ import java.util.Set;
* <pre>
* public class MyModule extends AbstractDruidServiceModule
* {
- * @ProvidesIntoSet
- * @Named("jsonNameOfNodeRole")
+ * @ProvidesIntoSet
+ * @Named("jsonNameOfNodeRole")
* public Class<? extends DruidService> getDataNodeService()
* {
* return DataNodeService.class;
diff --git
a/sql/src/main/java/org/apache/druid/sql/calcite/external/ExtendOperator.java
b/sql/src/main/java/org/apache/druid/sql/calcite/external/ExtendOperator.java
index 14d5ca63e93..bbece8403cf 100644
---
a/sql/src/main/java/org/apache/druid/sql/calcite/external/ExtendOperator.java
+++
b/sql/src/main/java/org/apache/druid/sql/calcite/external/ExtendOperator.java
@@ -36,7 +36,7 @@ import org.apache.druid.java.util.common.ISE;
* is said to have been added for Apache Phoenix, and which we repurpose to
* supply a schema for an ingest input table.
*
- * @see {@link SchemaAwareUserDefinedTableMacro} for details
+ * @see SchemaAwareUserDefinedTableMacro for details
*/
public class ExtendOperator extends SqlInternalOperator
{
diff --git
a/sql/src/main/java/org/apache/druid/sql/calcite/planner/QueryHandler.java
b/sql/src/main/java/org/apache/druid/sql/calcite/planner/QueryHandler.java
index 77a5d01dcae..270b793d34d 100644
--- a/sql/src/main/java/org/apache/druid/sql/calcite/planner/QueryHandler.java
+++ b/sql/src/main/java/org/apache/druid/sql/calcite/planner/QueryHandler.java
@@ -480,7 +480,7 @@ public abstract class QueryHandler extends
SqlStatementHandler.BaseStatementHand
* DruidRel (A)
* DruidRel (B)
* DruidRel(C)
- * </code</pre>will return {@code [DruidRel(A), DruidRel(B), DruidRel(C)]}.
+ * </code></pre>will return {@code [DruidRel(A), DruidRel(B), DruidRel(C)]}.
*
* @param outermostDruidRel The outermost rel which is to be flattened
* @return a list of DruidRel's which do not have a DruidUnionRel nested in
between them
diff --git
a/sql/src/main/java/org/apache/druid/sql/calcite/table/RowSignatures.java
b/sql/src/main/java/org/apache/druid/sql/calcite/table/RowSignatures.java
index 444f4d2b9c3..285f3472e43 100644
--- a/sql/src/main/java/org/apache/druid/sql/calcite/table/RowSignatures.java
+++ b/sql/src/main/java/org/apache/druid/sql/calcite/table/RowSignatures.java
@@ -199,7 +199,7 @@ public class RowSignatures
* {@link ComplexSqlType} is interned. This is important because Calcite
checks that the references are equal
* instead of the objects being equivalent.
* <p>
- * This method uses {@link
RelDataTypeFactory#createTypeWithNullability(RelDataType, boolean) ensures that
if the
+ * This method uses {@link
RelDataTypeFactory#createTypeWithNullability(RelDataType, boolean)} ensures
that if the
* type factory is a {@link
org.apache.calcite.rel.type.RelDataTypeFactoryImpl} that the type is passed
through
* {@link
org.apache.calcite.rel.type.RelDataTypeFactoryImpl#canonize(RelDataType)} which
interns the type.
*/
@@ -215,7 +215,7 @@ public class RowSignatures
* Calcite {@link RelDataType} for Druid complex columns, to preserve
complex type information.
* <p>
* If using with other operations of a {@link RelDataTypeFactory}, consider
wrapping the creation of this type in
- * {@link RelDataTypeFactory#createTypeWithNullability(RelDataType, boolean)
to ensure that if the type factory is a
+ * {@link RelDataTypeFactory#createTypeWithNullability(RelDataType,
boolean)} to ensure that if the type factory is a
* {@link org.apache.calcite.rel.type.RelDataTypeFactoryImpl} that the type
is passed through
* {@link
org.apache.calcite.rel.type.RelDataTypeFactoryImpl#canonize(RelDataType)} which
interns the type.
* <p>
diff --git
a/sql/src/test/java/org/apache/druid/sql/calcite/MultiComponentSupplier.java
b/sql/src/test/java/org/apache/druid/sql/calcite/MultiComponentSupplier.java
index 27028e87809..a83882d5465 100644
--- a/sql/src/test/java/org/apache/druid/sql/calcite/MultiComponentSupplier.java
+++ b/sql/src/test/java/org/apache/druid/sql/calcite/MultiComponentSupplier.java
@@ -52,7 +52,7 @@ import java.util.Set;
* Usage:
*
* <pre>
- * @ComponentSuppliers( { RealSupplier1.class, RealSupplier2.class } )
+ * @ComponentSuppliers( { RealSupplier1.class, RealSupplier2.class } )
* public class SomeSupplier extends MultiComponentSupplier {
* }
* </pre>
diff --git
a/sql/src/test/java/org/apache/druid/sql/calcite/NotYetSupported.java
b/sql/src/test/java/org/apache/druid/sql/calcite/NotYetSupported.java
index 142573e5aa5..96c18be8c2f 100644
--- a/sql/src/test/java/org/apache/druid/sql/calcite/NotYetSupported.java
+++ b/sql/src/test/java/org/apache/druid/sql/calcite/NotYetSupported.java
@@ -61,7 +61,7 @@ import static org.junit.jupiter.api.Assertions.assertThrows;
* testclass. Ensure that it's loaded as the most outer-rule by using the right
* ExtendWith order - or by specifying Order: <code>
* @Order(0)
- * @RegisterExtension
+ * @RegisterExtension
* public TestRule notYetSupportedRule = new
NotYetSupportedProcessor(Scope.DECOUPLED);
*
* @NotYetSupported(NOT_ENOUGH_RULES)
diff --git
a/sql/src/test/java/org/apache/druid/sql/calcite/SqlTestFrameworkConfig.java
b/sql/src/test/java/org/apache/druid/sql/calcite/SqlTestFrameworkConfig.java
index 3fdb4b31323..cb7f161e727 100644
--- a/sql/src/test/java/org/apache/druid/sql/calcite/SqlTestFrameworkConfig.java
+++ b/sql/src/test/java/org/apache/druid/sql/calcite/SqlTestFrameworkConfig.java
@@ -302,7 +302,7 @@ public class SqlTestFrameworkConfig
}
/**
- * @see {@link SqlTestFrameworkConfig}
+ * @see SqlTestFrameworkConfig
*/
public static class Rule implements AfterAllCallback, BeforeEachCallback
{
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
