Repository Analysis

apache/pinot

Apache Pinot - A realtime distributed OLAP datastore

4.7 Likely human-written View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of apache/pinot, a Java project with 6,128 GitHub stars. SynthScan v2.0 examined 1,422,664 lines of code across 6952 source files, recording 2805 pattern matches distributed across 19 syntactic categories. The overall adjusted score of 4.7 places this repository in the Likely human-written band.

The scanner applied 160+ deterministic lexical heuristics, multi-line block detectors, abstract syntax tree depth profilers, and a cross-file Jaccard similarity matrix to construct a statistically normalised synthetic code estimate. All matches are individually weighted by severity coefficient and contextual multiplier before summation, and the resulting headline score is temporally discounted to account for the repository's development history relative to the commercial emergence of large language model coding tooling (November 2022 onward).

4.7
Adjusted Score
4.7
Raw Score
100%
Time Factor
2026-08-29
Last Push
6.1K
Stars
Java
Language
1.4M
Lines of Code
7.0K
Files
2.8K
Pattern Hits
2026-08-29
Scan Date
0.05
HC Hit Rate

What These Metrics Mean

Adjusted Score
Primary synthetic code indicator. Raw score normalised per 1,000 lines of code and multiplied by the temporal discount factor. This is the definitive comparative metric — use it to rank repositories by AI authorship density.
Raw Score
The unmodified sum of all severity-weighted, context-multiplied pattern match scores before temporal discounting. Reflects the absolute signal strength independent of when the repository was last active.
Time Factor
The temporal discount multiplier (0–100%) applied to the raw score. Repositories last updated before ChatGPT's launch (Nov 2022) receive a 5% factor. Full signal is only assigned to repositories active in the post-adoption era (Jan 2024+).
Pattern Hits
Total count of individual pattern matches across all files and categories. A high hit count with a low score may indicate a very large codebase with isolated AI snippets; a low count with a high score indicates dense, concentrated AI signatures.
HC Hit Rate
High+Critical pattern hits per file, averaged across the repository. This orthogonal signal catches repositories where a few files are densely packed with high-severity AI tells — a strong indicator even when the normalised score appears moderate due to codebase size.
Lines of Code / Files
Total lines and files analysed. The scanner examines 94 file extensions. These denominators are used to normalise the score, enabling fair comparison between repositories of vastly different sizes.

Score History

This chart maps the temporal evolution of the adjusted synthetic code score across successive scan runs. An upward trajectory indicates ongoing incorporation of AI-generated code or expanding LLM-assisted scaffolding; a stable or declining trajectory may reflect active human refactoring, code removal, or the adoption of stricter authorship policies. The dashed secondary line (right axis) independently tracks total raw pattern hit count, which can diverge from the normalised score when codebase size changes significantly between scans.

Severity Breakdown

Classifies detected patterns by their diagnostic confidence and structural impact. CRITICAL patterns (coefficient 10) represent definitive synthetic signatures — hallucinated imports, explicit LLM attribution metadata — virtually never produced by human authors. HIGH (5) indicates strong structural tells such as cross-file repetition or cross-linguistic idioms. MEDIUM (2) covers recognisable conversational padding and AI-specific vocabulary. LOW (1) captures subtle indicators like tautological comments and generic boilerplate that require density to carry independent signal.

CRITICAL 314HIGH 2MEDIUM 129LOW 2360

Directory Score Breakdown

This horizontal bar chart decomposes the repository's raw synthetic code score by top-level directory, allowing you to pinpoint precisely which modules or components carry the highest AI authorship density. Directories with disproportionately high scores relative to their size warrant targeted manual review: concentrated AI signatures often trace back to mass-generated configuration layers, auto-ported test suites, LLM-scaffolded boilerplate classes, or entire subsystems authored under heavy copilot assistance. Use this view to prioritise your human code-review effort.

Pattern Findings

The scanner identified 2805 distinct pattern matches across 19 syntactic categories. Each entry below represents a discrete location in the source code where the engine recorded a statistically significant AI authorship indicator. Expand any category row to inspect the individual file paths, line numbers, code snippets, and the lexical context (CODE, COMMENT, or STRING) in which each match was detected.

Reading the findings table: The Severity column indicates the diagnostic confidence level (CRITICAL / HIGH / MEDIUM / LOW). The Context column identifies whether the match occurred inside executable code, an inline comment, or a string literal — comment-context matches receive a ×1.5 weight because LLMs systematically over-annotate. The ⚡ bolt icon marks clustered matches: three or more patterns within a 10-line window, each receiving an additional ×1.5 density multiplier as dense clusters constitute far stronger evidence of synthetic authorship than isolated hits.

