This is an automated email from the ASF dual-hosted git repository.
dependabot[bot] pushed a change to branch
dependabot/maven/net.java.dev.javacc-javacc-7.0.13
in repository https://gitbox.apache.org/repos/asf/pinot.git
discard 64ef0e6988b Bump net.java.dev.javacc:javacc from 5.0 to 7.0.13
add 7ee50a8d59b Bump org.asynchttpclient:async-http-client from 3.0.8 to
3.0.9 (#18180)
add fa7dbebbb8a Bump com.microsoft.azure:msal4j from 1.24.0 to 1.24.1
(#18181)
add 31eac8363ff Bump software.amazon.awssdk:bom from 2.42.32 to 2.42.33
(#18182)
add aa483d33a3f Add TableConfigValidator and InstanceConfigValidator SPI
for batch restart enforcement (#18167)
add 9ca894363ec Allow CastTypeAliasRewriter to recurse into nested CAST
operands to fix upgrade incompatibility issue (#18153)
add 4f4298c16e4 Bump software.amazon.awssdk:bom from 2.42.33 to 2.42.34
(#18194)
add d29972964b1 Bump bouncycastle.version from 1.83 to 1.84 (#18193)
add a200db21670 Push element length, ASCII, and sorted-values stats into
Dictionary implementations (#18189)
add e85fcd35c4e Add polymorphic window functions (#18169)
add d3063c0553a Bump axios from 0.30.3 to 1.15.0 in
/pinot-controller/src/main/resources (#18155)
add c9027e950c3 Bump follow-redirects in
/pinot-controller/src/main/resources (#18196)
add 9ff14da6dbc Fix NPE in ServerGrpcChannelBackoffResetHandler (#18139)
add 9a580ddbd9d Deprecate padding character check in ColumnMetadataImpl
(#18200)
add da908b0f6f7 [bugfix] Clear realtime inverted index bitmaps on close
(#18204)
add 8e678644a76 Overhaul Docker base images and release workflows (#18178)
add fe112388768 fix: replace disallowed third-party GitHub Actions with
shell equivalents (ASF compliance) (#18209)
add 3cc19023dc8 Fix literal-only stages being scheduled on wrong tenant
servers (#18213)
add 0e8b4d83d28 Update DOAP file for release 1.5.0 (#18227)
add 68f213b5902 Fix typo in RefreshSegmentTaskExecutor TODO comment
(#18230)
add 76f2fdd63cd Bump com.google.cloud:libraries-bom from 26.79.0 to
26.80.0 (#18210)
add 87e09fd31f1 [refactor] Move FunctionEvaluator interface to pinot-spi
and implementations to pinot-common (#18208)
add b9897956e6c Track minion task generation logs based on id using mdc
(#18215)
add 932b406e079 Fix some comment typos and duplicated words (#18236)
add 1bf528ee3cd Bump io.opentelemetry.contrib:opentelemetry-gcp-resources
(#18235)
add 77ecc4cd0c8 Add time-range based segment reload to controller API
(#17627)
add e4a18a0927e [multistage] add lookup join support to physical optimizer
(#18158)
add f3c60379696 Fix duplicate FieldConfig when RAW column is also in
noDictionaryColumns (#18212)
add 3ab2dcade98 Accept any negative cardinality as unknown in
BloomIndexType (#18232)
add 57e779e3d46 [Flaky Test] Fix
ExactlyOnceKafkaRealtimeClusterIntegrationTest countRecords early termination
(#18238)
add 46cc680ee96 Add OOM pause mechanism to pause query threads before
killing on critical heap (#18163)
add c2a648ebb0f Promote validator registry reset() to public lifecycle API
and invoke from controller stop (#18240)
add af725a5ccab Bump org.webjars:swagger-ui from 5.32.2 to 5.32.4 (#18243)
add 4a501ab09a1 Bump software.amazon.awssdk:bom from 2.42.34 to 2.42.35
(#18244)
add d86660ab309 Bump org.apache.maven:maven-core from 3.9.14 to 3.9.15
(#18245)
add d5324027213 Update compatibility CI to release 1.5.0 (#18249)
add da906242985 Fix noisy logs in QueryDispatcher (#18246)
add ade9f6c3dc6 [codex] Upgrade Flink connector to Flink 2.2.0 for Java 21
(#18250)
add 7ae0861a2bf Fix AIOOBE in MapColumnPreIndexStatsCollector when all map
rows are empty (#18198)
add 85147cc3b1c Fix flaky PinotTaskManagerDistributedLockingTest cron race
(#18252)
add 9ad9c1b042c Support role-specific accounting config prefixes for
broker and server (#18251)
add fc680e68e5b Restrict nightly Docker build workflows to apache/pinot
(#18255)
add 0d67f47121e Fix flaky integration tests: prevent MSE port collisions
on rapid server starts (#18254)
add 5af58ec5124 Fix flaky
MergeRollupMinionClusterIntegrationTest.testRealtimeTableProcessAllModeMultiLevelConcat
(#18253)
add 3eff094baa2 feat: expose BrokerResponse to subclasses via overridable
onQueryCompletion hook (#18247)
add b5c9d2c4d7a Reject duplicate FieldConfig column names during table
config validation (#18211)
add 3ca4c332e72 Bump org.javassist:javassist from 3.30.2-GA to 3.31.0-GA
(#18265)
add b07f22b624b Bump org.apache.httpcomponents.client5:httpclient5 from
5.6 to 5.6.1 (#18266)
add 093e164216e Bump software.amazon.awssdk:bom from 2.42.35 to 2.42.36
(#18267)
add 5b0e3ff2d14 Add realtime integration test for
ProtoBufCodeGenMessageDecoder (#18234)
add 159f046dd1a Fix flaky MergeRollupMinionClusterIntegrationTest gauge
assertions (#18260)
add 8ed77aa91e1 Add support for handling scenarios where end time is
invalid during RetentionManager run (#18148)
add 91ed7305df4 [refactor] Decouple pinot-common test deps with
FakeMetrics + plugin subclass tests; add SettableValue.getValue() (#18259)
add 8b1ba5c3fa4 Bump software.amazon.awssdk:bom from 2.42.36 to 2.42.37
(#18274)
add bc42fe60e7f Re-enable old disabled query test and remove stale TODO
about agg without group by (#18269)
add eea63ad19ef Bump org.testcontainers:testcontainers-bom from 2.0.4 to
2.0.5 (#18273)
add 0607efe710d Add LeafOperator tests for aggregation, group-by, and
distinct result blocks (#18271)
add f7f18da2437 Export Adaptive Routing Stats as broker metrics (#18134)
add e217ca3f098 Add Claude Code skills for common developer workflows
(#18276)
add dc78809d480 Move cursor response cleanup from controller to broker and
add batch delete API (#17643) (#18203)
add d4f586655c5 Remove deprecated scheduleTasks wrapper methods from
PinotTaskManager (#18275)
add 5d48eeb3ea8 Add sender stage ID to error message in
BlockingMultiStreamConsumer; cleanup stale TODO (#18278)
add d65a645d841 Propagate task configuration to remote index buffers for
improved configuration resolution (#18264)
add 2d92c442fc2 Refactor: convert RealtimeOffsetAutoResetHandler to
interface with init(); fix nonLeaderCleanup (#18127)
add 9cd44c435e7 Add PercentileTDigest support for MergeAndRollup
aggregation (#18088)
add 81732e0fb75 Bump software.amazon.awssdk:bom from 2.42.37 to 2.42.38
(#18283)
add 7f0a4b6cd56 Upgrade code-reviewer to multi-agent orchestrator with 8
domain skills (#18284)
add 85cdc7cbf0b MSE resilience to silently unreachable servers (#18268)
add c137b75031a Add query test cases for LOOKUP join (#18279)
add 1d2d1919774 Fix memory leak in pinot client BrokerCache (#18290)
add 78e38eb1c20 Fix comment typos: succesfully→successfully, sould→should,
dont→don't (#18291)
add 8f7dafe2db3 Add round robin segment assignment strategies (#18270)
add 51e610d486b Add SOUNDEX and DIFFERENCE scalar functions for phonetic
string matching (#18293)
add 6797edc2822 [agent] Quote code-reviewer description to fix YAML
frontmatter (#18301)
add 73c89c72e02 make message handler pluggable (#18298)
add 57234efa195 minor(cleanup): fix 'occurence'/'seperate' typos in
comments and javadocs (#18302)
add 523926317a0 Clean up unused SegmentCreationDriverFactory (#18299)
add d36c9f3f578 Refactor ColumnMetadata SPI and simplify MapIndexReader
(#18280)
add 673828c7c2e Replace SingleValueVisitor/MultiValueVisitor with
per-predicate visitors (#18297)
add 6da39b46164 Fix false-positive "column deleted" stale check for
timestamp-index derived columns (#18294)
add 59f1006b8c4 Bump org.jetbrains.kotlin:kotlin-bom from 2.3.20 to 2.3.21
(#18306)
add a239cb3e63c Bump com.mchange:mchange-commons-java from 0.4.0 to 0.5.0
(#18307)
add 66ae77cc1af Bump software.amazon.awssdk:bom from 2.42.38 to 2.42.39
(#18304)
add b11fe9ef5ee Revert "Fix false-positive "column deleted" stale check
for timestamp-index d…" (#18309)
add 6b79b5726ad Bump com.gradle:common-custom-user-data-maven-extension
(#18305)
add 2a84fc7e313 Add `pinot_server_mse_queries` server metrics (#18287)
add e6bcd55f9c4 Bump net.java.dev.javacc:javacc from 5.0 to 7.0.13
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (64ef0e6988b)
\
N -- N -- N
refs/heads/dependabot/maven/net.java.dev.javacc-javacc-7.0.13 (e6bcd55f9c4)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
.claude/agents/code-reviewer.md | 123 +-
.claude/skills/README.md | 213 ++++
.claude/skills/bench-compare/SKILL.md | 107 ++
.claude/skills/flaky-analyze/SKILL.md | 117 ++
.claude/skills/precommit/SKILL.md | 82 ++
.claude/skills/quickstart/SKILL.md | 74 ++
.claude/skills/review-architecture/SKILL.md | 47 +
.claude/skills/review-concurrency-state/SKILL.md | 55 +
.claude/skills/review-config-backcompat/SKILL.md | 74 ++
.claude/skills/review-correctness-nulls/SKILL.md | 48 +
.claude/skills/review-naming-api/SKILL.md | 47 +
.claude/skills/review-performance/SKILL.md | 48 +
.claude/skills/review-process-scope/SKILL.md | 46 +
.claude/skills/review-testing/SKILL.md | 67 ++
.claude/skills/run-test/SKILL.md | 67 ++
.github/workflows/build-all-pinot-docker-image.yml | 128 +++
.../build-multi-arch-pinot-docker-image.yml | 105 --
.../workflows/build-pinot-base-docker-image.yml | 44 +-
.github/workflows/build-pinot-docker-image.yml | 17 +-
.github/workflows/build-superset-docker-image.yml | 10 +-
.../nightly-build-all-pinot-docker-image.yml | 122 ++
...htly-build-multi-arch-superset-docker-image.yml | 107 ++
.github/workflows/pinot_tests.yml | 4 +-
.github/workflows/pinot_vuln_check.yml | 32 +-
.github/workflows/scripts/.pinot_vuln_check.sh | 10 +-
.../.pinot_base_docker_image_build_and_push.sh | 8 +-
... .pinot_base_docker_manifest_build_and_push.sh} | 23 +-
.../scripts/docker/.pinot_build_info_gen.sh | 14 +-
.../docker/.pinot_compile_and_push_build_image.sh | 69 ++
.../scripts/docker/.pinot_docker_image_build.sh | 69 --
.../docker/.pinot_docker_image_build_and_push.sh | 16 +-
...not_multi_arch_docker_image_manifest_package.sh | 10 +-
.../docker/.pinot_package_single_platform.sh | 93 ++
.../.pinot_single_platform_docker_image_build.sh | 89 --
...erset_multi_arch_docker_image_build_and_push.sh | 59 -
.gitignore | 2 +
.mvn/extensions.xml | 2 +-
.../config/queries/feature-test-1-sql.queries | 3 +
.../query-results/feature-test-1-rest-sql.results | 3 +
doap_Pinot.rdf | 6 +-
.../pinot-base-build/amazoncorretto.dockerfile | 88 +-
.../pinot-base-build/ms-openjdk.dockerfile | 47 +-
.../pinot-base/pinot-base-build/openjdk.dockerfile | 52 -
.../pinot-base-runtime/amazoncorretto.dockerfile | 47 +-
.../pinot-base-runtime/ms-openjdk.dockerfile | 5 +-
.../pinot-base-runtime/openjdk.dockerfile | 39 -
docker/images/pinot/Dockerfile | 9 +-
docker/images/pinot/Dockerfile.build | 11 +-
docker/images/pinot/Dockerfile.package | 2 +-
docker/images/pinot/README.md | 18 +-
docker/images/pinot/docker-build.sh | 23 +-
.../api/resources/ResponseStoreResource.java | 22 +
.../broker/broker/helix/BaseBrokerStarter.java | 92 +-
.../pinot/broker/cursors/FsResponseStore.java | 13 +-
.../requesthandler/BaseBrokerRequestHandler.java | 13 +-
.../BaseSingleStageBrokerRequestHandler.java | 2 +-
.../MultiStageBrokerRequestHandler.java | 12 +-
.../routing/manager/BaseBrokerRoutingManager.java | 70 +-
.../manager/MultiClusterRoutingManager.java | 9 +
.../api/resources/ResponseStoreResourceTest.java | 108 ++
.../pinot/broker/cursors/FsResponseStoreTest.java | 235 ++++
.../BaseSingleStageBrokerRequestHandlerTest.java | 50 +
.../broker/requesthandler/QueryValidationTest.java | 4 +-
.../BrokerRoutingManagerConcurrencyTest.java | 4 +-
.../routing/manager/BrokerRoutingManagerTest.java | 29 +
.../manager/MultiClusterRoutingManagerTest.java | 22 +
.../java/org/apache/pinot/client/BrokerCache.java | 8 +-
.../pinot/client/PinotClientNettyResources.java | 82 ++
pinot-common/pom.xml | 17 -
.../common/cursors/AbstractResponseStore.java | 49 +-
.../evaluator}/FunctionEvaluatorFactory.java | 15 +-
.../common/evaluator}/GroovyFunctionEvaluator.java | 3 +-
.../evaluator}/GroovyStaticAnalyzerConfig.java | 2 +-
.../evaluator}/InbuiltFunctionEvaluator.java | 3 +-
.../evaluator}/TimeSpecFunctionEvaluator.java | 7 +-
.../common/function/scalar/StringFunctions.java | 44 +-
.../scalar/regexp/RegexpReplaceConstFunctions.java | 2 +-
.../common/messages/SegmentReloadMessage.java | 16 +
.../pinot/common/metrics/AbstractMetrics.java | 4 +
.../apache/pinot/common/metrics/BrokerGauge.java | 7 +
.../apache/pinot/common/metrics/ServerMeter.java | 7 +-
.../RealtimeToOfflineSegmentsTaskMetadata.java | 2 +-
.../resources/PinotControllerJobMetadataDto.java | 11 +
.../pinot/common/utils/config/InstanceUtils.java | 60 +
.../parsers/rewriter/CastTypeAliasRewriter.java | 2 +
.../common/cursors/AbstractResponseStoreTest.java | 181 +++
.../evaluator}/InbuiltFunctionEvaluatorTest.java | 14 +-
.../ConnectionFailureDetectorTest.java | 4 +-
.../function/scalar/StringFunctionsTest.java | 22 +
.../function/test/MutableStringTestFunction.java} | 23 +-
.../common/messages/SegmentReloadMessageTest.java | 57 +
.../pinot/common/metrics/AbstractMetricsTest.java | 319 +++---
.../pinot/common/metrics/MetricValueUtils.java | 105 +-
.../pinot/common/metrics/MetricsInspector.java | 154 +--
.../pinot/common/metrics/PinotMetricUtilsTest.java | 32 +-
.../common/utils/config/InstanceUtilsTest.java | 71 ++
.../fake/FakeMetricsAbstractMetricsTest.java | 66 ++
.../plugin/metrics/fake/FakeMetricsFactory.java | 30 +-
.../plugin/metrics/fake/FakeMetricsInspector.java | 77 ++
.../plugin/metrics/fake/FakePinotCounter.java | 28 +-
.../pinot/plugin/metrics/fake/FakePinotGauge.java | 27 +-
.../pinot/plugin/metrics/fake/FakePinotMeter.java | 44 +-
.../plugin/metrics/fake/FakePinotMetricName.java | 22 +-
.../metrics/fake/FakePinotMetricsRegistry.java | 145 +++
.../pinot/plugin/metrics/fake/FakePinotTimer.java | 43 +-
.../rewriter/CastTypeAliasRewriterTest.java | 206 ++++
pinot-connectors/pinot-flink-connector/README.md | 8 +-
pinot-connectors/pinot-flink-connector/pom.xml | 5 -
.../pinot/connector/flink/FlinkQuickStart.java | 9 +-
.../pinot/connector/flink/sink/PinotSink.java | 344 ++++++
.../connector/flink/sink/PinotSinkFunction.java | 195 +---
.../flink/sink/PinotSinkIntegrationTest.java | 8 +-
.../sink/PinotSinkUpsertTableIntegrationTest.java | 18 +-
.../pinot/controller/BaseControllerStarter.java | 13 +-
.../apache/pinot/controller/ControllerConf.java | 15 +-
.../api/resources/PinotClusterConfigs.java | 2 +-
.../resources/PinotInstanceRestletResource.java | 7 +
.../api/resources/PinotTableReloadResource.java | 16 +-
.../api/resources/PinotTableRestletResource.java | 5 +
.../api/resources/TableConfigValidationUtils.java | 2 +
.../api/resources/TableConfigsRestletResource.java | 3 +
.../controller/cursors/ResponseStoreCleaner.java | 310 -----
.../helix/core/PinotHelixResourceManager.java | 46 +-
.../assignment/segment/SegmentAssignmentUtils.java | 15 +-
.../BalancedNumSegmentAssignmentStrategy.java | 6 +-
.../ReplicaGroupSegmentAssignmentStrategy.java | 23 +-
...RobinReplicaGroupSegmentAssignmentStrategy.java | 78 ++
.../RoundRobinSegmentAssignmentStrategy.java | 77 ++
.../strategy/SegmentAssignmentStrategyFactory.java | 6 +
.../helix/core/minion/PinotTaskManager.java | 203 +---
.../RealtimeOffsetAutoResetHandler.java | 18 +-
.../RealtimeOffsetAutoResetKafkaHandler.java | 12 +-
.../realtime/BlockingSegmentCompletionFSM.java | 2 +-
.../helix/core/retention/RetentionManager.java | 111 +-
.../retention/strategy/TimeRetentionStrategy.java | 33 +-
.../realtime/provisioning/MemoryEstimator.java | 2 +-
.../utils/QueryInvertedSortedIndexRecommender.java | 2 +-
.../services/PinotTableReloadService.java | 252 +++-
.../services/PinotTableReloadStatusReporter.java | 43 +-
.../validation/RealtimeOffsetAutoResetManager.java | 22 +-
.../src/main/resources/package-lock.json | 31 +-
pinot-controller/src/main/resources/package.json | 2 +-
.../cursors/ResponseStoreCleanerTest.java | 333 ------
...ControllerPeriodicTaskStarterStatelessTest.java | 2 +-
...otHelixResourceManagerConfigValidationTest.java | 171 +++
.../PinotHelixResourceManagerReloadJobTest.java | 98 ++
...nReplicaGroupSegmentAssignmentStrategyTest.java | 247 ++++
...> RoundRobinSegmentAssignmentStrategyTest.java} | 118 +-
.../PinotTaskManagerDistributedLockingTest.java | 10 +-
.../helix/core/retention/RetentionManagerTest.java | 103 ++
.../strategy/TimeRetentionStrategyTest.java | 67 ++
.../services/PinotTableReloadServiceTest.java | 371 ++++++
.../PinotTableReloadStatusReporterTest.java | 29 +-
.../RealtimeOffsetAutoResetManagerTest.java | 92 +-
.../HeapUsagePublishingAccountantFactory.java | 6 +-
.../PerQueryCPUMemAccountantFactory.java | 29 +-
.../pinot/core/accounting/QueryMonitorConfig.java | 254 ++--
.../core/accounting/QueryResourceAggregator.java | 131 ++-
.../accounting/ResourceUsageAccountantFactory.java | 49 +-
.../apache/pinot/core/common/MinionConstants.java | 2 +-
.../realtime/RealtimeSegmentDataManager.java | 2 +-
.../predicate/EqualsPredicateEvaluatorFactory.java | 47 +-
.../predicate/InPredicateEvaluatorFactory.java | 57 +-
.../NotEqualsPredicateEvaluatorFactory.java | 42 +-
.../predicate/NotInPredicateEvaluatorFactory.java | 57 +-
.../predicate/RangePredicateEvaluatorFactory.java | 98 +-
.../function/GroovyTransformFunction.java | 2 +-
.../core/query/scheduler/WorkloadScheduler.java | 6 +-
.../apache/pinot/core/routing/RoutingManager.java | 13 +
.../aggregator/PercentileTDigestAggregator.java | 62 +
.../aggregator/ValueAggregatorFactory.java | 3 +
.../partitioner/TransformFunctionPartitioner.java | 4 +-
.../routing/stats/ServerRoutingStatsManager.java | 43 +
.../core/accounting/QueryMonitorConfigTest.java | 244 +++-
.../accounting/QueryResourceAggregatorTest.java | 216 ++++
.../data/function/ArithmeticFunctionsTest.java | 2 +-
.../core/data/function/ArrayFunctionsTest.java | 2 +-
.../pinot/core/data/function/BitFunctionsTest.java | 2 +-
.../core/data/function/DateTimeFunctionsTest.java | 2 +-
.../data/function/GroovyFunctionEvaluatorTest.java | 8 +-
.../function/GroovyStaticAnalyzerConfigTest.java | 2 +-
.../core/data/function/JsonFunctionsTest.java | 2 +-
.../core/data/function/LogicalFunctionsTest.java | 2 +-
.../core/data/function/ObjectFunctionsTest.java | 2 +-
.../core/data/function/VectorFunctionsTest.java | 2 +-
.../offline/DimensionTableDataManagerTest.java | 4 +-
.../predicate/InPredicateEvaluatorFactoryTest.java | 79 +-
.../groupby/DoubleGroupByResultHolderTest.java | 2 +-
.../PercentileTDigestAggregatorTest.java | 154 +++
.../stats/ServerRoutingStatsManagerTest.java | 86 ++
.../org/apache/pinot/core/util/CrcUtilsTest.java | 8 +-
.../test/resources/conf/pinot-broker.properties | 2 +-
.../pinot/integration/tests/ClusterTest.java | 11 +-
pinot-integration-tests/pom.xml | 5 +
.../CpuBasedBrokerQueryKillingIntegrationTest.java | 15 +-
.../CpuBasedServerQueryKillingIntegrationTest.java | 15 +-
.../tests/CursorCronCleanupIntegrationTest.java | 137 +++
.../integration/tests/CursorFsIntegrationTest.java | 24 +-
.../integration/tests/CursorIntegrationTest.java | 169 ++-
...tlyOnceKafkaRealtimeClusterIntegrationTest.java | 94 +-
...moryBasedServerQueryKillingIntegrationTest.java | 13 +-
.../MergeRollupMinionClusterIntegrationTest.java | 88 +-
.../MultiNodesOfflineClusterIntegrationTest.java | 20 +-
.../tests/MultiStageEngineIntegrationTest.java | 4 +-
.../tests/OfflineClusterIntegrationTest.java | 4 +-
.../tests/OfflineGRPCServerIntegrationTest.java | 16 +-
.../tests/PurgeMinionClusterIntegrationTest.java | 2 +-
.../tests/QueryWorkloadIntegrationTest.java | 26 +-
.../tests/WindowResourceAccountingTest.java | 17 +-
.../tests/cursors/MemoryResponseStore.java | 30 +-
.../CustomDataQueryClusterIntegrationTest.java | 14 +-
.../custom/ProtoBufCodeGenMessageDecoderTest.java | 290 +++++
.../src/test/resources/sample-samplerecord.desc | 0
.../src/test/resources/sample-samplerecord.jar | Bin
.../pinot/perf/BenchmarkOfflineIndexReader.java | 2 +-
.../pinot/perf/BenchmarkWorkloadBudgetManager.java | 6 +-
.../BenchmarkDistinctCountHLLThreshold.java | 9 -
.../pinot-metrics/pinot-dropwizard/pom.xml | 33 +
.../dropwizard/DropwizardAbstractMetricsTest.java} | 33 +-
.../dropwizard/DropwizardMetricValueUtils.java | 68 ++
.../dropwizard/DropwizardMetricsInspector.java | 133 +++
.../DropwizardBrokerPrometheusMetricsTest.java | 2 +-
.../DropwizardControllerPrometheusMetricsTest.java | 2 +-
.../DropwizardMinionPrometheusMetricsTest.java | 2 +-
.../DropwizardServerPrometheusMetricsTest.java | 5 +-
pinot-plugins/pinot-metrics/pinot-yammer/pom.xml | 33 +
.../plugin/metrics/yammer/YammerSettableGauge.java | 5 +
.../metrics/yammer/YammerAbstractMetricsTest.java | 52 +
.../metrics/yammer/YammerMetricValueUtils.java | 19 +-
.../metrics/yammer/YammerMetricsInspector.java | 91 +-
.../YammerBrokerPrometheusMetricsTest.java | 4 +-
.../YammerControllerPrometheusMetricsTest.java | 4 +-
.../YammerMinionPrometheusMetricsTest.java | 4 +-
.../YammerServerPrometheusMetricsTest.java | 4 +-
.../mergerollup/MergeRollupTaskGenerator.java | 8 +-
.../refreshsegment/RefreshSegmentTaskExecutor.java | 4 +-
.../MergeRollupTDigestTaskExecutorTest.java | 543 +++++++++
.../mergerollup/MergeRollupTaskGeneratorTest.java | 38 +
.../pinot/calcite/rel/rules/PinotRuleUtils.java | 2 +-
.../pinot/calcite/rel/traits/TraitAssignment.java | 31 +-
.../planner/physical/v2/ExchangeStrategy.java | 14 +-
.../v2/PlanFragmentAndMailboxAssignment.java | 81 +-
.../physical/v2/opt/PhysicalOptRuleSet.java | 2 +
.../physical/v2/opt/rules/LookupJoinRule.java | 189 +++
.../apache/pinot/query/routing/WorkerManager.java | 55 +-
.../planner/physical/v2/ExchangeStrategyTest.java | 9 +
.../planner/physical/v2/LookupJoinPlanTest.java | 411 +++++++
.../pinot/query/routing/WorkerManagerTest.java | 176 +++
.../resources/queries/PhysicalOptimizerPlans.json | 174 +++
.../utils/BlockingMultiStreamConsumer.java | 4 +-
...ator.java => BoolAndWindowValueAggregator.java} | 2 +-
...gator.java => BoolOrWindowValueAggregator.java} | 2 +-
...ava => MaxComparableWindowValueAggregator.java} | 40 +-
...or.java => MaxDoubleWindowValueAggregator.java} | 5 +-
...gator.java => MaxIntWindowValueAggregator.java} | 35 +-
...ator.java => MaxLongWindowValueAggregator.java} | 36 +-
...ava => MinComparableWindowValueAggregator.java} | 40 +-
...or.java => MinDoubleWindowValueAggregator.java} | 5 +-
...gator.java => MinIntWindowValueAggregator.java} | 35 +-
...ator.java => MinLongWindowValueAggregator.java} | 36 +-
...ava => SumBigDecimalWindowValueAggregator.java} | 25 +-
...or.java => SumDoubleWindowValueAggregator.java} | 2 +-
...ator.java => SumLongWindowValueAggregator.java} | 13 +-
.../aggregate/WindowValueAggregatorFactory.java | 54 +-
.../query/service/dispatch/DispatchClient.java | 65 +-
.../query/service/dispatch/QueryDispatcher.java | 21 +-
.../pinot/query/service/server/QueryServer.java | 2 +
.../java/org/apache/pinot/query/QueryTestSet.java | 3 +-
.../query/runtime/operator/LeafOperatorTest.java | 105 +-
.../aggregate/WindowValueAggregatorTest.java | 756 ++++++++++++
.../query/runtime/queries/QueryRunnerTestBase.java | 6 +
.../runtime/queries/ResourceBasedQueriesTest.java | 75 +-
.../query/service/server/QueryServerTest.java | 73 ++
.../src/test/resources/queries/LookupJoin.json | 79 ++
.../segment/local/function/FunctionEvaluator.java | 31 +-
.../local/function/FunctionEvaluatorFactory.java | 95 +-
.../local/function/GroovyFunctionEvaluator.java | 212 +---
.../local/function/GroovyStaticAnalyzerConfig.java | 113 +-
.../local/function/InbuiltFunctionEvaluator.java | 378 +-----
.../local/function/TimeSpecFunctionEvaluator.java | 62 +-
.../indexsegment/mutable/MutableSegmentImpl.java | 1 +
.../converter/stats/MutableColumnStatistics.java | 50 +-
.../dictionary/BaseOffHeapMutableDictionary.java | 2 +-
.../BigDecimalOffHeapMutableDictionary.java | 46 +-
.../BigDecimalOnHeapMutableDictionary.java | 45 +-
.../dictionary/BytesOffHeapMutableDictionary.java | 45 +-
.../dictionary/BytesOnHeapMutableDictionary.java | 43 +-
.../dictionary/DoubleOffHeapMutableDictionary.java | 29 +-
.../dictionary/DoubleOnHeapMutableDictionary.java | 30 +-
.../dictionary/FloatOffHeapMutableDictionary.java | 29 +-
.../dictionary/FloatOnHeapMutableDictionary.java | 30 +-
.../dictionary/IntOffHeapMutableDictionary.java | 29 +-
.../dictionary/IntOnHeapMutableDictionary.java | 30 +-
.../dictionary/LongOffHeapMutableDictionary.java | 30 +-
.../dictionary/LongOnHeapMutableDictionary.java | 30 +-
.../dictionary/SameValueMutableDictionary.java | 15 +
.../dictionary/StringOffHeapMutableDictionary.java | 55 +-
.../dictionary/StringOnHeapMutableDictionary.java | 50 +-
.../impl/invertedindex/RealtimeInvertedIndex.java | 10 +-
.../recordtransformer/ComplexTypeTransformer.java | 2 +-
.../recordtransformer/ExpressionTransformer.java | 4 +-
.../local/recordtransformer/FilterTransformer.java | 4 +-
.../enricher/function/CustomFunctionEnricher.java | 4 +-
.../function/CustomFunctionEnricherFactory.java | 2 +-
.../segment/creator/impl/BaseSegmentCreator.java | 151 ++-
.../creator/impl/SegmentCreationDriverFactory.java | 32 -
.../stats/MapColumnPreIndexStatsCollector.java | 10 +-
.../local/segment/index/bloom/BloomIndexType.java | 3 +-
.../index/dictionary/DictionaryIndexType.java | 7 +-
.../segment/index/loader/ForwardIndexHandler.java | 2 +-
.../ColumnMinMaxValueGenerator.java | 6 +-
.../defaultcolumn/BaseDefaultColumnHandler.java | 4 +-
.../local/segment/index/map/BaseMapDataSource.java | 4 +-
.../segment/index/map/ImmutableMapDataSource.java | 8 +-
.../segment/index/map/MapIndexReaderWrapper.java | 121 +-
.../segment/index/map/MutableMapDataSource.java | 2 +-
.../map/SimpleColumnMetadata.java} | 99 +-
.../index/readers/BaseConstantValueDictionary.java | 49 +-
.../index/readers/BaseImmutableDictionary.java | 7 -
.../readers/ConstantValueBigDecimalDictionary.java | 13 +-
.../readers/ConstantValueBytesDictionary.java | 13 +-
.../readers/ConstantValueDoubleDictionary.java | 3 +-
.../readers/ConstantValueFloatDictionary.java | 3 +-
.../index/readers/ConstantValueIntDictionary.java | 3 +-
.../index/readers/ConstantValueLongDictionary.java | 3 +-
.../readers/ConstantValueStringDictionary.java | 23 +-
.../segment/index/readers/DocIdDictionary.java | 14 +-
.../segment/store/SingleFileIndexDirectory.java | 40 +
.../local/utils/FixedIntArrayOffHeapIdMap.java | 5 -
.../pinot/segment/local/utils/SchemaUtils.java | 4 +-
.../segment/local/utils/TableConfigUtils.java | 6 +-
.../local/utils/tablestate/TableStateUtils.java | 4 +-
.../function/FunctionPackageCompatibilityTest.java | 62 +
.../mutable/MutableSegmentImplTest.java | 23 +
.../converter/RealtimeSegmentConverterTest.java | 4 +-
.../stats/MutableColumnStatisticsTest.java | 1208 +++++++++-----------
.../RealtimeInvertedIndexReaderTest.java | 21 +
.../segment/local/segment/creator/BlocksTest.java | 4 +-
.../local/segment/creator/DictionariesTest.java | 4 +-
.../segment/creator/DictionaryOptimiserTest.java | 4 +-
.../DictionaryOptimizerCardinalityTest.java | 4 +-
.../local/segment/creator/IntArraysTest.java | 4 +-
.../impl/ColumnarSegmentBuildingTestBase.java | 2 +-
.../stats/MapColumnPreIndexStatsCollectorTest.java | 104 +-
.../local/segment/index/ColumnMetadataTest.java | 109 +-
.../segment/index/SegmentMetadataImplTest.java | 4 +-
.../SegmentV1V2ToV3FormatConverterTest.java | 4 +-
.../index/dictionary/DictionaryIndexTypeTest.java | 143 +++
.../index/loader/ForwardIndexHandlerTest.java | 546 +++------
.../index/loader/SegmentPreProcessorTest.java | 444 ++++---
.../local/upsert/PartialUpsertHandlerTest.java | 2 +-
.../segment/local/utils/TableConfigUtilsTest.java | 106 ++
.../apache/pinot/segment/spi/ColumnMetadata.java | 98 +-
.../org/apache/pinot/segment/spi/Constants.java | 3 +
.../org/apache/pinot/segment/spi/V1Constants.java | 81 +-
.../spi/index/metadata/ColumnMetadataImpl.java | 367 +++---
.../spi/index/metadata/SegmentMetadataImpl.java | 37 +-
.../spi/index/mutable/MutableDictionary.java | 15 +
.../pinot/segment/spi/index/reader/Dictionary.java | 40 +-
.../segment/spi/index/reader/MapIndexReader.java | 26 +-
.../metadata/ColumnPartitionMetadata.java | 23 +-
.../pinot/server/api/resources/TablesResource.java | 20 +-
.../server/starter/helix/BaseServerStarter.java | 18 +-
.../helix/SegmentMessageHandlerFactory.java | 4 +-
.../ServerGrpcChannelBackoffResetHandler.java | 5 +-
.../apache/pinot/server/api/BaseResourceTest.java | 38 +-
.../pinot/server/api/TableSizeResourceTest.java | 14 +-
.../pinot/server/api/TableTierResourceTest.java | 27 +-
.../pinot/server/api/TablesResourceTest.java | 286 ++---
.../ServerGrpcChannelBackoffResetHandlerTest.java | 16 +
.../test/resources/conf/pinot-broker.properties | 2 +-
.../pinot/spi/accounting/ThreadAccountant.java | 9 +
.../spi/accounting/ThreadAccountantUtils.java | 95 +-
.../spi/accounting/WorkloadBudgetManager.java | 32 +-
.../config/instance/InstanceConfigValidator.java | 42 +
.../instance/InstanceConfigValidatorRegistry.java | 90 ++
.../spi/config/table/TableConfigValidator.java | 39 +-
.../config/table/TableConfigValidatorRegistry.java | 93 ++
.../apache/pinot/spi/cursors/ResponseStore.java | 11 +
.../java/org/apache/pinot/spi/data/FieldSpec.java | 24 +
.../apache/pinot/spi/data/MultiValueVisitor.java | 99 --
.../apache/pinot/spi/data/SingleValueVisitor.java | 45 -
.../spi/exception/ConfigValidationException.java | 17 +-
.../pinot/spi}/function/FunctionEvaluator.java | 7 +-
.../org/apache/pinot/spi/metrics/PinotGauge.java | 5 +
.../apache/pinot/spi/metrics/SettableValue.java | 5 +
.../apache/pinot/spi/query/QueryThreadContext.java | 35 +
.../apache/pinot/spi/utils/CommonConstants.java | 230 ++--
.../spi/accounting/WorkloadBudgetManagerTest.java | 6 +-
.../InstanceConfigValidatorRegistryTest.java | 91 ++
.../table/TableConfigValidatorRegistryTest.java | 92 ++
.../apache/pinot/tools/utils/PinotConfigUtils.java | 21 +-
.../pinot/tools/utils/PinotConfigUtilsTest.java | 29 -
.../ExpressionTransformerTestScenario.java | 4 +-
pom.xml | 37 +-
395 files changed, 15673 insertions(+), 6923 deletions(-)
create mode 100644 .claude/skills/README.md
create mode 100644 .claude/skills/bench-compare/SKILL.md
create mode 100644 .claude/skills/flaky-analyze/SKILL.md
create mode 100644 .claude/skills/precommit/SKILL.md
create mode 100644 .claude/skills/quickstart/SKILL.md
create mode 100644 .claude/skills/review-architecture/SKILL.md
create mode 100644 .claude/skills/review-concurrency-state/SKILL.md
create mode 100644 .claude/skills/review-config-backcompat/SKILL.md
create mode 100644 .claude/skills/review-correctness-nulls/SKILL.md
create mode 100644 .claude/skills/review-naming-api/SKILL.md
create mode 100644 .claude/skills/review-performance/SKILL.md
create mode 100644 .claude/skills/review-process-scope/SKILL.md
create mode 100644 .claude/skills/review-testing/SKILL.md
create mode 100644 .claude/skills/run-test/SKILL.md
create mode 100644 .github/workflows/build-all-pinot-docker-image.yml
delete mode 100644 .github/workflows/build-multi-arch-pinot-docker-image.yml
create mode 100644 .github/workflows/nightly-build-all-pinot-docker-image.yml
create mode 100644
.github/workflows/nightly-build-multi-arch-superset-docker-image.yml
copy
.github/workflows/scripts/docker/{.pinot_base_docker_image_build_and_push.sh =>
.pinot_base_docker_manifest_build_and_push.sh} (64%)
create mode 100755
.github/workflows/scripts/docker/.pinot_compile_and_push_build_image.sh
delete mode 100755
.github/workflows/scripts/docker/.pinot_docker_image_build.sh
create mode 100755
.github/workflows/scripts/docker/.pinot_package_single_platform.sh
delete mode 100755
.github/workflows/scripts/docker/.pinot_single_platform_docker_image_build.sh
delete mode 100755
.github/workflows/scripts/docker/.superset_multi_arch_docker_image_build_and_push.sh
delete mode 100644 docker/images/pinot-base/pinot-base-build/openjdk.dockerfile
delete mode 100644
docker/images/pinot-base/pinot-base-runtime/openjdk.dockerfile
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/api/resources/ResponseStoreResourceTest.java
create mode 100644
pinot-broker/src/test/java/org/apache/pinot/broker/cursors/FsResponseStoreTest.java
create mode 100644
pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientNettyResources.java
copy
{pinot-segment-local/src/main/java/org/apache/pinot/segment/local/function =>
pinot-common/src/main/java/org/apache/pinot/common/evaluator}/FunctionEvaluatorFactory.java
(91%)
copy
{pinot-segment-local/src/main/java/org/apache/pinot/segment/local/function =>
pinot-common/src/main/java/org/apache/pinot/common/evaluator}/GroovyFunctionEvaluator.java
(98%)
copy
{pinot-segment-local/src/main/java/org/apache/pinot/segment/local/function =>
pinot-common/src/main/java/org/apache/pinot/common/evaluator}/GroovyStaticAnalyzerConfig.java
(98%)
copy
{pinot-segment-local/src/main/java/org/apache/pinot/segment/local/function =>
pinot-common/src/main/java/org/apache/pinot/common/evaluator}/InbuiltFunctionEvaluator.java
(99%)
copy
{pinot-segment-local/src/main/java/org/apache/pinot/segment/local/function =>
pinot-common/src/main/java/org/apache/pinot/common/evaluator}/TimeSpecFunctionEvaluator.java
(94%)
create mode 100644
pinot-common/src/test/java/org/apache/pinot/common/cursors/AbstractResponseStoreTest.java
rename
{pinot-segment-local/src/test/java/org/apache/pinot/segment/local/function =>
pinot-common/src/test/java/org/apache/pinot/common/evaluator}/InbuiltFunctionEvaluatorTest.java
(96%)
copy
pinot-common/src/{main/java/org/apache/pinot/common/function/scalar/string/LTrimFunction.java
=>
test/java/org/apache/pinot/common/function/test/MutableStringTestFunction.java}
(66%)
create mode 100644
pinot-common/src/test/java/org/apache/pinot/common/messages/SegmentReloadMessageTest.java
create mode 100644
pinot-common/src/test/java/org/apache/pinot/plugin/metrics/fake/FakeMetricsAbstractMetricsTest.java
copy
pinot-plugins/pinot-metrics/pinot-yammer/src/main/java/org/apache/pinot/plugin/metrics/yammer/YammerMetricsFactory.java
=>
pinot-common/src/test/java/org/apache/pinot/plugin/metrics/fake/FakeMetricsFactory.java
(69%)
create mode 100644
pinot-common/src/test/java/org/apache/pinot/plugin/metrics/fake/FakeMetricsInspector.java
copy
pinot-plugins/pinot-metrics/pinot-yammer/src/main/java/org/apache/pinot/plugin/metrics/yammer/YammerCounter.java
=>
pinot-common/src/test/java/org/apache/pinot/plugin/metrics/fake/FakePinotCounter.java
(70%)
copy
pinot-plugins/pinot-metrics/pinot-compound-metrics/src/main/java/org/apache/pinot/plugin/metrics/compound/CompoundPinotGauge.java
=>
pinot-common/src/test/java/org/apache/pinot/plugin/metrics/fake/FakePinotGauge.java
(70%)
copy
pinot-plugins/pinot-metrics/pinot-compound-metrics/src/main/java/org/apache/pinot/plugin/metrics/compound/CompoundPinotMeter.java
=>
pinot-common/src/test/java/org/apache/pinot/plugin/metrics/fake/FakePinotMeter.java
(65%)
copy pinot-spi/src/main/java/org/apache/pinot/spi/plugin/Plugin.java =>
pinot-common/src/test/java/org/apache/pinot/plugin/metrics/fake/FakePinotMetricName.java
(67%)
create mode 100644
pinot-common/src/test/java/org/apache/pinot/plugin/metrics/fake/FakePinotMetricsRegistry.java
copy
pinot-plugins/pinot-metrics/pinot-dropwizard/src/main/java/org/apache/pinot/plugin/metrics/dropwizard/DropwizardTimer.java
=>
pinot-common/src/test/java/org/apache/pinot/plugin/metrics/fake/FakePinotTimer.java
(63%)
create mode 100644
pinot-common/src/test/java/org/apache/pinot/sql/parsers/rewriter/CastTypeAliasRewriterTest.java
create mode 100644
pinot-connectors/pinot-flink-connector/src/main/java/org/apache/pinot/connector/flink/sink/PinotSink.java
delete mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/cursors/ResponseStoreCleaner.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/strategy/RoundRobinReplicaGroupSegmentAssignmentStrategy.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/assignment/segment/strategy/RoundRobinSegmentAssignmentStrategy.java
delete mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/cursors/ResponseStoreCleanerTest.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/PinotHelixResourceManagerConfigValidationTest.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/PinotHelixResourceManagerReloadJobTest.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/assignment/segment/strategy/RoundRobinReplicaGroupSegmentAssignmentStrategyTest.java
copy
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/assignment/segment/strategy/{BalancedNumSegmentAssignmentStrategyTest.java
=> RoundRobinSegmentAssignmentStrategyTest.java} (50%)
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/services/PinotTableReloadServiceTest.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/segment/processing/aggregator/PercentileTDigestAggregator.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/accounting/QueryResourceAggregatorTest.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/segment/processing/aggregator/PercentileTDigestAggregatorTest.java
create mode 100644
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/CursorCronCleanupIntegrationTest.java
create mode 100644
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/custom/ProtoBufCodeGenMessageDecoderTest.java
copy
pinot-plugins/pinot-input-format/pinot-confluent-protobuf/src/test/resources/sample.desc
=> pinot-integration-tests/src/test/resources/sample-samplerecord.desc (100%)
copy
pinot-plugins/pinot-input-format/pinot-confluent-protobuf/src/test/resources/sample.jar
=> pinot-integration-tests/src/test/resources/sample-samplerecord.jar (100%)
copy
pinot-plugins/pinot-metrics/pinot-dropwizard/src/{main/java/org/apache/pinot/plugin/metrics/dropwizard/DropwizardJmxReporter.java
=>
test/java/org/apache/pinot/plugin/metrics/dropwizard/DropwizardAbstractMetricsTest.java}
(51%)
create mode 100644
pinot-plugins/pinot-metrics/pinot-dropwizard/src/test/java/org/apache/pinot/plugin/metrics/dropwizard/DropwizardMetricValueUtils.java
create mode 100644
pinot-plugins/pinot-metrics/pinot-dropwizard/src/test/java/org/apache/pinot/plugin/metrics/dropwizard/DropwizardMetricsInspector.java
rename
{pinot-common/src/test/java/org/apache/pinot/common/metrics/prometheus/dropwizard
=>
pinot-plugins/pinot-metrics/pinot-dropwizard/src/test/java/org/apache/pinot/plugin/metrics/dropwizard/prometheus}/DropwizardBrokerPrometheusMetricsTest.java
(97%)
rename
{pinot-common/src/test/java/org/apache/pinot/common/metrics/prometheus/dropwizard
=>
pinot-plugins/pinot-metrics/pinot-dropwizard/src/test/java/org/apache/pinot/plugin/metrics/dropwizard/prometheus}/DropwizardControllerPrometheusMetricsTest.java
(97%)
rename
{pinot-common/src/test/java/org/apache/pinot/common/metrics/prometheus/dropwizard
=>
pinot-plugins/pinot-metrics/pinot-dropwizard/src/test/java/org/apache/pinot/plugin/metrics/dropwizard/prometheus}/DropwizardMinionPrometheusMetricsTest.java
(97%)
rename
{pinot-common/src/test/java/org/apache/pinot/common/metrics/prometheus/dropwizard
=>
pinot-plugins/pinot-metrics/pinot-dropwizard/src/test/java/org/apache/pinot/plugin/metrics/dropwizard/prometheus}/DropwizardServerPrometheusMetricsTest.java
(92%)
create mode 100644
pinot-plugins/pinot-metrics/pinot-yammer/src/test/java/org/apache/pinot/plugin/metrics/yammer/YammerAbstractMetricsTest.java
copy
pinot-common/src/test/java/org/apache/pinot/common/metrics/MetricValueUtils.java
=>
pinot-plugins/pinot-metrics/pinot-yammer/src/test/java/org/apache/pinot/plugin/metrics/yammer/YammerMetricValueUtils.java
(86%)
copy
pinot-common/src/test/java/org/apache/pinot/common/metrics/MetricsInspector.java
=>
pinot-plugins/pinot-metrics/pinot-yammer/src/test/java/org/apache/pinot/plugin/metrics/yammer/YammerMetricsInspector.java
(50%)
rename
{pinot-common/src/test/java/org/apache/pinot/common/metrics/prometheus/yammer
=>
pinot-plugins/pinot-metrics/pinot-yammer/src/test/java/org/apache/pinot/plugin/metrics/yammer/prometheus}/YammerBrokerPrometheusMetricsTest.java
(89%)
rename
{pinot-common/src/test/java/org/apache/pinot/common/metrics/prometheus/yammer
=>
pinot-plugins/pinot-metrics/pinot-yammer/src/test/java/org/apache/pinot/plugin/metrics/yammer/prometheus}/YammerControllerPrometheusMetricsTest.java
(89%)
rename
{pinot-common/src/test/java/org/apache/pinot/common/metrics/prometheus/yammer
=>
pinot-plugins/pinot-metrics/pinot-yammer/src/test/java/org/apache/pinot/plugin/metrics/yammer/prometheus}/YammerMinionPrometheusMetricsTest.java
(89%)
rename
{pinot-common/src/test/java/org/apache/pinot/common/metrics/prometheus/yammer
=>
pinot-plugins/pinot-metrics/pinot-yammer/src/test/java/org/apache/pinot/plugin/metrics/yammer/prometheus}/YammerServerPrometheusMetricsTest.java
(89%)
create mode 100644
pinot-plugins/pinot-minion-tasks/pinot-minion-builtin-tasks/src/test/java/org/apache/pinot/plugin/minion/tasks/mergerollup/MergeRollupTDigestTaskExecutorTest.java
create mode 100644
pinot-query-planner/src/main/java/org/apache/pinot/query/planner/physical/v2/opt/rules/LookupJoinRule.java
create mode 100644
pinot-query-planner/src/test/java/org/apache/pinot/query/planner/physical/v2/LookupJoinPlanTest.java
rename
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/window/aggregate/{BoolAndValueAggregator.java
=> BoolAndWindowValueAggregator.java} (95%)
rename
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/window/aggregate/{BoolOrValueAggregator.java
=> BoolOrWindowValueAggregator.java} (95%)
copy
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/window/aggregate/{MaxWindowValueAggregator.java
=> MaxComparableWindowValueAggregator.java} (67%)
copy
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/window/aggregate/{MaxWindowValueAggregator.java
=> MaxDoubleWindowValueAggregator.java} (94%)
copy
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/window/aggregate/{MaxWindowValueAggregator.java
=> MaxIntWindowValueAggregator.java} (68%)
rename
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/window/aggregate/{MaxWindowValueAggregator.java
=> MaxLongWindowValueAggregator.java} (66%)
copy
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/window/aggregate/{MinWindowValueAggregator.java
=> MinComparableWindowValueAggregator.java} (67%)
copy
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/window/aggregate/{MinWindowValueAggregator.java
=> MinDoubleWindowValueAggregator.java} (94%)
copy
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/window/aggregate/{MinWindowValueAggregator.java
=> MinIntWindowValueAggregator.java} (68%)
rename
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/window/aggregate/{MinWindowValueAggregator.java
=> MinLongWindowValueAggregator.java} (66%)
copy
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/window/aggregate/{SumWindowValueAggregator.java
=> SumBigDecimalWindowValueAggregator.java} (62%)
copy
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/window/aggregate/{SumWindowValueAggregator.java
=> SumDoubleWindowValueAggregator.java} (94%)
rename
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/window/aggregate/{SumWindowValueAggregator.java
=> SumLongWindowValueAggregator.java} (77%)
create mode 100644
pinot-query-runtime/src/test/java/org/apache/pinot/query/runtime/operator/window/aggregate/WindowValueAggregatorTest.java
create mode 100644
pinot-query-runtime/src/test/resources/queries/LookupJoin.json
delete mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/creator/impl/SegmentCreationDriverFactory.java
copy
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/{creator/impl/stats/EmptyColumnStatistics.java
=> index/map/SimpleColumnMetadata.java} (55%)
copy
pinot-core/src/main/java/org/apache/pinot/core/query/distinct/table/EmptyDistinctTable.java
=>
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/index/readers/BaseConstantValueDictionary.java
(50%)
create mode 100644
pinot-segment-local/src/test/java/org/apache/pinot/segment/local/function/FunctionPackageCompatibilityTest.java
create mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/config/instance/InstanceConfigValidator.java
create mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/config/instance/InstanceConfigValidatorRegistry.java
copy
pinot-timeseries/pinot-timeseries-spi/src/main/java/org/apache/pinot/tsdb/spi/TimeSeriesMetadata.java
=>
pinot-spi/src/main/java/org/apache/pinot/spi/config/table/TableConfigValidator.java
(50%)
create mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/config/table/TableConfigValidatorRegistry.java
delete mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/data/MultiValueVisitor.java
delete mode 100644
pinot-spi/src/main/java/org/apache/pinot/spi/data/SingleValueVisitor.java
copy
pinot-clients/pinot-java-client/src/main/java/org/apache/pinot/client/PinotClientException.java
=>
pinot-spi/src/main/java/org/apache/pinot/spi/exception/ConfigValidationException.java
(64%)
copy {pinot-segment-local/src/main/java/org/apache/pinot/segment/local =>
pinot-spi/src/main/java/org/apache/pinot/spi}/function/FunctionEvaluator.java
(85%)
create mode 100644
pinot-spi/src/test/java/org/apache/pinot/spi/config/instance/InstanceConfigValidatorRegistryTest.java
create mode 100644
pinot-spi/src/test/java/org/apache/pinot/spi/config/table/TableConfigValidatorRegistryTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
