Repository Analysis

apache/pinot

Apache Pinot - A realtime distributed OLAP datastore

3.9 Likely human-written View on GitHub

Analysis Overview

This report presents the forensic synthetic code analysis of apache/pinot, a Java project with 6,106 GitHub stars. SynthScan v2.0 examined 1,369,192 lines of code across 6748 source files, recording 1634 pattern matches distributed across 18 syntactic categories. The overall adjusted score of 3.9 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).

3.9
Adjusted Score
3.9
Raw Score
100%
Time Factor
2026-07-14
Last Push
6.1K
Stars
Java
Language
1.4M
Lines of Code
6.7K
Files
1.6K
Pattern Hits
2026-07-14
Scan Date
0.04
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

Longitudinal tracking requires multiple scan runs. Once this repository is re-scanned after new commits land, this chart will visualise how the synthetic code signal evolves over time — enabling you to detect whether AI authorship is growing, stabilising, or being actively corrected by human engineers.

No multi-scan history yet — run the scanner again to build trend data.

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 301HIGH 1MEDIUM 110LOW 1222

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 1634 distinct pattern matches across 18 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 Indicators301 hits · 3585 pts
SeverityFileLineSnippetContext
CRITICAL…pache/pinot/calcite/rel/rules/PinotFilterJoinRule.java81 com.google.common.collect.ImmutableList.copyOf(origAboveFilters), joinType);CODE
CRITICAL…sthandler/BaseSingleStageBrokerRequestHandlerTest.java696 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…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.java83 + "org.apache.pinot.tools.admin.PinotAdministrator.main(args); 2})",CODE
CRITICAL…ot/core/data/function/GroovyFunctionEvaluatorTest.java196 "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.java1271 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.java244 // @see org.glassfish.jersey.grizzly2.httpserver.GrizzlyHttpServerFactory.createHttpServer(java.net.URI, orgCOMMENT
CRITICAL…ava/org/apache/pinot/core/common/ObjectSerDeUtils.java1176 return org.apache.datasketches.tuple.Sketches.heapifySketch(Memory.wrap(bytes),CODE
CRITICAL…ava/org/apache/pinot/core/common/ObjectSerDeUtils.java1184 return org.apache.datasketches.tuple.Sketches.heapifySketch(Memory.wrap(bytes),CODE
CRITICAL…ava/org/apache/pinot/core/common/ObjectSerDeUtils.java1770 org.apache.datasketches.tuple.Sketches.heapifySketch(Memory.wrap(bytes),CODE
CRITICAL…unction/DistinctCountCPCSketchAggregationFunction.java678 return org.apache.datasketches.common.Util.exactLog2OfInt(_nominalEntries);CODE
CRITICAL…ier/src/main/java/org/apache/pinot/compat/TableOp.java165 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…ache/pinot/server/predownload/PredownloadZKClient.java175 if (!CommonConstants.Helix.StateModel.SegmentStateModel.ONLINE.equals(entry.getValue())) {CODE
CRITICAL…/apache/pinot/server/api/resources/TablesResource.java596 File segmentTarFile = org.apache.pinot.common.utils.FileUtils.concatAndValidateFile(tmpSegmentTarDir,CODE
CRITICAL…/apache/pinot/server/api/resources/TablesResource.java1154 File segmentTarFile = org.apache.pinot.common.utils.FileUtils.concatAndValidateFile(segmentTarUploadDir,CODE
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…on-tests/src/test/resources/udf-test-results/plus.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
CRITICAL…ts/src/test/resources/udf-test-results/todatetime.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
CRITICAL…ion-tests/src/test/resources/udf-test-results/and.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
CRITICAL…on-tests/src/test/resources/udf-test-results/year.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
CRITICAL…test/resources/udf-test-results/arrayconcatdouble.yaml21# Use the org.apache.pinot.integration.tests.udfUdfTest.generateSnapshots() method to regenerate it.COMMENT
241 more matches not shown…
Over-Commented Block859 hits · 842 pts
SeverityFileLineSnippetContext
LOW.asf.yaml1#COMMENT
LOW.codecov.yml1#COMMENT
LOW…inot/query/planner/physical/v2/LookupJoinPlanTest.java181COMMENT
LOW…pache/pinot/calcite/rel/rules/PinotFilterJoinRule.java121 }COMMENT
LOW…te/rel/rules/PinotAggregateExchangeNodeInsertRule.java481 private static boolean isGroupTrimmingEnabled(RelOptRuleCall call, Map<String, String> hintOptions,COMMENT
LOW…g/apache/pinot/calcite/sql/fun/PinotOperatorTable.java301 OperandTypes.family(List.of(SqlTypeFamily.ARRAY, SqlTypeFamily.ARRAY, SqlTypeFamily.NUMERIC), i -> i == 2)),COMMENT
LOW…t/query/planner/physical/MailboxAssignmentVisitor.java81 } else {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…ot/query/planner/logical/PinotLogicalQueryPlanner.java81// for (Map.Entry<Integer, PlanNode> subPlanEntry : subPlanContext._subPlanIdToRootNodeMap.entrySet()) {COMMENT
LOW…inot/query/planner/logical/EquivalentStagesFinder.java121COMMENT
LOW…org/apache/pinot/query/planner/rules/PinotRuleSet.java41/// 2. For every [RuleSetCustomizer] (in supplied order), callCOMMENT
LOW…ker/routing/instanceselector/InstanceSelectorTest.java321 balancedInstanceSelector.init(_tableConfig, propertyStore, brokerMetrics, null, Clock.systemUTC(),COMMENT
LOW…ker/routing/instanceselector/InstanceSelectorTest.java361 assertTrue(selectionResult.getUnavailableSegments().isEmpty());COMMENT
LOW…ker/routing/instanceselector/InstanceSelectorTest.java401 replicaGroupInstanceSelector.onInstancesChange(enabledInstances, List.of(instance0));COMMENT
LOW…ker/routing/instanceselector/InstanceSelectorTest.java501 expectedReplicaGroupInstanceSelectorResult.put(segment2, instance1);COMMENT
LOW…ker/routing/instanceselector/InstanceSelectorTest.java541 // segment4 is a newly added segment with 3 online instances in idealStage and 2 online instances in externalView.COMMENT
LOW…ker/routing/instanceselector/InstanceSelectorTest.java641 selectionResult = replicaGroupInstanceSelector.select(brokerRequest, segments, requestId);COMMENT
LOW…ker/routing/instanceselector/InstanceSelectorTest.java681 Map<String, String> externalViewInstanceStateMap2 = new TreeMap<>();COMMENT
LOW…ker/routing/instanceselector/InstanceSelectorTest.java901 // segment3 -> instance0COMMENT
LOW…ker/routing/instanceselector/InstanceSelectorTest.java1061 // Iterate 5 timesCOMMENT
LOW…ker/routing/instanceselector/InstanceSelectorTest.java1081 selectionResult = strictReplicaGroupInstanceSelector.select(brokerRequest, segments, 0);COMMENT
LOW…ker/routing/instanceselector/InstanceSelectorTest.java1141 balancedInstanceSelector.onAssignmentChange(idealState, externalView, onlineSegments);COMMENT
LOW…ker/routing/instanceselector/InstanceSelectorTest.java1221 // (Note that for StrictReplicaGroupInstanceSelector, segment1 but it is old so it will mark instance down forCOMMENT
LOW…ker/routing/instanceselector/InstanceSelectorTest.java1241 assertEquals(selectionResult.getUnavailableSegments(), Arrays.asList(segment0, segment1));COMMENT
LOW…ker/routing/instanceselector/InstanceSelectorTest.java1261 assertTrue(selectionResult.getSegmentToInstanceMap().isEmpty());COMMENT
LOW…he/pinot/broker/requesthandler/EmptyResponseUtils.java161 }COMMENT
LOW…ker/requesthandler/MultiStageBrokerRequestHandler.java121 /// Disabled by default, but can be enabled withCOMMENT
LOW…ker/requesthandler/MultiStageBrokerRequestHandler.java361 // If the error code is not recognized, does nothingCOMMENT
LOW…ker/requesthandler/MultiStageBrokerRequestHandler.java381 /// - The error message and part of the stack trace will be sent to the user and the error message will be loggedCOMMENT
LOW…equesthandler/BaseSingleStageBrokerRequestHandler.java561 routeProvider = _implicitHybridTableRouteProvider;COMMENT
LOW…equesthandler/BaseSingleStageBrokerRequestHandler.java921 // - Alias handlingCOMMENT
LOW…equesthandler/BaseSingleStageBrokerRequestHandler.java1201 _tableName = tableName;COMMENT
LOW…equesthandler/BaseSingleStageBrokerRequestHandler.java1221 /// multi-cluster routing map. Without this early-exit, a FULL_REWRITE swap would turn aCOMMENT
LOW…equesthandler/BaseSingleStageBrokerRequestHandler.java2641 /// Processes an MV-split query by issuing two independent scatter-gather requests - one to theCOMMENT
LOW…ker/routing/instanceselector/BaseInstanceSelector.java61///COMMENT
LOW…routing/instanceselector/BalancedInstanceSelector.java21import java.util.HashMap;COMMENT
LOW…te/equivalence/AggregationEquivalenceRegistryTest.java21import org.testng.annotations.Test;COMMENT
LOW…ializedview/metadata/MaterializedViewMetadataTest.java161 /// znode from a prior failed CREATE doesn't get classified as "different content".COMMENT
LOW…va/org/apache/pinot/materializedview/package-info.java21/// are produced by a saved SQL query against one or more base Pinot tables. The MV isCOMMENT
LOW…va/org/apache/pinot/materializedview/package-info.java41/// and generates `PinotTaskConfig`s.COMMENT
LOW…va/org/apache/pinot/materializedview/package-info.java61///COMMENT
LOW…lizedview/handler/MaterializedViewSplitDispatcher.java41 /// always-false-filter pruning), builds the MV-side broker request and route, then issues twoCOMMENT
LOW…/materializedview/handler/MaterializedViewHandler.java21import org.apache.helix.store.zk.ZkHelixPropertyStore;COMMENT
LOW…/materializedview/handler/MaterializedViewHandler.java41/// scatter-gather, and merging the results.COMMENT
LOW…/materializedview/handler/MaterializedViewHandler.java81 /// model on ONLINE→OFFLINE / ONLINE→DROPPED transitions.COMMENT
LOW…/materializedview/handler/MaterializedViewHandler.java101 }COMMENT
LOW…pache/pinot/materializedview/handler/package-info.java21///COMMENT
LOW…pache/pinot/materializedview/handler/package-info.java41///COMMENT
LOW…terializedview/rewrite/MaterializedViewQueryShape.java21import java.util.List;COMMENT
LOW…edview/rewrite/MaterializedViewQueryRewriteEngine.java41///COMMENT
LOW…edview/rewrite/MaterializedViewQueryRewriteEngine.java181 /// partition map is permitted — V1 routing uses `watermarkMs` as the split point, so theCOMMENT
LOW…edview/rewrite/MaterializedViewQueryRewriteEngine.java221 ///COMMENT
LOW…terializedview/rewrite/MaterializedViewMatchUtils.java41/// from the broker hot path. Future contributors adding caching to any method must preserveCOMMENT
LOW…terializedview/rewrite/MaterializedViewMatchUtils.java61 if (func != null && "as".equals(func.getOperator())) {COMMENT
LOW…terializedview/rewrite/MaterializedViewMatchUtils.java121 /// @param expr a SELECT-list expression from the user's queryCOMMENT
LOW…terializedview/rewrite/MaterializedViewMatchUtils.java181 return null;COMMENT
LOW…terializedview/rewrite/MaterializedViewMatchUtils.java201 /// **TODO(materialized-view): OR / IN subsumption is currently correctness-safe but conservative.**COMMENT
LOW…terializedview/rewrite/MaterializedViewMatchUtils.java281 return RequestUtils.getFunctionExpression(FilterKind.AND.name(), operands);COMMENT
LOW…terializedview/rewrite/MaterializedViewMatchUtils.java341 }COMMENT
LOW…ializedview/rewrite/MaterializedViewMetadataCache.java81 /// runtime znode listener may fire ahead of the definition znode listener. Dropping theCOMMENT
799 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.java142 // ─── helpers ──────────────────────────────────────────────────────────────────COMMENT
MEDIUM…gration/tests/StreamStatsReportingIntegrationTest.java176 // ─── tests ────────────────────────────────────────────────────────────────────COMMENT
MEDIUM…gration/tests/StreamStatsReportingIntegrationTest.java463 // ─── 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 Overuse115 hits · 205 pts
SeverityFileLineSnippetContext
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java595 // Step 1: Get LogicalTableRouteInfo using LogicalTableRouteProviderCOMMENT
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java603 // Step 2: Build broker requests for route calculationCOMMENT
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java617 // Step 3: Calculate routesCOMMENT
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java621 // Step 4: Build worker assignment from LogicalTableRouteInfoCOMMENT
LOW…uting/manager/BrokerRoutingManagerConcurrencyTest.java408 // Step 1: Build OFFLINE table first - should not have TimeBoundaryManagerCOMMENT
LOW…uting/manager/BrokerRoutingManagerConcurrencyTest.java417 // 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.java87 /// Step 1: shape gateCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java95 /// Step 2: GROUP BYCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java101 /// Step 3: projection subsumption — use the projection map cached on the entry.COMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java108 /// Step 4: WHERE matching + residual extraction (shared logic)COMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java143 /// Step 5: residual validation (subclass-specific)COMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java149 /// Step 6: ORDER BYCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java155 /// Step 7: HAVINGCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java161 /// Step 8: build resultCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java141 // Step 2: source table existence and time-column checksCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java147 // Step 3: MV schema column completeness (including dateTime columns)COMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java150 // Step 5: extract and validate time column transformation mappings.COMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java157 // Step 6: MV time column (segmentsConfig.timeColumnName) must be wired to a SELECT-producedCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java164 // Step 7: MV time column shape + type. TIMESTAMP-only contract: both base and MV timeCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java112 // Step 1: SQL syntax and Pinot semantic validationCOMMENT
LOW…lizedview/scheduler/MaterializedViewTaskScheduler.java343 /// Step 1: Finds the earliest STALE partition and dispatches the appropriate task.COMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java134 // Step 1: Convert output range to millis rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java217 // Step 2: Convert millis range to input rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java253 // Step 3: Rewrite the filter functionCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java297 // Step 1: Convert output range to millis rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java386 // Step 2: Convert millis range to input rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java422 // Step 3: Rewrite the filter functionCOMMENT
LOW…not/core/query/executor/ServerQueryExecutorV1Impl.java328 // NOTE: This method might change indexSegments. Do not use it after calling this method.COMMENT
LOW…java/org/apache/pinot/spi/filesystem/LocalPinotFS.java217 // Step 1: Copy the file or directory into the temporary fileCOMMENT
LOW…java/org/apache/pinot/spi/filesystem/LocalPinotFS.java233 // Step 2: Rename the temporary file to the destination fileCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java627 /// Step 1: Verify MV is currently hit (precondition; SLO disabled).COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java633 /// Step 2: Tighten the SLO on the MV definition. watermarkMs = DATA_MAX_TIME_MS is aCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java514 /// Step 1: baseline — split query before the simulated overlap.COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java527 /// Step 2: simulate endSegmentReplace without postProcess — upload MV segmentsCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java569 /// Step 3: rerun the split query. With the materializedViewTime < watermarkMs filterCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java656 /// Step 3: Query again — the MV should NOT be hit (SLO trips eligibility gate).COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java671 /// Step 4: Disable the SLO again by setting stalenessThresholdMs back to 0.COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java686 /// 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.java537 // NOTE: This method is only meant to retain compatibility of serialization for endpoint:COMMENT
55 more matches not shown…
Verbosity Indicators114 hits · 203 pts
SeverityFileLineSnippetContext
LOW…t/query/planner/physical/v2/PRelNodeTreeValidator.java56 // If joins are disabled in lite mode, we need to check if the plan contains joinsCOMMENT
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java595 // Step 1: Get LogicalTableRouteInfo using LogicalTableRouteProviderCOMMENT
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java603 // Step 2: Build broker requests for route calculationCOMMENT
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java617 // Step 3: Calculate routesCOMMENT
LOW…ysical/v2/opt/rules/LeafStageWorkerAssignmentRule.java621 // Step 4: Build worker assignment from LogicalTableRouteInfoCOMMENT
LOW…uting/manager/BrokerRoutingManagerConcurrencyTest.java408 // Step 1: Build OFFLINE table first - should not have TimeBoundaryManagerCOMMENT
LOW…uting/manager/BrokerRoutingManagerConcurrencyTest.java417 // 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.java87 /// Step 1: shape gateCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java95 /// Step 2: GROUP BYCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java101 /// Step 3: projection subsumption — use the projection map cached on the entry.COMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java108 /// Step 4: WHERE matching + residual extraction (shared logic)COMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java143 /// Step 5: residual validation (subclass-specific)COMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java149 /// Step 6: ORDER BYCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java155 /// Step 7: HAVINGCOMMENT
LOW…view/rewrite/strategy/AbstractSubsumptionStrategy.java161 /// Step 8: build resultCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java141 // Step 2: source table existence and time-column checksCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java147 // Step 3: MV schema column completeness (including dateTime columns)COMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java150 // Step 5: extract and validate time column transformation mappings.COMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java157 // Step 6: MV time column (segmentsConfig.timeColumnName) must be wired to a SELECT-producedCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java164 // Step 7: MV time column shape + type. TIMESTAMP-only contract: both base and MV timeCOMMENT
LOW…aterializedview/analysis/MaterializedViewAnalyzer.java112 // Step 1: SQL syntax and Pinot semantic validationCOMMENT
LOW…lizedview/scheduler/MaterializedViewTaskScheduler.java343 /// Step 1: Finds the earliest STALE partition and dispatches the appropriate task.COMMENT
LOW…/apache/pinot/query/runtime/operator/LeafOperator.java602 * 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.java293 // When maxStepDuration > 0, we need to check if the event_to_add has a timestamp within the max durationCOMMENT
LOW…indow/FunnelEventsFunctionEvalAggregationFunction.java422 // When maxStepDuration > 0, we need to check if the event_to_add has a timestamp within the max durationCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java134 // Step 1: Convert output range to millis rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java217 // Step 2: Convert millis range to input rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java253 // Step 3: Rewrite the filter functionCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java297 // Step 1: Convert output range to millis rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java386 // Step 2: Convert millis range to input rangeCOMMENT
LOW…ery/optimizer/filter/TimePredicateFilterOptimizer.java422 // Step 3: Rewrite the filter functionCOMMENT
LOW…java/org/apache/pinot/spi/filesystem/LocalPinotFS.java217 // Step 1: Copy the file or directory into the temporary fileCOMMENT
LOW…java/org/apache/pinot/spi/filesystem/LocalPinotFS.java233 // Step 2: Rename the temporary file to the destination fileCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java627 /// Step 1: Verify MV is currently hit (precondition; SLO disabled).COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java633 /// Step 2: Tighten the SLO on the MV definition. watermarkMs = DATA_MAX_TIME_MS is aCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java514 /// Step 1: baseline — split query before the simulated overlap.COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java527 /// Step 2: simulate endSegmentReplace without postProcess — upload MV segmentsCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java569 /// Step 3: rerun the split query. With the materializedViewTime < watermarkMs filterCOMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java656 /// Step 3: Query again — the MV should NOT be hit (SLO trips eligibility gate).COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java671 /// Step 4: Disable the SLO again by setting stalenessThresholdMs back to 0.COMMENT
LOW…tion/tests/MaterializedViewClusterIntegrationTest.java686 /// 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
54 more matches not shown…
Example Usage Blocks71 hits · 106 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…pi/src/test/resources/ingestion_job_spec_template.yaml31# Sample 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
LOW…ces/examples/batch/baseballStats/ingestionJobSpec.yaml54# Sample usage:COMMENT
LOW…xamples/batch/baseballStats/sparkIngestionJobSpec.yaml49# Sample usage:COMMENT
11 more matches not shown…
Self-Referential Comments20 hits · 59 pts
SeverityFileLineSnippetContext
MEDIUM…ration-tests/src/test/resources/ssb/ssb_query_set.yaml20# This function defines the test set of SSB queriesCOMMENT
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…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…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…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/degrees.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
Hyper-Verbose Identifiers28 hits · 26 pts
SeverityFileLineSnippetContext
LOW…ot/broker/requesthandler/TimeSeriesRequestHandler.java88public class TimeSeriesRequestHandler extends BaseBrokerRequestHandler {CODE
LOW…ot/broker/requesthandler/BaseBrokerRequestHandler.java77public abstract class BaseBrokerRequestHandler implements BrokerRequestHandler {CODE
LOW…ker/requesthandler/MultiStageBrokerRequestHandler.java119public class MultiStageBrokerRequestHandler extends BaseBrokerRequestHandler {CODE
LOW…questhandler/SingleConnectionBrokerRequestHandler.java71public class SingleConnectionBrokerRequestHandler extends BaseSingleStageBrokerRequestHandler {CODE
LOW…ot/broker/requesthandler/GrpcBrokerRequestHandler.java61public class GrpcBrokerRequestHandler extends BaseSingleStageBrokerRequestHandler {CODE
LOW…equesthandler/BaseSingleStageBrokerRequestHandler.java144public abstract class BaseSingleStageBrokerRequestHandler extends BaseBrokerRequestHandler {CODE
LOW…a/manager/realtime/RealtimeSegmentDataManagerTest.java1367 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.java70public class InstanceRequestHandler extends SimpleChannelInboundHandler<ByteBuf> {CODE
LOW…che/pinot/core/data/manager/DuoSegmentDataManager.java34public 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.java97public class RealtimeTableDataManager extends BaseTableDataManager {CODE
LOW…/data/manager/realtime/RealtimeSegmentDataManager.java131public class RealtimeSegmentDataManager extends SegmentDataManager {CODE
LOW…re/data/manager/offline/DimensionTableDataManager.java63public class DimensionTableDataManager extends OfflineTableDataManager {CODE
LOW…core/data/manager/offline/OfflineTableDataManager.java40public class OfflineTableDataManager extends BaseTableDataManager {CODE
LOW…/data/manager/offline/ImmutableSegmentDataManager.java28public class ImmutableSegmentDataManager extends SegmentDataManager {CODE
LOW…not/server/starter/helix/HelixInstanceDataManager.java88public class HelixInstanceDataManager implements InstanceDataManager {CODE
LOW…me/utils/FailureInjectingRealtimeTableDataManager.java40public class FailureInjectingRealtimeTableDataManager extends RealtimeTableDataManager {CODE
LOW…/utils/FailureInjectingRealtimeSegmentDataManager.java41public 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.java31public abstract class SegmentDataManager {CODE
AI Slop Vocabulary5 hits · 15 pts
SeverityFileLineSnippetContext
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…/connector/spark/v3/datasource/PinotWriteBuilder.scala31 // TODO: utilize filtersCOMMENT
MEDIUM…inot/integration/tests/UpsertTableIntegrationTest.java190 // fashion, but query more times to be more robust)COMMENT
MEDIUM…inot/integration/tests/UpsertTableIntegrationTest.java209 // 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
Fake / Example Data10 hits · 12 pts
SeverityFileLineSnippetContext
LOW…ot/core/data/function/GroovyFunctionEvaluatorTest.java178 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.java215 props.setProperty("headers.X-Dummy-Header-1", "dummy-value-1");CODE
LOW…rg/apache/pinot/client/AbstractJdbcDriverAuthTest.java216 props.setProperty("headers.X-Dummy-Header-2", "dummy-value-2");CODE
LOW…rg/apache/pinot/client/AbstractJdbcDriverAuthTest.java226 assertEquals(headers.get("X-Dummy-Header-1"), "dummy-value-1",CODE
LOW…rg/apache/pinot/client/AbstractJdbcDriverAuthTest.java230 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.java801 // TODO: Add validation logic hereCOMMENT
LOW…rter/helix/IngestionBasedConsumptionStatusChecker.java169 // TODO: implement a way to have this work correctly for kafka consumersCOMMENT
LOW…in/java/org/apache/pinot/spi/plugin/PluginManager.java310 // TODO: implement the self-declaring META-INF/pinot-realm-exports mechanism.COMMENT
LOW…t/integration/tests/OfflineClusterIntegrationTest.java3241 // TODO: Add test to delete broker instance. Currently, stopBroker() does not work correctly.COMMENT
LOW…tion/tests/ControllerPeriodicTasksIntegrationTest.java72// TODO: Add tests for other ControllerPeriodicTasks (RetentionManager, RealtimeSegmentValidationManager).COMMENT
LOW…ache/pinot/controller/recommender/io/InputManager.java607 return 0; //TODO: implement this after the complex is supportedCODE
LOW…ache/pinot/controller/recommender/io/InputManager.java627 return 0; //TODO: implement this after the complex is supportedCODE
LOW…ache/pinot/controller/recommender/io/InputManager.java641 //TODO: implement this after the complex is supportedCOMMENT
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.java51 * 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