Hallucination Indicators314 hits · 3760 pts
SeverityFileLineSnippetContext
CRITICAL…pache/pinot/calcite/rel/rules/PinotFilterJoinRule.java109 com.google.common.collect.ImmutableList.copyOf(origAboveFilters), joinType);CODE
CRITICAL…sthandler/BaseSingleStageBrokerRequestHandlerTest.java744 org.apache.pinot.spi.exception.QueryErrorCode.TOO_MANY_REQUESTS.getId(),CODE
CRITICAL…e/pinot/broker/requesthandler/QueryValidationTest.java137 + "\"REALTIME\"] as String[]; org.apache.pinot.tools.admin.PinotAdministrator.main(args); 2') FROM foo";CODE
CRITICAL…adaptiveserverselector/AdaptiveServerSelectorTest.java76 CommonConstants.Broker.AdaptiveServerSelector.Type.NO_OP.name());CODE
CRITICAL…adaptiveserverselector/AdaptiveServerSelectorTest.java86 CommonConstants.Broker.AdaptiveServerSelector.Type.NUM_INFLIGHT_REQ.name());CODE
CRITICAL…adaptiveserverselector/AdaptiveServerSelectorTest.java94 CommonConstants.Broker.AdaptiveServerSelector.Type.LATENCY.name());CODE
CRITICAL…adaptiveserverselector/AdaptiveServerSelectorTest.java102 CommonConstants.Broker.AdaptiveServerSelector.Type.HYBRID.name());CODE
CRITICAL…pinot/core/accounting/QueryResourceAggregatorTest.java55 long maxHeapSize = org.apache.pinot.spi.utils.ResourceUsageUtils.getMaxHeapSize();CODE
CRITICAL…pinot/core/accounting/QueryResourceAggregatorTest.java66 long maxHeapSize = org.apache.pinot.spi.utils.ResourceUsageUtils.getMaxHeapSize();CODE
CRITICAL…pinot/core/accounting/QueryResourceAggregatorTest.java189 long maxHeapSize = org.apache.pinot.spi.utils.ResourceUsageUtils.getMaxHeapSize();CODE
CRITICAL…che/pinot/core/util/SegmentProcessorAvroUtilsTest.java113 org.apache.pinot.spi.data.Schema pinotSchema = new org.apache.pinot.spi.data.Schema.SchemaBuilder()CODE
CRITICAL…che/pinot/core/util/SegmentProcessorAvroUtilsTest.java303 org.apache.pinot.spi.data.Schema pinotSchema = new org.apache.pinot.spi.data.Schema.SchemaBuilder()CODE
CRITICAL…che/pinot/core/util/SegmentProcessorAvroUtilsTest.java325 org.apache.pinot.spi.data.Schema pinotSchema = new org.apache.pinot.spi.data.Schema.SchemaBuilder()CODE
CRITICAL…che/pinot/core/util/SegmentProcessorAvroUtilsTest.java348 return new org.apache.pinot.spi.data.Schema.SchemaBuilder()CODE
CRITICAL…killing/strategy/ScanEntriesThresholdStrategyTest.java218 org.apache.pinot.spi.env.PinotConfiguration pinotConfig = new org.apache.pinot.spi.env.PinotConfiguration(props);CODE
CRITICAL…killing/strategy/ScanEntriesThresholdStrategyTest.java220 new org.apache.pinot.core.accounting.QueryMonitorConfig(pinotConfig, 1_000_000_000L);CODE
CRITICAL…killing/strategy/ScanEntriesThresholdStrategyTest.java233 org.apache.pinot.spi.env.PinotConfiguration pinotConfig = new org.apache.pinot.spi.env.PinotConfiguration(props);CODE
CRITICAL…killing/strategy/ScanEntriesThresholdStrategyTest.java235 new org.apache.pinot.core.accounting.QueryMonitorConfig(pinotConfig, 1_000_000_000L);CODE
CRITICAL…ot/core/data/function/GroovyFunctionEvaluatorTest.java81 + "org.apache.pinot.tools.admin.PinotAdministrator.main(args); 2})",CODE
CRITICAL…ot/core/data/function/GroovyFunctionEvaluatorTest.java194 "Groovy({org.apache.commons.codec.digest.DigestUtils.sha256Hex(ssn)}, ssn)", Lists.newArrayList("ssn"),CODE
CRITICAL…ta/manager/BaseTableDataManagerAcquireSegmentTest.java102 org.apache.commons.io.FileUtils.deleteQuietly(_tmpDir);CODE
CRITICAL…a/manager/realtime/RealtimeSegmentDataManagerTest.java1267 new org.apache.pinot.spi.config.table.CompletionConfig("DOWNLOAD"));CODE
CRITICAL…r/filter/predicate/PredicateEvaluatorProviderTest.java190 new org.apache.pinot.common.request.context.predicate.NotEqPredicate(ExpressionContext.forIdentifier("col"),CODE
CRITICAL…r/filter/predicate/PredicateEvaluatorProviderTest.java218 FieldSpec fieldSpec = new org.apache.pinot.spi.data.DimensionFieldSpec(columnName, dataType, true);CODE
CRITICAL…ot/queries/JsonUnnestIngestionFromAvroQueriesTest.java79 private static final org.apache.pinot.spi.data.Schema SCHEMA = new org.apache.pinot.spi.data.Schema.SchemaBuilder()CODE
CRITICAL…he/pinot/queries/JsonIngestionFromAvroQueriesTest.java82 private static final org.apache.pinot.spi.data.Schema SCHEMA = new org.apache.pinot.spi.data.Schema.SchemaBuilder()CODE
CRITICAL…ava/org/apache/pinot/core/transport/NettyInstance.java86 return io.netty.util.internal.ReflectionUtil.trySetAccessible(CONSTRUCTOR, true) == null;CODE
CRITICAL…ava/org/apache/pinot/core/transport/NettyInstance.java91 return io.netty.util.internal.PlatformDependent.usedDirectMemory();CODE
CRITICAL…ava/org/apache/pinot/core/transport/NettyInstance.java96 return io.netty.util.internal.PlatformDependent.maxDirectMemory();CODE
CRITICAL…ava/org/apache/pinot/core/transport/NettyInstance.java113 return io.grpc.netty.shaded.io.netty.util.internal.ReflectionUtil.trySetAccessible(CONSTRUCTOR, true) == null;CODE
CRITICAL…ava/org/apache/pinot/core/transport/NettyInstance.java118 return io.grpc.netty.shaded.io.netty.util.internal.PlatformDependent.usedDirectMemory();CODE
CRITICAL…ava/org/apache/pinot/core/transport/NettyInstance.java123 return io.grpc.netty.shaded.io.netty.util.internal.PlatformDependent.maxDirectMemory();CODE
CRITICAL…ava/org/apache/pinot/core/util/ListenerConfigUtil.java240 // @see org.glassfish.jersey.grizzly2.httpserver.GrizzlyHttpServerFactory.createHttpServer(java.net.URI, orgCOMMENT
CRITICAL…unction/DistinctCountCPCSketchAggregationFunction.java862 return org.apache.datasketches.common.Util.exactLog2OfInt(_nominalEntries);CODE
CRITICAL…ier/src/main/java/org/apache/pinot/compat/TableOp.java163 org.apache.pinot.spi.data.Schema.fromString(schemaJson);CODE
CRITICAL…pache/pinot/sql/ddl/compile/DdlCompileContextTest.java48 org.assertj.core.api.Assertions.assertThat(ex.getMessage())CODE
CRITICAL…ot/connector/spark/v3/datasource/PinotDataWriter.scala199 val fs = org.apache.hadoop.fs.FileSystem.get(new java.net.URI(savePath), new org.apache.hadoop.conf.Configuration())CODE
CRITICAL…ot/connector/spark/v3/datasource/PinotDataWriter.scala229 case org.apache.spark.sql.types.ArrayType(elementType, _) =>CODE
CRITICAL…rg/apache/pinot/connector/spark/common/HttpUtils.scala98 val connectionManager = org.apache.hc.client5.http.impl.io.PoolingHttpClientConnectionManagerBuilder.create()CODE
CRITICAL…r/spark/common/reader/PinotGrpcServerDataFetcher.scala44 val (hostStr, portStr) = org.apache.pinot.connector.spark.common.NetUtils.parseHostPort(proxyUri, readOptions.useHCODE
CRITICAL…ector/spark/common/reader/PinotServerDataFetcher.scala170 val (proxyHost, proxyPort) = org.apache.pinot.connector.spark.common.NetUtils.parseHostPort(proxyUri, dataSourceOpCODE
CRITICAL…not/server/predownload/PredownloadSegmentInfoTest.java112 org.apache.commons.io.FileUtils.writeByteArrayToFile(new File(segDir, "columns.psf"), new byte[]{1, 2, 3});CODE
CRITICAL…not/server/predownload/PredownloadSegmentInfoTest.java127 org.apache.commons.io.FileUtils.deleteQuietly(tempDir);CODE
CRITICAL…pinot/server/predownload/PredownloadTableInfoTest.java92 org.apache.commons.io.FileUtils.writeByteArrayToFile(new File(segDir, "columns.psf"), new byte[]{1, 2, 3});CODE
CRITICAL…pinot/server/predownload/PredownloadTableInfoTest.java107 org.apache.commons.io.FileUtils.deleteQuietly(tempDir);CODE
CRITICAL…/server/api/ServerAdminApiAccessControlFilterTest.java135 .thenThrow(new NotAuthorizedException(javax.ws.rs.core.Response.status(Status.UNAUTHORIZED).build()));CODE
CRITICAL…ache/pinot/server/predownload/PredownloadZKClient.java169 if (!CommonConstants.Helix.StateModel.SegmentStateModel.ONLINE.equals(entry.getValue())) {CODE
CRITICAL…/apache/pinot/server/api/resources/TablesResource.java598 File segmentTarFile = org.apache.pinot.common.utils.FileUtils.concatAndValidateFile(tmpSegmentTarDir,CODE
CRITICAL…/apache/pinot/server/api/resources/TablesResource.java1068 File segmentTarFile = org.apache.pinot.common.utils.FileUtils.concatAndValidateFile(segmentTarUploadDir,CODE
CRITICAL…s/src/test/resources/udf-test-results/uuidtobytes.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
CRITICAL…on-tests/src/test/resources/udf-test-results/acos.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
CRITICAL…src/test/resources/udf-test-results/all-functions.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
CRITICAL…ests/src/test/resources/udf-test-results/arraymax.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
CRITICAL…ion-tests/src/test/resources/udf-test-results/not.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
CRITICAL…test/resources/udf-test-results/arrayelementatint.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
CRITICAL…tests/src/test/resources/udf-test-results/adler32.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
CRITICAL…tests/src/test/resources/udf-test-results/isfalse.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
CRITICAL…tion-tests/src/test/resources/udf-test-results/or.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
CRITICAL…-tests/src/test/resources/udf-test-results/isuuid.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
CRITICAL…s/src/test/resources/udf-test-results/uuidversion.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
254 more matches not shown…
Over-Commented Block1967 hits · 1946 pts
SeverityFileLineSnippetContext
LOW.asf.yaml1#COMMENT
LOW.codecov.yml1#COMMENT
LOW…/java/org/apache/pinot/query/QueryCompilationTest.java201 // CALCITE-7379: decorrelating a scalar correlated sub-query feeding an aggregate changes the nullability of theCOMMENT
LOW…inot/query/planner/physical/v2/LookupJoinPlanTest.java181 // PhysicalExchange(SINGLETON_EXCHANGE) ← rootCOMMENT
LOW…apache/pinot/query/planner/logical/StagesTestBase.java61COMMENT
LOW…apache/pinot/query/planner/logical/StagesTestBase.java241 Preconditions.checkState(old == null, "Mailbox already exists for stageId: %s", stageId);COMMENT
LOW…apache/pinot/query/planner/logical/StagesTestBase.java261 /// tableScan("T1")COMMENT
LOW…apache/pinot/query/planner/logical/StagesTestBase.java301COMMENT
LOW…apache/pinot/query/planner/logical/StagesTestBase.java321 /// readT1.newReceiver(), // here a new receiver is createdCOMMENT
LOW…apache/pinot/query/planner/logical/StagesTestBase.java361 /// Returns whether the spool is sealed or not.COMMENT
LOW…rg/apache/pinot/calcite/rel/hint/PinotHintOptions.java81 @NullableCOMMENT
LOW…rg/apache/pinot/calcite/rel/hint/PinotHintOptions.java101 /// rows which are equal across all projected columns are guaranteed to land on the same worker. Forcing it whenCOMMENT
LOW…che/pinot/calcite/rel/hint/PinotHintStrategyTable.java101 /// Check if a hint-able [org.apache.calcite.rel.RelNode] contains an option key for a specific hint name ofCOMMENT
LOW…he/pinot/calcite/rel/logical/PinotRelExchangeType.java21/// Type of exchange.COMMENT
LOW…lcite/rel/rules/PinotWindowExchangeNodeInsertRule.java101COMMENT
LOW…lcite/rel/rules/PinotWindowExchangeNodeInsertRule.java161 ///COMMENT
LOW…t/calcite/rel/rules/PinotRelDistributionTraitRule.java161 RelDistribution inputRelDistribution = inputs.get(0).getTraitSet().getDistribution();COMMENT
LOW…pache/pinot/calcite/rel/rules/PinotFilterJoinRule.java41COMMENT
LOW…pache/pinot/calcite/rel/rules/PinotFilterJoinRule.java61 @OverrideCOMMENT
LOW…che/pinot/calcite/rel/rules/GroupingSetsPlanUtils.java41import org.apache.calcite.util.ImmutableBitSet;COMMENT
LOW…te/rel/rules/PinotAggregateExchangeNodeInsertRule.java81/// - `aggName`\_\_LEAF \[+ `aggName`\_\_INTERMEDIATE\] + `aggName`\_\_FINALCOMMENT
LOW…te/rel/rules/PinotAggregateExchangeNodeInsertRule.java341 // Create a LEAF aggregate.COMMENT
LOW…org/apache/pinot/calcite/rel/rules/PinotRuleUtils.java101 /// segment-local info (indexing and others) to speed up the execution.COMMENT
LOW…org/apache/pinot/calcite/rel/rules/PinotRuleUtils.java141 /// relocated -- pushed below a join, duplicated onto another input, and so on.COMMENT
LOW…apache/pinot/calcite/rel/rules/PinotQueryRuleSets.java141 UnionToDistinctRule.Config.DEFAULTCOMMENT
LOW…/calcite/rel/rules/PinotProjectAggregateMergeRule.java41/// [org.apache.pinot.calcite.rel.hint.PinotHintStrategyTable]). The aggregate's hints are therefore droppedCOMMENT
LOW…calcite/rel/rules/PinotJoinToDynamicBroadcastRule.java41/// | |COMMENT
LOW…calcite/rel/rules/PinotJoinToDynamicBroadcastRule.java61///COMMENT
LOW…calcite/rel/rules/PinotJoinToDynamicBroadcastRule.java81///COMMENT
LOW…apache/pinot/calcite/sql2rel/PinotRelDecorrelator.java41///COMMENT
LOW…g/apache/pinot/calcite/sql/fun/PinotOperatorTable.java61COMMENT
LOW…g/apache/pinot/calcite/sql/fun/PinotOperatorTable.java301COMMENT
LOW…g/apache/pinot/calcite/sql/fun/PinotOperatorTable.java521 /// AVG into SUM / COUNT, since Pinot has native window AVG support viaCOMMENT
LOW…main/java/org/apache/pinot/query/QueryEnvironment.java101import org.apache.pinot.sql.parsers.CalciteSqlParser;COMMENT
LOW…main/java/org/apache/pinot/query/QueryEnvironment.java401 _envConfig.getTableCache()).unwrap();COMMENT
LOW…main/java/org/apache/pinot/query/QueryEnvironment.java541 /// It performs several phases of rule application over the parsed decorrelated trimmed plan:COMMENT
LOW…main/java/org/apache/pinot/query/QueryEnvironment.java581 hepProgramBuilder.addRuleCollection(projectPushdownRules);COMMENT
LOW…main/java/org/apache/pinot/query/QueryEnvironment.java761COMMENT
LOW…main/java/org/apache/pinot/query/QueryEnvironment.java801 /// Whether to use physical optimizer by default.COMMENT
LOW…main/java/org/apache/pinot/query/QueryEnvironment.java821 }COMMENT
LOW…main/java/org/apache/pinot/query/QueryEnvironment.java841 default boolean defaultUseBrokerPruning() {COMMENT
LOW…main/java/org/apache/pinot/query/QueryEnvironment.java901 /// This is used whenever the query needs to be executed, but can be null when the QueryEnvironment will be usedCOMMENT
LOW…/query/planner/explain/PhysicalExplainPlanVisitor.java81 /// as the node that is executing this sub-tree. This is helpful for debugging what is happeningCOMMENT
LOW…apache/pinot/query/planner/explain/PlanNodeMerger.java61 ///COMMENT
LOW…/query/planner/explain/AskingServerStageExplainer.java141 /// and [PlanNodeMerger]. This basically means that plans from different segments should be grouped by aCOMMENT
LOW…anner/explain/MultiStageExplainAskingServersUtils.java41 /// Some of the new nodes may be [org.apache.pinot.core.plan.PinotExplainedRelNode], so once this method isCOMMENT
LOW…pinot/query/planner/explain/ExplainNodeSimplifier.java41import org.apache.pinot.query.planner.plannode.TableScanNode;COMMENT
LOW…t/query/planner/physical/DispatchablePlanMetadata.java181 /// are not in partition-class space.COMMENT
LOW…pinot/query/planner/physical/PinotDispatchPlanner.java121 /// When only _some_ leaf stages are empty (an empty or fully-pruned table combined with a non-empty table in theCOMMENT
LOW…t/query/planner/physical/MailboxAssignmentVisitor.java101 // TODO: Add support for more exchange typesCOMMENT
LOW…nner/physical/v2/PlanFragmentAndMailboxAssignment.java41import org.apache.pinot.query.planner.plannode.PlanNode;COMMENT
LOW…/pinot/query/planner/physical/v2/ExchangeStrategy.java21import java.util.List;COMMENT
LOW…/pinot/query/planner/physical/v2/ExchangeStrategy.java41 SUB_PARTITIONING_HASH_EXCHANGE(true),COMMENT
LOW…query/planner/physical/v2/PRelToPlanNodeConverter.java361COMMENT
LOW…pinot/query/planner/physical/v2/TableScanMetadata.java21import java.util.List;COMMENT
LOW…pinot/query/planner/physical/v2/TableScanMetadata.java41 /// ...COMMENT
LOW…/query/planner/physical/v2/nodes/PhysicalExchange.java41/// Exchange is a special plan node because it is often used to change the number of streams. Since we trackCOMMENT
LOW…hysical/v2/opt/rules/WorkerExchangeAssignmentRule.java61/// This rule also adds Exchanges when either of the following conditions are met:COMMENT
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java81COMMENT
LOW…uery/planner/physical/v2/opt/rules/LookupJoinRule.java41/// 1. **Right side**: Exchange converted to [ExchangeStrategy#LOOKUP_LOCAL_EXCHANGE] — a pseudo-exchangeCOMMENT
1907 more matches not shown…
Decorative Section Separators83 hits · 278 pts
SeverityFileLineSnippetContext
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java63 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java65 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java135 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java137 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java190 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java192 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java298 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java300 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java351 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java353 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java422 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java424 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java462 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java464 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java606 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…iew/metadata/MaterializedViewPartitionManagerTest.java608 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…erializedview/analysis/timeexpr/TimeExprValidator.java109 // ─── Policy layer ──────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…erializedview/analysis/timeexpr/TimeExprValidator.java200 // ─── Structural layer: ADT + parser ────────────────────────────────────────────────────COMMENT
MEDIUM…ew/consistency/MaterializedViewConsistencyManager.java407 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…ew/consistency/MaterializedViewConsistencyManager.java409 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…zedview/metadata/MaterializedViewPartitionManager.java149 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…zedview/metadata/MaterializedViewPartitionManager.java151 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…zedview/metadata/MaterializedViewPartitionManager.java465 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…zedview/metadata/MaterializedViewPartitionManager.java467 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…zedview/metadata/MaterializedViewPartitionManager.java521 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…zedview/metadata/MaterializedViewPartitionManager.java523 // ─────────────────────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…ry/aggregation/function/funnel/DictIdsWrapperTest.java49 // ── Single-key constructor ───────────────────────────────────────────────COMMENT
MEDIUM…ry/aggregation/function/funnel/DictIdsWrapperTest.java58 // ── HashMap fallback path ────────────────────────────────────────────────COMMENT
MEDIUM…ry/aggregation/function/funnel/DictIdsWrapperTest.java112 // ── Stride path reverseCompositeId ──────────────────────────────────────COMMENT
MEDIUM…pinot/server/predownload/PredownloadSchedulerTest.java442 // ── Peer download tests ────────────────────────────────────────────────────COMMENT
MEDIUM…gration/tests/StreamStatsReportingIntegrationTest.java137 // ─── helpers ──────────────────────────────────────────────────────────────────COMMENT
MEDIUM…gration/tests/StreamStatsReportingIntegrationTest.java167 // ─── tests ────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…gration/tests/StreamStatsReportingIntegrationTest.java437 // ─── private helpers ──────────────────────────────────────────────────────────COMMENT
MEDIUMscripts/update-release-binaries.py194# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py196# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py235# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py237# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py256# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py258# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py339# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py341# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py476# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py478# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py535# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py537# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py636# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py638# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py713# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py715# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py830# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py832# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py1066# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py1068# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py82# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py84# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py122# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py124# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py1261# ---------------------------------------------------------------------------COMMENT
MEDIUMscripts/update-release-binaries.py1263# ---------------------------------------------------------------------------COMMENT
MEDIUM…tHelixResourceManagerMaterializedViewBackfillTest.java87 // ── backfill ────────────────────────────────────────────────────────────────────────────COMMENT
23 more matches not shown…
Structural Annotation Overuse132 hits · 232 pts
SeverityFileLineSnippetContext
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java579 // Step 1: Get LogicalTableRouteInfo using LogicalTableRouteProviderCOMMENT
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java587 // Step 2: Build broker requests for route calculationCOMMENT
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java601 // Step 3: Calculate routesCOMMENT
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java605 // Step 4: Build worker assignment from LogicalTableRouteInfoCOMMENT
LOW…uting/manager/BrokerRoutingManagerConcurrencyTest.java412 // Step 1: Build OFFLINE table first - should not have TimeBoundaryManagerCOMMENT
LOW…uting/manager/BrokerRoutingManagerConcurrencyTest.java420 // Step 2: Build REALTIME table - should add TimeBoundaryManager to existing offline tableCOMMENT
LOW…ializedview/analysis/MaterializedViewAnalyzerTest.java208 // Step 1: SQL syntax errorsCOMMENT
LOW…ializedview/analysis/MaterializedViewAnalyzerTest.java414 // Step 2: Source table validationCOMMENT
LOW…ializedview/analysis/MaterializedViewAnalyzerTest.java664 // Step 3: MV schema column validationCOMMENT
LOW…ializedview/analysis/MaterializedViewAnalyzerTest.java747 // Step 4: Task config parameter validationCOMMENT
LOW…ializedview/analysis/MaterializedViewAnalyzerTest.java1018 // Step 6: MV time-column alignment (segmentsConfig.timeColumnName)COMMENT
LOW…ializedview/analysis/MaterializedViewAnalyzerTest.java1159 // Step 7: MV time column TIMESTAMP-only contract (TimeExprValidator)COMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java86 /// Step 1: shape gateCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java98 /// Step 2: GROUP BYCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java104 /// Step 3: projection subsumptionCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java110 /// Step 4: WHERE matching + residual extraction (shared logic)COMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java145 /// Step 5: residual validation (subclass-specific)COMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java151 /// Step 6: ORDER BYCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java157 /// Step 7: HAVINGCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java163 /// Step 8: build resultCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java140 // Step 2: source table existence and time-column checksCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java146 // Step 3: MV schema column completeness (including dateTime columns)COMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java149 // Step 5: extract and validate time column transformation mappings.COMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java156 // Step 6: MV time column (segmentsConfig.timeColumnName) must be wired to a SELECT-producedCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java163 // Step 7: MV time column shape + type. TIMESTAMP-only contract: both base and MV timeCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java111 // Step 1: SQL syntax and Pinot semantic validationCOMMENT
LOW…lizedview/scheduler/MaterializedViewTaskScheduler.java342 /// Step 1: Finds the earliest STALE partition and dispatches the appropriate task.COMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java131 // Step 1: Convert output range to millis rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java214 // Step 2: Convert millis range to input rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java250 // Step 3: Rewrite the filter functionCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java292 // Step 1: Convert output range to millis rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java381 // Step 2: Convert millis range to input rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java417 // Step 3: Rewrite the filter functionCOMMENT
LOW…not/core/query/executor/ServerQueryExecutorV1Impl.java332 // NOTE: This method might change indexSegments. Do not use it after calling this method.COMMENT
LOW…java/org/apache/pinot/spi/filesystem/LocalPinotFS.java231 // Step 1: Copy the file or directory into the temporary fileCOMMENT
LOW…java/org/apache/pinot/spi/filesystem/LocalPinotFS.java247 // Step 2: Rename the temporary file to the destination fileCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java643 /// Step 1: Verify MV is currently hit (precondition; SLO disabled).COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java649 /// Step 2: Tighten the SLO on the MV definition. watermarkMs = DATA_MAX_TIME_MS is aCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java530 /// Step 1: baseline — split query before the simulated overlap.COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java543 /// Step 2: simulate endSegmentReplace without postProcess — upload MV segmentsCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java585 /// Step 3: rerun the split query. With the materializedViewTime < watermarkMs filterCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java672 /// Step 3: Query again — the MV should NOT be hit (SLO trips eligibility gate).COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java687 /// Step 4: Disable the SLO again by setting stalenessThresholdMs back to 0.COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java702 /// Step 5: Query again — the MV should be hit again.COMMENT
LOWscripts/update-release-binaries.py195# Step 1: Parse assembly descriptor for shipped modulesCOMMENT
LOWscripts/update-release-binaries.py236# Step 2: Get Maven artifact IDs for modulesCOMMENT
LOWscripts/update-release-binaries.py257# Step 3: Run mvn dependency:listCOMMENT
LOWscripts/update-release-binaries.py340# Step 4: Parse current LICENSE-binaryCOMMENT
LOWscripts/update-release-binaries.py477# Step 5: Compute diffCOMMENT
LOWscripts/update-release-binaries.py536# Step 6: Detect licenses for deps (new and version-bumped)COMMENT
LOWscripts/update-release-binaries.py714# Step 7: Generate reportCOMMENT
LOWscripts/update-release-binaries.py831# Step 8: Generate updated LICENSE-binaryCOMMENT
LOWscripts/update-release-binaries.py1067# Step 9: Generate NOTICE-binaryCOMMENT
LOWscripts/update-release-binaries.py1380 # Step 4: Parse current LICENSE-binaryCOMMENT
LOWscripts/update-release-binaries.py1389 # Step 5: Compute diffCOMMENT
LOWscripts/update-release-binaries.py1392 # Step 6: Detect licenses for new depsCOMMENT
LOWscripts/update-release-binaries.py1424 # Step 7: Print reportCOMMENT
LOWscripts/update-release-binaries.py1428 # Step 8: Generate updated fileCOMMENT
LOWscripts/update-release-binaries.py1353 # Step 1: Parse assembly to find shipped modulesCOMMENT
LOW…not/segment/spi/index/metadata/ColumnMetadataImpl.java577 // NOTE: This method is only meant to retain compatibility of serialization for endpoint:COMMENT
72 more matches not shown…
Verbosity Indicators121 hits · 216 pts
SeverityFileLineSnippetContext
LOW…t/query/planner/physical/v2/PRelNodeTreeValidator.java50 // If joins are disabled in lite mode, we need to check if the plan contains joinsCOMMENT
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java579 // Step 1: Get LogicalTableRouteInfo using LogicalTableRouteProviderCOMMENT
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java587 // Step 2: Build broker requests for route calculationCOMMENT
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java601 // Step 3: Calculate routesCOMMENT
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java605 // Step 4: Build worker assignment from LogicalTableRouteInfoCOMMENT
LOW…uting/manager/BrokerRoutingManagerConcurrencyTest.java412 // Step 1: Build OFFLINE table first - should not have TimeBoundaryManagerCOMMENT
LOW…uting/manager/BrokerRoutingManagerConcurrencyTest.java420 // Step 2: Build REALTIME table - should add TimeBoundaryManager to existing offline tableCOMMENT
LOW…ializedview/analysis/MaterializedViewAnalyzerTest.java208 // Step 1: SQL syntax errorsCOMMENT
LOW…ializedview/analysis/MaterializedViewAnalyzerTest.java414 // Step 2: Source table validationCOMMENT
LOW…ializedview/analysis/MaterializedViewAnalyzerTest.java664 // Step 3: MV schema column validationCOMMENT
LOW…ializedview/analysis/MaterializedViewAnalyzerTest.java747 // Step 4: Task config parameter validationCOMMENT
LOW…ializedview/analysis/MaterializedViewAnalyzerTest.java1018 // Step 6: MV time-column alignment (segmentsConfig.timeColumnName)COMMENT
LOW…ializedview/analysis/MaterializedViewAnalyzerTest.java1159 // Step 7: MV time column TIMESTAMP-only contract (TimeExprValidator)COMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java86 /// Step 1: shape gateCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java98 /// Step 2: GROUP BYCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java104 /// Step 3: projection subsumptionCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java110 /// Step 4: WHERE matching + residual extraction (shared logic)COMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java145 /// Step 5: residual validation (subclass-specific)COMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java151 /// Step 6: ORDER BYCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java157 /// Step 7: HAVINGCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java163 /// Step 8: build resultCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java140 // Step 2: source table existence and time-column checksCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java146 // Step 3: MV schema column completeness (including dateTime columns)COMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java149 // Step 5: extract and validate time column transformation mappings.COMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java156 // Step 6: MV time column (segmentsConfig.timeColumnName) must be wired to a SELECT-producedCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java163 // Step 7: MV time column shape + type. TIMESTAMP-only contract: both base and MV timeCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java111 // Step 1: SQL syntax and Pinot semantic validationCOMMENT
LOW…lizedview/scheduler/MaterializedViewTaskScheduler.java342 /// Step 1: Finds the earliest STALE partition and dispatches the appropriate task.COMMENT
LOW…/apache/pinot/query/runtime/operator/LeafOperator.java618 /// For selection, we need to check if the columns are in order. If not, we need to re-arrange the columns.COMMENT
LOW…ction/funnel/window/FunnelBaseAggregationFunction.java304 // When maxStepDuration > 0, we need to check if the event_to_add has a timestamp within the max durationCOMMENT
LOW…indow/FunnelEventsFunctionEvalAggregationFunction.java452 // When maxStepDuration > 0, we need to check if the event_to_add has a timestamp within the max durationCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java131 // Step 1: Convert output range to millis rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java214 // Step 2: Convert millis range to input rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java250 // Step 3: Rewrite the filter functionCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java292 // Step 1: Convert output range to millis rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java381 // Step 2: Convert millis range to input rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java417 // Step 3: Rewrite the filter functionCOMMENT
LOW…java/org/apache/pinot/spi/filesystem/LocalPinotFS.java231 // Step 1: Copy the file or directory into the temporary fileCOMMENT
LOW…java/org/apache/pinot/spi/filesystem/LocalPinotFS.java247 // Step 2: Rename the temporary file to the destination fileCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java643 /// Step 1: Verify MV is currently hit (precondition; SLO disabled).COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java649 /// Step 2: Tighten the SLO on the MV definition. watermarkMs = DATA_MAX_TIME_MS is aCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java530 /// Step 1: baseline — split query before the simulated overlap.COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java543 /// Step 2: simulate endSegmentReplace without postProcess — upload MV segmentsCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java585 /// Step 3: rerun the split query. With the materializedViewTime < watermarkMs filterCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java672 /// Step 3: Query again — the MV should NOT be hit (SLO trips eligibility gate).COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java687 /// Step 4: Disable the SLO again by setting stalenessThresholdMs back to 0.COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java702 /// Step 5: Query again — the MV should be hit again.COMMENT
LOWscripts/update-release-binaries.py195# Step 1: Parse assembly descriptor for shipped modulesCOMMENT
LOWscripts/update-release-binaries.py236# Step 2: Get Maven artifact IDs for modulesCOMMENT
LOWscripts/update-release-binaries.py257# Step 3: Run mvn dependency:listCOMMENT
LOWscripts/update-release-binaries.py340# Step 4: Parse current LICENSE-binaryCOMMENT
LOWscripts/update-release-binaries.py477# Step 5: Compute diffCOMMENT
LOWscripts/update-release-binaries.py536# Step 6: Detect licenses for deps (new and version-bumped)COMMENT
LOWscripts/update-release-binaries.py714# Step 7: Generate reportCOMMENT
LOWscripts/update-release-binaries.py831# Step 8: Generate updated LICENSE-binaryCOMMENT
LOWscripts/update-release-binaries.py1067# Step 9: Generate NOTICE-binaryCOMMENT
LOWscripts/update-release-binaries.py1380 # Step 4: Parse current LICENSE-binaryCOMMENT
LOWscripts/update-release-binaries.py1389 # Step 5: Compute diffCOMMENT
LOWscripts/update-release-binaries.py1392 # Step 6: Detect licenses for new depsCOMMENT
LOWscripts/update-release-binaries.py1424 # Step 7: Print reportCOMMENT
61 more matches not shown…
Example Usage Blocks77 hits · 116 pts
SeverityFileLineSnippetContext
LOW…/examples/docker/ingestion-job-specs/airlineStats.yaml47# Sample usage:COMMENT
LOW…/examples/docker/ingestion-job-specs/airlineStats.yaml53# Sample usage:COMMENT
LOW…examples/docker/ingestion-job-specs/baseballStats.yaml47# Sample usage:COMMENT
LOW…examples/docker/ingestion-job-specs/baseballStats.yaml53# Sample usage:COMMENT
LOW…apache/pinot/core/function/scalar/SketchFunctions.java58/// Example usage:COMMENT
LOW…pi/src/test/resources/ingestion_job_spec_template.yaml35# Sample usage:COMMENT
LOW…i/src/main/java/org/apache/pinot/tsdb/spi/AggInfo.java43/// Example usage:COMMENT
LOW…ources/examples/batch/testUnnest/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…ources/examples/batch/testUnnest/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…rces/examples/batch/githubEvents/ingestionJobSpec.yaml47# Sample usage:COMMENT
LOW…rces/examples/batch/githubEvents/ingestionJobSpec.yaml53# Sample usage:COMMENT
LOW…examples/batch/githubEvents/sparkIngestionJobSpec.yaml49# Sample usage:COMMENT
LOW…examples/batch/githubEvents/sparkIngestionJobSpec.yaml55# Sample usage:COMMENT
LOW…sources/examples/batch/ssb/dates/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…sources/examples/batch/ssb/dates/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…rces/examples/batch/ssb/supplier/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…rces/examples/batch/ssb/supplier/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…esources/examples/batch/ssb/part/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…esources/examples/batch/ssb/part/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…rces/examples/batch/ssb/customer/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…rces/examples/batch/ssb/customer/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…ces/examples/batch/ssb/lineorder/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…ces/examples/batch/ssb/lineorder/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…s/examples/batch/starbucksStores/ingestionJobSpec.yaml47# Sample usage:COMMENT
LOW…s/examples/batch/starbucksStores/ingestionJobSpec.yaml53# Sample usage:COMMENT
LOW…es/batch/githubComplexTypeEvents/ingestionJobSpec.yaml47# Sample usage:COMMENT
LOW…es/batch/githubComplexTypeEvents/ingestionJobSpec.yaml53# Sample usage:COMMENT
LOW…mples/batch/lookup/userGroupsDim/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…mples/batch/lookup/userGroupsDim/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…examples/batch/clickstreamFunnel/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…examples/batch/clickstreamFunnel/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…ces/examples/batch/tpch/lineitem/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…ces/examples/batch/tpch/lineitem/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…ces/examples/batch/tpch/partsupp/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…ces/examples/batch/tpch/partsupp/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…urces/examples/batch/tpch/nation/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…urces/examples/batch/tpch/nation/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…urces/examples/batch/tpch/region/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…urces/examples/batch/tpch/region/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…ces/examples/batch/tpch/supplier/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…ces/examples/batch/tpch/supplier/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…sources/examples/batch/tpch/part/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…sources/examples/batch/tpch/part/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…urces/examples/batch/tpch/orders/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…urces/examples/batch/tpch/orders/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…ces/examples/batch/tpch/customer/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…ces/examples/batch/tpch/customer/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…xamples/batch/airlineStats/hadoopIngestionJobSpec.yaml53# Sample usage:COMMENT
LOW…xamples/batch/airlineStats/hadoopIngestionJobSpec.yaml59# Sample usage:COMMENT
LOW…rces/examples/batch/airlineStats/ingestionJobSpec.yaml47# Sample usage:COMMENT
LOW…rces/examples/batch/airlineStats/ingestionJobSpec.yaml53# Sample usage:COMMENT
LOW…examples/batch/airlineStats/sparkIngestionJobSpec.yaml53# Sample usage:COMMENT
LOW…examples/batch/airlineStats/sparkIngestionJobSpec.yaml59# Sample usage:COMMENT
LOW…s/examples/batch/fineFoodReviews/ingestionJobSpec.yaml48# Sample usage:COMMENT
LOW…s/examples/batch/fineFoodReviews/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…/resources/examples/batch/sorted/ingestionJobSpec.yaml47# Sample usage:COMMENT
LOW…/resources/examples/batch/sorted/ingestionJobSpec.yaml53# Sample usage:COMMENT
LOW…examples/batch/clientSalaryNulls/ingestionJobSpec.yaml47# Sample usage:COMMENT
LOW…examples/batch/clientSalaryNulls/ingestionJobSpec.yaml53# Sample usage:COMMENT
LOW…ces/examples/batch/baseballStats/ingestionJobSpec.yaml48# Sample usage:COMMENT
17 more matches not shown…
Self-Referential Comments29 hits · 86 pts
SeverityFileLineSnippetContext
MEDIUM…ration-tests/src/test/resources/ssb/ssb_query_set.yaml20# This function defines the test set of SSB queriesCOMMENT
MEDIUM…s/src/test/resources/udf-test-results/uuidtobytes.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…on-tests/src/test/resources/udf-test-results/acos.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…src/test/resources/udf-test-results/all-functions.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…ests/src/test/resources/udf-test-results/arraymax.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…ion-tests/src/test/resources/udf-test-results/not.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…test/resources/udf-test-results/arrayelementatint.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…tests/src/test/resources/udf-test-results/adler32.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…tests/src/test/resources/udf-test-results/isfalse.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…tion-tests/src/test/resources/udf-test-results/or.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…-tests/src/test/resources/udf-test-results/isuuid.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…s/src/test/resources/udf-test-results/uuidversion.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…on-tests/src/test/resources/udf-test-results/plus.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…/src/test/resources/udf-test-results/uuidtostring.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…ts/src/test/resources/udf-test-results/todatetime.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…ion-tests/src/test/resources/udf-test-results/and.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…-tests/src/test/resources/udf-test-results/touuid.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…-tests/src/test/resources/udf-test-results/uuidv4.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…on-tests/src/test/resources/udf-test-results/year.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…test/resources/udf-test-results/arrayconcatdouble.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…ion-tests/src/test/resources/udf-test-results/abs.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…n-tests/src/test/resources/udf-test-results/array.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…/src/test/resources/udf-test-results/arrayaverage.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…-tests/src/test/resources/udf-test-results/uuidv7.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…tests/src/test/resources/udf-test-results/degrees.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…src/test/resources/udf-test-results/uuidtimestamp.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…s/src/test/resources/udf-test-results/bytestouuid.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…on-tests/src/test/resources/udf-test-results/mult.yaml20# This file is auto-generated by the UDF test framework. Do not edit it manually.COMMENT
MEDIUM…va/org/apache/pinot/integration/tests/udf/UdfTest.java381 + "# This file is auto-generated by the UDF test framework. Do not edit it manually.\n"CODE
AI Slop Vocabulary15 hits · 45 pts
SeverityFileLineSnippetContext
MEDIUM…org/apache/pinot/calcite/rel/rules/PinotRuleUtils.java100 /// utility logic to determine if a JOIN can be pushed down to the leaf-stage execution and leverage theCOMMENT
MEDIUM…calcite/rel/rules/PinotJoinToDynamicBroadcastRule.java82/// - new plan can leverage the indexes and fast filtering of the leaf-stage Pinot server processing logic.COMMENT
MEDIUM…g/instanceselector/MultiStageReplicaGroupSelector.java52/// Instance selector for multi-stage queries which can ensure that Colocated Tables always leverage Colocated JoinCOMMENT
MEDIUM…va/org/apache/pinot/query/runtime/blocks/MseBlock.java42/// Meanwhile, the API force callers to do some castings, but it is a trade-off to have a more robust and maintainableCOMMENT
MEDIUM…e/pinot/core/query/reduce/MergeDataTablesOnlyTest.java657 /// the comparison is robust for unordered group-by / distinct results).COMMENT
MEDIUM…pache/pinot/core/data/manager/InstanceDataManager.java143 /// uploaded segment file. Servers utilize segment uploader to upload llc segment to segment store.COMMENT
MEDIUM…/connector/spark/v3/datasource/PinotWriteBuilder.scala31 // TODO: utilize filtersCOMMENT
MEDIUM…inot/integration/tests/UpsertTableIntegrationTest.java188 // fashion, but query more times to be more robust)COMMENT
MEDIUM…inot/integration/tests/UpsertTableIntegrationTest.java207 // fashion, but query more times to be more robust)COMMENT
MEDIUM…/pinot/integration/tests/BaseDedupIntegrationTest.java113 // fashion, but query more times to be more robust)COMMENT
MEDIUM…/integration/tests/custom/GroupingSetsQueriesTest.java319 /// expressions) executes on both engines without hitting a column-count cap. Assert only what is robustCOMMENT
MEDIUM…/integration/tests/custom/GroupingSetsQueriesTest.java346 /// is robust to either choice.COMMENT
MEDIUM…gment/local/segment/index/loader/BaseIndexHandler.java42/// postUpdateIndicesCleanup() method. For [IndexHandler] classes which do not utilize the forward index or do notCOMMENT
MEDIUM…t/segment/local/io/util/FixedBitIntReaderWriterV2.java67 /// leverage the underlying bulk contiguous API as much as possible toCOMMENT
MEDIUM…segment/local/utils/SegmentOperationsThrottlerSet.java36/// Code paths that do not need to download or rebuild the index or which don't happen on the server need not utilizeCOMMENT
Hyper-Verbose Identifiers28 hits · 26 pts
SeverityFileLineSnippetContext
LOW…ot/broker/requesthandler/TimeSeriesRequestHandler.java88public class TimeSeriesRequestHandler extends BaseBrokerRequestHandler {CODE
LOW…ot/broker/requesthandler/BaseBrokerRequestHandler.java79public abstract class BaseBrokerRequestHandler implements BrokerRequestHandler {CODE
LOW…ker/requesthandler/MultiStageBrokerRequestHandler.java117public class MultiStageBrokerRequestHandler extends BaseBrokerRequestHandler {CODE
LOW…questhandler/SingleConnectionBrokerRequestHandler.java69public class SingleConnectionBrokerRequestHandler extends BaseSingleStageBrokerRequestHandler {CODE
LOW…ot/broker/requesthandler/GrpcBrokerRequestHandler.java59public class GrpcBrokerRequestHandler extends BaseSingleStageBrokerRequestHandler {CODE
LOW…equesthandler/BaseSingleStageBrokerRequestHandler.java147public abstract class BaseSingleStageBrokerRequestHandler extends BaseBrokerRequestHandler {CODE
LOW…a/manager/realtime/RealtimeSegmentDataManagerTest.java1351 public static class FakeRealtimeSegmentDataManager extends RealtimeSegmentDataManager implements Closeable {CODE
LOW…ata/manager/realtime/RealtimeTableDataManagerTest.java78 class FakeRealtimeTableDataManager extends RealtimeTableDataManager {CODE
LOW…ore/data/manager/realtime/ConsumerCoordinatorTest.java41 private static class FakeRealtimeTableDataManager extends RealtimeTableDataManager {CODE
LOW…pache/pinot/core/transport/InstanceRequestHandler.java68public class InstanceRequestHandler extends SimpleChannelInboundHandler<ByteBuf> {CODE
LOW…che/pinot/core/data/manager/DuoSegmentDataManager.java32public class DuoSegmentDataManager extends SegmentDataManager {CODE
LOW…ache/pinot/core/data/manager/BaseTableDataManager.java133public abstract class BaseTableDataManager implements TableDataManager {CODE
LOW…re/data/manager/realtime/RealtimeTableDataManager.java96public class RealtimeTableDataManager extends BaseTableDataManager {CODE
LOW…/data/manager/realtime/RealtimeSegmentDataManager.java129public class RealtimeSegmentDataManager extends SegmentDataManager {CODE
LOW…re/data/manager/offline/DimensionTableDataManager.java60public class DimensionTableDataManager extends OfflineTableDataManager {CODE
LOW…core/data/manager/offline/OfflineTableDataManager.java38public class OfflineTableDataManager extends BaseTableDataManager {CODE
LOW…/data/manager/offline/ImmutableSegmentDataManager.java26public class ImmutableSegmentDataManager extends SegmentDataManager {CODE
LOW…not/server/starter/helix/HelixInstanceDataManager.java86public class HelixInstanceDataManager implements InstanceDataManager {CODE
LOW…me/utils/FailureInjectingRealtimeTableDataManager.java40public class FailureInjectingRealtimeTableDataManager extends RealtimeTableDataManager {CODE
LOW…/utils/FailureInjectingRealtimeSegmentDataManager.java40public class FailureInjectingRealtimeSegmentDataManager extends RealtimeSegmentDataManager {CODE
LOWscripts/update-release-binaries.py640def find_orphaned_license_files(CODE
LOWscripts/update-release-binaries.py834def generate_updated_license_binary(CODE
LOWscripts/update-release-binaries.py597def check_version_bump_license_changes(CODE
LOWscripts/update-release-binaries.py1093def extract_notices_from_jars(deps: Set[Dep], m2_repo: Path) -> List[Tuple[str, str]]:STRING
LOW…/Homepage/Operations/AddRealTimeIngestionComponent.tsx45export default function AddRealTimeIngestionComponent({CODE
LOW…ents/Homepage/Operations/AddOfflineTenantComponent.tsx50export default function AddOfflineTenantComponent({CODE
LOW…ts/Homepage/Operations/AddRealTimePartionComponent.tsx46export default function AddRealTimePartionComponent({CODE
LOW…not/segment/local/data/manager/SegmentDataManager.java29public abstract class SegmentDataManager {CODE
Fake / Example Data10 hits · 12 pts
SeverityFileLineSnippetContext
LOW…ot/core/data/function/GroovyFunctionEvaluatorTest.java176 genericRow5, "John Doe"CODE
LOW…org/apache/pinot/client/DynamicBrokerSelectorTest.java130 _dynamicBrokerSelectorUnderTest.handleDataChange("dummy-data-path", "dummy-date");CODE
LOW…org/apache/pinot/client/DynamicBrokerSelectorTest.java140 _dynamicBrokerSelectorUnderTest.handleDataChange("dummy-data-path", "dummy-date");CODE
LOW…rg/apache/pinot/client/AbstractJdbcDriverAuthTest.java207 props.setProperty("headers.X-Dummy-Header-1", "dummy-value-1");CODE
LOW…rg/apache/pinot/client/AbstractJdbcDriverAuthTest.java208 props.setProperty("headers.X-Dummy-Header-2", "dummy-value-2");CODE
LOW…rg/apache/pinot/client/AbstractJdbcDriverAuthTest.java218 assertEquals(headers.get("X-Dummy-Header-1"), "dummy-value-1",CODE
LOW…rg/apache/pinot/client/AbstractJdbcDriverAuthTest.java222 assertEquals(headers.get("X-Dummy-Header-2"), "dummy-value-2",CODE
LOW…che/pinot/common/function/scalar/UrlFunctionsTest.java366 assertEquals(UrlFunctions.urlNetloc("https://user@example.com/path"), "user@example.com");CODE
LOW…ache/pinot/common/audit/AuditIdentityResolverTest.java69 when(_requestContext.getHeaderString("X-User-Email")).thenReturn("user@example.com");CODE
LOW…ache/pinot/common/audit/AuditIdentityResolverTest.java74 assertThat(result.getPrincipal()).isEqualTo("user@example.com");CODE
TODO Padding8 hits · 11 pts
SeverityFileLineSnippetContext
LOW…che/pinot/core/query/request/context/QueryContext.java737 // TODO: Add validation logic hereCOMMENT
LOW…rter/helix/IngestionBasedConsumptionStatusChecker.java167 // TODO: implement a way to have this work correctly for kafka consumersCOMMENT
LOW…in/java/org/apache/pinot/spi/plugin/PluginManager.java306 // TODO: implement the self-declaring META-INF/pinot-realm-exports mechanism.COMMENT
LOW…t/integration/tests/OfflineClusterIntegrationTest.java3311 // TODO: Add test to delete broker instance. Currently, stopBroker() does not work correctly.COMMENT
LOW…tion/tests/ControllerPeriodicTasksIntegrationTest.java70// TODO: Add tests for other ControllerPeriodicTasks (RetentionManager, RealtimeSegmentValidationManager).COMMENT
LOW…ache/pinot/controller/recommender/io/InputManager.java591 return 0; //TODO: implement this after the complex is supportedCODE
LOW…ache/pinot/controller/recommender/io/InputManager.java611 return 0; //TODO: implement this after the complex is supportedCODE
LOW…ache/pinot/controller/recommender/io/InputManager.java625 //TODO: implement this after the complex is supportedCOMMENT
Synthetic Comment Markers1 hit · 8 pts
SeverityFileLineSnippetContext
HIGH…core/executor/ThrottleOnCriticalHeapUsageExecutor.java493 /// Also handles config parsing and logging as requested in review.COMMENT
Magic Placeholder Names1 hit · 5 pts
SeverityFileLineSnippetContext
HIGH…/src/main/java/org/apache/pinot/client/admin/README.md264 "X-API-Key", "your-api-key",CODE
Redundant / Tautological Comments6 hits · 4 pts
SeverityFileLineSnippetContext
LOWscripts/update-release-binaries.py429 # Check if this line is a dash-underline (indicating previous line was a header)COMMENT
LOWscripts/update-release-binaries.py906 # Check if previous non-blank line is a section nameCOMMENT
LOWscripts/update-release-binaries.py949 # Check if removedCOMMENT
LOWscripts/update-release-binaries.py954 # Check if version changedCOMMENT
LOWscripts/update-release-binaries.py972 # Check if this could be a section header (next line might be dashes)COMMENT
LOWscripts/update-release-binaries.py1161 # Check if next line is the ASF URL lineSTRING
Deep Nesting8 hits · 4 pts
SeverityFileLineSnippetContext
LOWscripts/update-release-binaries.py198CODE
LOWscripts/update-release-binaries.py260CODE
LOWscripts/update-release-binaries.py349CODE
LOWscripts/update-release-binaries.py539CODE
LOWscripts/update-release-binaries.py834CODE
LOWscripts/update-release-binaries.py1093CODE
LOWscripts/update-release-binaries.py1141CODE
LOWscripts/update-release-binaries.py1265CODE
Excessive Try-Catch Wrapping2 hits · 3 pts
SeverityFileLineSnippetContext
LOW…/src/main/resources/scripts/timeseries/run_ts_query.py48 except Exception as e:CODE
MEDIUM…/src/main/resources/scripts/timeseries/run_ts_query.py44def read_query_file(path, logger):CODE
Slop Phrases1 hit · 3 pts
SeverityFileLineSnippetContext
MEDIUM…controller/recommender/rules/impl/SegmentSizeRule.java50/// It's worth noting that since this rule gets executed before other rules, we run into chicken-egg problem.COMMENT
Unused Imports1 hit · 0 pts
SeverityFileLineSnippetContext
LOWscripts/update-release-binaries.py55CODE
AI Structural Patterns1 hit · 0 pts
SeverityFileLineSnippetContext
LOWscripts/update-release-binaries.py1186CODE