This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a change to branch http-support-spark-connector
in repository https://gitbox.apache.org/repos/asf/pinot.git
discard 1bc4343ffba feat: Add comprehensive Pinot Proxy and gRPC support to
pinot-spark-3-connector
discard eb6a67b9840 feat: Add HTTPS and authentication header support to
pinot-spark-3-connector
add b00dbfec1b8 [bugfix] Fixing the TableType val passed for unavailable
segments in physical optimizer (#16660)
add 283b5f720e2 Fix broker request id generator to avoid generating same
id (#16661)
add fecac1b8757 Bump software.amazon.awssdk:bom from 2.32.27 to 2.32.28
(#16667)
add 7135c9fc509 Bump net.openhft:chronicle-bom from 2.27ea73 to 2.27ea74
(#16668)
add 633c90d43be Fix LeafOperator thread accountant (#16651)
add d3c322dcc56 roundDecimal() fails for null FLOAT values (#15377)
add c49eac24933 Bump com.uber:h3 from 4.1.1 to 4.3.0 (#16669)
add 8eb40796057 Move time-series constants into CommonConstants (#16673)
add 868e2c9e7ce Add broker metrics to count segments that are not zone
failure tolerant (#16334)
add 98ea698debd Fix upgrade compatibility issue with type casts in SSE
(#16682)
add 85fbe1653ab Improve segment build auto retry logics (#16663)
add 274fe480617 Revert "Bump com.uber:h3 from 4.1.1 to 4.3.0 (#16669)"
(#16680)
add 2ee3ce931cc Bump software.amazon.awssdk:bom from 2.32.28 to 2.32.29
(#16685)
add 777936a28e5 Bump io.dropwizard.metrics:metrics-bom from 4.2.33 to
4.2.34 (#16686)
add fae135e33f5 Be sure block serialization can be interrupted (#16595)
add ab09ff318c6 Enhance validation for multi-value columns in aggregate
grouping (#16577)
add 4b15e83f26b Disable Flaky Tests (#16554)
add 54ee6360ca2 Disable idle mailboxes by default (#16691)
add f2153a1382b Handle null values in JsonExtractScalarTransformFunction
with default value support (#16683)
add d5ce73b0c6c Fix a basic null handling issue in MSE (#16658)
add d6f3ec3758f [refactor] Refactor TableCache to interface with
ZkTableCache implementation (#16646)
add 48cd24b9701 Refactor DefaultClusterConfigChangeHandler to common
module to enable sharing same infra across pinot components (#16662)
add 1593c937de1 Bump net.openhft:chronicle-bom from 2.27ea74 to 2.27ea75
(#16695)
add 388497cabfc [audit] Implement support for comma-separated header
filtering (#16694)
add 6d1b8d69888 Bump software.amazon.awssdk:bom from 2.32.29 to 2.32.30
(#16697)
add ed5b6997ee9 Bump software.amazon.awssdk:bom from 2.32.29 to 2.32.31
(#16701)
add 4b457b36685 reduce logging (#16698)
add 44a7b8f82c4 Removes ingestion metrics for consuming -> offline
transition (#16657)
add 71112fa2d9c docs: enhance copilot-instructions.md with comprehensive
guidelines (#16693)
add eb1e77aebeb Fix rebalance for RealtimeSegmentAssignment for ONLINE
segments with COMMITTING status (#16706)
add 4c00889a38d Bump com.gradle:common-custom-user-data-maven-extension
(#16702)
add ceb3ef2b2b8 Fix early termination on MSE operator (#16696)
add 7b1d881e909 [Query Resource Isolation]Interface for Workload Stats
Collection (#16340)
add fb06abc2c2f [Query Resource Isolation] Fix Refresh message (#16636)
add 78b76641f06 Add extra JSON fields (schemas and tableConfigs) in the
validateMultiStageQuery API - MSE (#16626)
add c3ce1cff782 [timeseries] Returning TimeSeriesBlock to API handlers to
eliminate extraneous transformation (#16641)
add 689c2f32d7a Avoid npe in the getdocIds code for Upserts (#16710)
add 0258b9217bb Handle null values gracefully in SSE's post aggregation
functions (#16711)
add 8f91ba79d76 Bump hadoop.version from 3.4.1 to 3.4.2 (#16712)
add 9d06452ca15 Bump com.fasterxml.jackson:jackson-bom from 2.19.2 to
2.20.0 (#16714)
add e9a778d9221 Bump org.apache.zookeeper:zookeeper from 3.9.3 to 3.9.4
(#16715)
add 095fc67dd6a Bump com.microsoft.azure:msal4j from 1.22.0 to 1.23.0
(#16716)
add 5d3e1884722 Bump com.google.cloud:libraries-bom from 26.66.0 to
26.67.0 (#16717)
add 1845ee02ce0 [audit] Enhance user identity resolution with custom
header and jwt. +DI refactor (#16709)
add 828b72427de Bump io.dropwizard.metrics:metrics-bom from 4.2.34 to
4.2.35 (#16713)
add 0e7393a1ac0 Cleanup some unused code in pinot-query-runtime (#16718)
add c44fd796a5b [Auto reset 2/3]Introduce topic 'inactive' status (#16692)
add ed5e306c0fd Add TenantRebalanceChecker for improved tenant rebalance
monitoring (#16455)
add 3388f7ead17 force commit API does not fail for non-existing segment
names (#16725)
add ee7b28c967c Adds Byte based throttling (#16572)
add 2bc41e415bc Bump software.amazon.awssdk:bom from 2.32.31 to 2.33.0
(#16732)
add 4d5b0b803d0 Bump org.webjars:swagger-ui from 5.27.1 to 5.28.0 (#16734)
add 0dd6aee058a Bump com.gradle:common-custom-user-data-maven-extension
(#16735)
add 375e0dfb628 Bump io.dropwizard.metrics:metrics-bom from 4.2.35 to
4.2.36 (#16736)
add 96b118a52f0 Bump org.apache.httpcomponents.core5:httpcore5 from 5.3.4
to 5.3.5 (#16738)
add f5256e1f2de Bump org.jetbrains:annotations from 26.0.2 to 26.0.2-1
(#16739)
add b9014763577 Bump org.yaml:snakeyaml from 2.4 to 2.5 (#16730)
add f7a7f2d9254 Bump org.checkerframework:checker-qual from 3.49.5 to
3.50.0 (#16731)
add 51838e17757 Upgrade avro lib to 1.12.0 (#16729)
add 22c4e446c69 Allow skip CRC check during segment load when server
starting. (#16432)
add e1a0b73dc49 Commit time compaction for upsert tables (#16344)
add 321111595df Add support for SNAPSHOT_WITH_DELETE validDocIdsType to
server APIs. (#16726)
add d6eb3c7dc6c Bump net.openhft:chronicle-bom from 2.27ea75 to 2.27ea76
(#16742)
add 278e5d6d6f9 Add support for minimum should match in lucene text search
(#16650)
add a58ec4c7522 [audit] Replace URL exclusion with PathMatcher glob
patterns (#16723)
add 37fbf1c166c Extract segment metadata from slim tar ball (#16635)
add 4b4e03b1252 Minor cleanups and refactors in instance selector module
(#16744)
add e8f5c93d7ce Bump software.amazon.awssdk:bom from 2.33.0 to 2.33.1
(#16748)
add 90067c5a763 Bump parquet.version from 1.15.2 to 1.16.0 (#16749)
add f314c253ff0 Bump net.openhft:chronicle-bom from 2.27ea76 to 2.27ea77
(#16750)
add 48de81a29fd Support to create combined Lucene Text Index Files and
merge into columns.psf (#16688)
add 6d1fd974acd feat: Add HTTPS and authentication header support to
pinot-spark-3-connector
add 47e3ad85bff feat: Add comprehensive Pinot Proxy and gRPC support to
pinot-spark-3-connector
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 (1bc4343ffba)
\
N -- N -- N refs/heads/http-support-spark-connector (47e3ad85bff)
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:
.github/copilot-instructions.md | 135 ++-
.mvn/extensions.xml | 2 +-
.../broker/api/resources/PinotClientRequest.java | 22 +-
.../broker/broker/helix/BaseBrokerStarter.java | 42 +-
.../BrokerUserDefinedMessageHandlerFactory.java | 28 +-
.../requesthandler/BaseBrokerRequestHandler.java | 5 +-
.../BaseSingleStageBrokerRequestHandler.java | 8 +-
.../requesthandler/BrokerRequestHandler.java | 7 +-
.../BrokerRequestHandlerDelegate.java | 9 +-
.../requesthandler/BrokerRequestIdGenerator.java | 28 +-
.../requesthandler/GrpcBrokerRequestHandler.java | 6 +-
.../MultiStageBrokerRequestHandler.java | 10 +-
.../SingleConnectionBrokerRequestHandler.java | 11 +-
.../requesthandler/TimeSeriesRequestHandler.java | 41 +-
.../ServerSelectionContext.java | 12 +-
.../instanceselector/BalancedInstanceSelector.java | 108 +-
.../instanceselector/BaseInstanceSelector.java | 108 +-
...eCandidate.java => InstanceSelectorConfig.java} | 49 +-
.../instanceselector/InstanceSelectorFactory.java | 20 +-
.../MultiStageReplicaGroupSelector.java | 9 +-
.../ReplicaGroupInstanceSelector.java | 97 +-
.../instanceselector/SegmentInstanceCandidate.java | 6 +
.../routing/instanceselector/SegmentStates.java | 19 +-
.../StrictReplicaGroupInstanceSelector.java | 5 +-
.../BaseSingleStageBrokerRequestHandlerTest.java | 2 +-
.../LiteralOnlyBrokerRequestTest.java | 15 +-
.../instanceselector/InstanceSelectorTest.java | 35 +-
.../MultiStageReplicaGroupSelectorTest.java | 2 +-
pinot-common/pom.xml | 4 +
.../org/apache/pinot/common/audit/AuditConfig.java | 52 +-
.../pinot/common/audit/AuditConfigManager.java | 113 +-
.../org/apache/pinot/common/audit/AuditEvent.java | 28 +-
.../pinot/common/audit/AuditIdentityResolver.java | 122 ++
.../apache/pinot/common/audit/AuditLogFilter.java | 10 +-
.../pinot/common/audit/AuditRequestProcessor.java | 100 +-
.../pinot/common/audit/AuditUrlPathFilter.java | 107 ++
.../config}/DefaultClusterConfigChangeHandler.java | 2 +-
.../org/apache/pinot/common/config/GrpcConfig.java | 13 +-
.../common/config/provider/StaticTableCache.java | 223 ++++
.../pinot/common/config/provider/TableCache.java | 565 +--------
.../{TableCache.java => ZkTableCache.java} | 117 +-
.../messages/QueryWorkloadRefreshMessage.java | 2 +-
.../apache/pinot/common/metrics/BrokerMeter.java | 16 +-
.../apache/pinot/common/metrics/ServerGauge.java | 5 +-
.../apache/pinot/common/metrics/ServerMeter.java | 12 +-
.../response/PinotBrokerTimeSeriesResponse.java | 64 +-
.../response/mapper/TimeSeriesResponseMapper.java | 126 ++
.../common/restlet/resources/ValidDocIdsType.java | 5 +
.../parsers/rewriter/CastTypeAliasRewriter.java | 86 ++
.../sql/parsers/rewriter/QueryRewriterFactory.java | 3 +-
.../pinot/common/audit/AuditConfigManagerTest.java | 194 ++-
.../common/audit/AuditIdentityResolverTest.java | 259 ++++
.../common/audit/AuditRequestProcessorTest.java | 149 ++-
.../pinot/common/audit/AuditUrlPathFilterTest.java | 165 +++
.../mapper/TimeSeriesResponseMapperTest.java | 157 +++
.../pinot/sql/parsers/CalciteSqlCompilerTest.java | 4 +-
.../parsers/rewriter/QueryRewriterFactoryTest.java | 6 +-
pinot-connectors/pinot-spark-3-connector/pom.xml | 1 -
.../spark/v3/datasource/DataExtractor.scala | 9 +
.../v3/datasource/SparkToPinotTypeTranslator.scala | 1 +
.../read_pinot_from_proxy_with_auth_token.scala | 33 +-
.../spark/v3/datasource/DataExtractorTest.scala | 47 +
.../SparkToPinotTypeTranslatorTest.scala | 2 +
.../pinot/connector/spark/common/HttpUtils.scala | 32 +-
.../spark/common/PinotClusterClient.scala | 68 +-
.../reader/PinotAbstractPartitionReader.scala | 2 +-
.../common/reader/PinotGrpcServerDataFetcher.scala | 82 +-
.../pinot/controller/BaseControllerStarter.java | 42 +-
.../apache/pinot/controller/ControllerConf.java | 18 +
.../controller/api/audit/AuditServiceBinder.java | 53 +
.../api/resources/PinotQueryResource.java | 93 +-
.../api/resources/PinotRealtimeTableResource.java | 68 ++
.../controller/helix/SegmentStatusChecker.java | 2 +-
.../helix/core/PinotHelixResourceManager.java | 4 +-
.../helix/core/PinotTableIdealStateBuilder.java | 6 +-
.../segment/RealtimeSegmentAssignment.java | 12 +-
.../realtime/MissingConsumingSegmentFinder.java | 8 +-
.../realtime/PinotLLCRealtimeSegmentManager.java | 144 ++-
.../segment/CommittingSegmentDescriptor.java | 12 +
.../SizeBasedSegmentFlushThresholdComputer.java | 71 +-
.../rebalance/tenant/DefaultTenantRebalancer.java | 288 -----
.../rebalance/tenant/TenantRebalanceChecker.java | 330 +++++
.../rebalance/tenant/TenantRebalanceContext.java | 130 ++
.../tenant/TenantRebalanceProgressStats.java | 14 +-
.../core/rebalance/tenant/TenantRebalancer.java | 332 ++++-
.../tenant/ZkBasedTenantRebalanceObserver.java | 61 +-
.../PinotQueryResourceStaticValidationTest.java | 72 ++
...ControllerPeriodicTaskStarterStatelessTest.java | 2 +-
.../pinot/controller/helix/TableCacheTest.java | 3 +-
.../PinotLLCRealtimeSegmentManagerTest.java | 43 +-
...SizeBasedSegmentFlushThresholdComputerTest.java | 394 ++++++
.../tenant/TenantRebalanceCheckerTest.java | 556 +++++++++
.../rebalance/tenant/TenantRebalancerTest.java | 20 +-
.../pinot/core/accounting/QueryAggregator.java | 2 +-
.../core/common/datablock/DataBlockBuilder.java | 440 ++++---
.../core/data/manager/BaseTableDataManager.java | 28 +-
.../realtime/RealtimeConsumptionRateManager.java | 158 ++-
.../realtime/RealtimeSegmentDataManager.java | 9 +-
.../manager/realtime/RealtimeTableDataManager.java | 13 +
.../ServerRateLimitConfigChangeListener.java | 40 +-
.../core/metadata/DefaultMetadataExtractor.java | 27 +-
.../JsonExtractScalarTransformFunction.java | 60 +-
.../function/RoundDecimalTransformFunction.java | 24 +-
.../postaggregation/PostAggregationFunction.java | 10 +-
.../data/manager/BaseTableDataManagerTest.java | 2 +
.../RealtimeConsumptionRateManagerTest.java | 20 +-
.../ServerRateLimitConfigChangeListenerTest.java | 32 +-
.../metadata/DefaultMetadataExtractorTest.java | 210 ++++
.../JsonExtractScalarTransformFunctionTest.java | 136 +++
.../PostAggregationFunctionTest.java | 5 +
.../impl/fakestream/FakeStreamMessageBatch.java | 7 +
.../pinot/queries/TextSearchQueriesTest.java | 65 +
.../TextSearchQueriesWithCombinedFilesTest.java | 58 +
.../tests/ClusterIntegrationTestUtils.java | 24 +-
.../pinot/integration/tests/QueryGenerator.java | 45 +-
.../tests/CommitTimeCompactionIntegrationTest.java | 1270 ++++++++++++++++++++
.../tests/ExplainIntegrationTestTrait.java | 19 +-
.../tests/GroupByOptionsIntegrationTest.java | 2 +-
.../tests/MultiStageEngineIntegrationTest.java | 257 +++-
.../tests/NullHandlingIntegrationTest.java | 80 +-
...flineClusterMemBasedServerQueryKillingTest.java | 6 +-
.../pinot/integration/tests/custom/ArrayTest.java | 6 +-
.../src/test/resources/log4j2-test.xml | 21 +-
.../src/test/resources/log4j2.xml | 36 -
.../pinot-stream-ingestion/pinot-kafka-2.0/pom.xml | 5 +
.../KafkaPartitionLevelConnectionHandler.java | 3 +-
.../kafka20/KafkaPartitionLevelConsumer.java | 6 +-
.../kafka20/KafkaPartitionLevelConsumerTest.java | 69 ++
.../pinot-stream-ingestion/pinot-kafka-3.0/pom.xml | 5 +
.../KafkaPartitionLevelConnectionHandler.java | 3 +-
.../kafka30/KafkaPartitionLevelConsumer.java | 6 +-
.../kafka30/KafkaPartitionLevelConsumerTest.java | 69 ++
.../plugin/stream/kafka/KafkaMessageBatch.java | 9 +-
.../plugin/stream/kinesis/KinesisConsumer.java | 16 +-
.../plugin/stream/kinesis/KinesisMessageBatch.java | 9 +-
.../plugin/stream/kinesis/KinesisConsumerTest.java | 2 +
.../stream/kinesis/KinesisMessageBatchTest.java | 2 +-
.../kinesis/KinesisStreamMetadataProviderTest.java | 24 +-
.../plugin/stream/pulsar/PulsarMessageBatch.java | 9 +-
.../pulsar/PulsarPartitionLevelConsumer.java | 7 +-
.../plugin/stream/pulsar/PulsarConsumerTest.java | 1 +
.../stream/pulsar/PulsarMessageBatchTest.java | 6 +-
.../pinot/calcite/sql/fun/PinotOperatorTable.java | 40 +-
.../org/apache/pinot/query/QueryEnvironment.java | 19 +-
.../query/planner/logical/RexExpressionUtils.java | 25 +-
.../opt/rules/LeafStageWorkerAssignmentRule.java | 2 +-
.../validation/ArrayToMvValidationVisitor.java | 20 +-
.../resources/queries/PhysicalOptimizerPlans.json | 2 +-
.../pinot/query/mailbox/GrpcSendingMailbox.java | 4 +-
.../apache/pinot/query/mailbox/MailboxService.java | 18 +-
.../query/mailbox/channel/ChannelManager.java | 46 +-
.../apache/pinot/query/runtime/QueryRunner.java | 78 +-
.../query/runtime/executor/OpChainScheduler.java | 86 --
.../runtime/executor/OpChainSchedulerService.java | 9 +-
.../query/runtime/operator/AggregateOperator.java | 5 +-
.../query/runtime/operator/AsofJoinOperator.java | 9 +-
.../operator/BaseMailboxReceiveOperator.java | 4 +-
.../query/runtime/operator/HashJoinOperator.java | 23 +-
.../pinot/query/runtime/operator/LeafOperator.java | 135 +--
.../runtime/operator/MailboxSendOperator.java | 6 +-
.../query/runtime/operator/MultiStageOperator.java | 52 +-
.../runtime/operator/NonEquiJoinOperator.java | 7 +-
.../runtime/operator/WindowAggregateOperator.java | 7 +-
.../runtime/operator/utils/BlockingStream.java | 47 -
.../query/runtime/plan/MultiStageQueryStats.java | 4 -
.../plan/pipeline/PipelineBreakerOperator.java | 35 +-
.../plan/server/ServerPlanRequestUtils.java | 10 -
.../query/service/dispatch/QueryDispatcher.java | 196 ++-
.../AsyncQueryTimeSeriesDispatchResponse.java | 57 -
.../timeseries/TimeSeriesDispatchObserver.java | 15 +-
.../operator/EnrichedHashJoinOperatorTest.java | 1 -
.../runtime/operator/MailboxSendOperatorTest.java | 1 -
.../queries/PerQueryCPUMemAccountantTest.java | 13 +-
.../query/runtime/queries/QueryRunnerTestBase.java | 6 -
.../runtime/queries/ResourceBasedQueriesTest.java | 7 -
.../testutils/MockInstanceDataManagerFactory.java | 4 -
.../local/data/manager/TableDataManager.java | 8 +
.../indexsegment/mutable/MutableSegmentImpl.java | 5 +
.../converter/RealtimeSegmentConverter.java | 131 +-
.../CompactedDictEncodedColumnStatistics.java | 148 +++
.../CompactedRawIndexDictColumnStatistics.java | 152 +++
.../RealtimeSegmentSegmentCreationDataSource.java | 19 +-
.../stats/RealtimeSegmentStatsContainer.java | 111 +-
.../text/LuceneCombinedTextIndexConstants.java | 105 ++
.../creator/impl/text/LuceneTextIndexCombined.java | 260 ++++
.../creator/impl/text/LuceneTextIndexCreator.java | 68 +-
.../converter/SegmentV1V2ToV3FormatConverter.java | 13 +-
.../loader/invertedindex/TextIndexHandler.java | 139 ++-
.../readers/text/LuceneTextIndexBufferReader.java | 245 ++++
.../index/readers/text/LuceneTextIndexHeader.java | 103 ++
.../index/readers/text/LuceneTextIndexReader.java | 177 ++-
.../index/readers/text/PinotBufferIndexInput.java | 88 ++
.../readers/text/PinotBufferLuceneDirectory.java | 139 +++
.../segment/index/text/TextIndexConfigBuilder.java | 16 +
.../local/segment/index/text/TextIndexType.java | 22 +-
.../text/lucene/parsers/MatchQueryParser.java | 335 ++++++
.../readers/CompactedPinotSegmentRecordReader.java | 136 ++-
.../segment/store/SingleFileIndexDirectory.java | 5 +-
.../local/segment/store/TextIndexUtils.java | 2 +-
.../upsert/BasePartitionUpsertMetadataManager.java | 28 +-
.../segment/local/utils/LuceneTextIndexUtils.java | 11 +
.../segment/local/utils/TableConfigUtils.java | 63 +-
.../CompactedDictEncodedColumnStatisticsTest.java | 223 ++++
.../CompactedRawIndexDictColumnStatisticsTest.java | 152 +++
.../text/LuceneTextIndexBufferIntegrationTest.java | 210 ++++
.../text/LuceneTextIndexConfigReloadTest.java | 289 +++++
.../parsers/MinimumShouldMatchQueryParserTest.java | 266 ++++
.../org/apache/pinot/segment/spi/V1Constants.java | 1 +
.../pinot/segment/spi/index/TextIndexConfig.java | 65 +-
.../pinot/server/api/resources/TablesResource.java | 4 +
.../server/starter/helix/BaseServerStarter.java | 20 +-
.../helix/HelixInstanceDataManagerConfig.java | 8 +
.../helix/QueryWorkloadMessageHandlerFactory.java | 87 --
.../helix/SegmentMessageHandlerFactory.java | 51 +
.../SegmentOnlineOfflineStateModelFactory.java | 12 +
.../apache/pinot/server/api/BaseResourceTest.java | 7 +-
.../pinot/server/api/TablesResourceTest.java | 134 ++-
.../test/resources/data/test_data_with_delete.avro | Bin 14086590 -> 15615184
bytes
pinot-spi/pom.xml | 5 +
.../spi/accounting/WorkloadBudgetManager.java | 59 +-
.../config/instance/InstanceDataManagerConfig.java | 2 +
.../apache/pinot/spi/config/table/PauseState.java | 16 +-
.../pinot/spi/config/table/UpsertConfig.java | 11 +
.../apache/pinot/spi/exception/QueryErrorCode.java | 1 +
.../org/apache/pinot/spi/stream/MessageBatch.java | 5 +
.../spi/stream/PartitionGroupMetadataFetcher.java | 10 +-
.../java/org/apache/pinot/spi/trace/Tracing.java | 9 +-
.../apache/pinot/spi/utils/CommonConstants.java | 63 +-
.../provider/PinotClusterConfigProviderTest.java | 213 ++++
.../data/readers/AbstractRecordExtractorTest.java | 15 +-
.../spi/data/readers/AbstractRecordReaderTest.java | 23 +-
.../stream/PartitionGroupMetadataFetcherTest.java | 216 ++++
.../tsdb/planner/TimeSeriesPlanConstants.java | 58 -
pom.xml | 30 +-
234 files changed, 12740 insertions(+), 3015 deletions(-)
copy
pinot-broker/src/main/java/org/apache/pinot/broker/routing/instanceselector/{SegmentInstanceCandidate.java
=> InstanceSelectorConfig.java} (50%)
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/audit/AuditIdentityResolver.java
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/audit/AuditUrlPathFilter.java
rename {pinot-server/src/main/java/org/apache/pinot/server/starter/helix =>
pinot-common/src/main/java/org/apache/pinot/common/config}/DefaultClusterConfigChangeHandler.java
(98%)
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/config/provider/StaticTableCache.java
copy
pinot-common/src/main/java/org/apache/pinot/common/config/provider/{TableCache.java
=> ZkTableCache.java} (84%)
create mode 100644
pinot-common/src/main/java/org/apache/pinot/common/response/mapper/TimeSeriesResponseMapper.java
create mode 100644
pinot-common/src/main/java/org/apache/pinot/sql/parsers/rewriter/CastTypeAliasRewriter.java
create mode 100644
pinot-common/src/test/java/org/apache/pinot/common/audit/AuditIdentityResolverTest.java
create mode 100644
pinot-common/src/test/java/org/apache/pinot/common/audit/AuditUrlPathFilterTest.java
create mode 100644
pinot-common/src/test/java/org/apache/pinot/common/response/mapper/TimeSeriesResponseMapperTest.java
copy
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/index/forward/ForwardIndexPlugin.java
=>
pinot-connectors/pinot-spark-3-connector/src/main/scala/org/apache/pinot/connector/spark/v3/examples/read_pinot_from_proxy_with_auth_token.scala
(53%)
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/api/audit/AuditServiceBinder.java
delete mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/rebalance/tenant/DefaultTenantRebalancer.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/rebalance/tenant/TenantRebalanceChecker.java
create mode 100644
pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/rebalance/tenant/TenantRebalanceContext.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/api/resources/PinotQueryResourceStaticValidationTest.java
create mode 100644
pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/rebalance/tenant/TenantRebalanceCheckerTest.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/core/metadata/DefaultMetadataExtractorTest.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/queries/TextSearchQueriesWithCombinedFilesTest.java
create mode 100644
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/CommitTimeCompactionIntegrationTest.java
copy pinot-segment-local/src/test/resources/log4j2.xml =>
pinot-integration-tests/src/test/resources/log4j2-test.xml (74%)
delete mode 100644 pinot-integration-tests/src/test/resources/log4j2.xml
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/executor/OpChainScheduler.java
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/utils/BlockingStream.java
delete mode 100644
pinot-query-runtime/src/main/java/org/apache/pinot/query/service/dispatch/timeseries/AsyncQueryTimeSeriesDispatchResponse.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/realtime/converter/stats/CompactedDictEncodedColumnStatistics.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/realtime/converter/stats/CompactedRawIndexDictColumnStatistics.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/creator/impl/text/LuceneCombinedTextIndexConstants.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/creator/impl/text/LuceneTextIndexCombined.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/index/readers/text/LuceneTextIndexBufferReader.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/index/readers/text/LuceneTextIndexHeader.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/index/readers/text/PinotBufferIndexInput.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/index/readers/text/PinotBufferLuceneDirectory.java
create mode 100644
pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/index/text/lucene/parsers/MatchQueryParser.java
create mode 100644
pinot-segment-local/src/test/java/org/apache/pinot/segment/local/realtime/converter/stats/CompactedDictEncodedColumnStatisticsTest.java
create mode 100644
pinot-segment-local/src/test/java/org/apache/pinot/segment/local/realtime/converter/stats/CompactedRawIndexDictColumnStatisticsTest.java
create mode 100644
pinot-segment-local/src/test/java/org/apache/pinot/segment/local/segment/creator/impl/text/LuceneTextIndexBufferIntegrationTest.java
create mode 100644
pinot-segment-local/src/test/java/org/apache/pinot/segment/local/segment/index/text/LuceneTextIndexConfigReloadTest.java
create mode 100644
pinot-segment-local/src/test/java/org/apache/pinot/segment/local/segment/index/text/lucene/parsers/MinimumShouldMatchQueryParserTest.java
delete mode 100644
pinot-server/src/main/java/org/apache/pinot/server/starter/helix/QueryWorkloadMessageHandlerFactory.java
copy
pinot-plugins/pinot-input-format/pinot-parquet/src/test/resources/test-data/airlines_parquet/4345e5eef217aa1b-c8f16177f35fd983_1150363067_data.1.parq
=> pinot-server/src/test/resources/data/test_data_with_delete.avro (58%)
create mode 100644
pinot-spi/src/test/java/org/apache/pinot/spi/config/provider/PinotClusterConfigProviderTest.java
create mode 100644
pinot-spi/src/test/java/org/apache/pinot/spi/stream/PartitionGroupMetadataFetcherTest.java
delete mode 100644
pinot-timeseries/pinot-timeseries-planner/src/main/java/org/apache/pinot/tsdb/planner/TimeSeriesPlanConstants.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
