You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pinot.apache.org by xi...@apache.org on 2023/03/25 07:43:49 UTC
[pinot] branch dependabot/maven/org.yaml-snakeyaml-2.0 updated (6f83167f0b -> 39b87cad45)
This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a change to branch dependabot/maven/org.yaml-snakeyaml-2.0
in repository https://gitbox.apache.org/repos/asf/pinot.git
discard 6f83167f0b Bump snakeyaml from 1.33 to 2.0
add 585f62a3c7 allow to customize the httpclient used to create S3PinotFS (#10369)
add 52761fcb72 add the ability to change FilterOperatorUtils code (#10371)
add 3ffa7c3e32 [multistage][stats] clean up some stats (#10390)
add 7c3c8e8705 Allow replica group assignment support in tier configs (#10255)
add 221db828cf Let applyAnd to be applied using different window sizes (#10372)
add 6bd8a7dcff Enhance select order-by combine to use merge sort (#10357)
add dadd42cff1 Make startReplaceSegments() more robust for NPE (#10403)
add 5b289fc2e5 [multistage] Fix Leaks in Mailbox (#10322)
add b62033a3ac [multistage] early terminate from query dispatcher (#10401)
add 2607c0ee11 refine method name withForwardIndexDisabled (#10407)
add be9dfe74ad Bug Fix: Handle empty validDocId snapshots during reloading (#10406)
add 6db6d65adf 10271: Updated the code for handling the slash at the end for controller.data.dir (#10395)
add d475712d31 allow segment details page to load without indices (#10398)
add 41db04509f [Multistage] Allow queries on multiple tables of same tenant to be executed from controller UI (#10336)
add 15cb707e86 Encapsulate changes in IndexLoadingConfig and SegmentGeneratorConfig (#10352)
add f8d432013b [Index SPI] IndexType (#10191)
add 81ceb1d020 Simplify filtered aggregate transform operator creation (#10410)
add 3bad67db07 feat(ui): persist oidc auth details (#10389)
add 01ff18d47c Introduce BaseProjectOperator and ValueBlock (#10405)
add 0b111a1310 Fix JDBC driver check for username (#10416)
add 856503256f Adding Pinot base build/runtime image support for Amazon Corretto and MS OpenJDK (#10422)
add 11b6bcda50 [multistage] Fix Predicate Pushdown by Using Rule Collection (#10409)
add 0362ad369d Support multi-arch pinot docker image (#10429)
add ce299cfe80 try fixing mailbox cancel race condition (#10432)
add 16cae5d9c6 Add support to create realtime segment in local (#10433)
add 00284b9ede Refactor: Pass context instead on individual arguments to operator (#10413)
add 40a7911c53 Revert "Add support to create realtime segment in local (#10433)" (#10436)
add dcddb9ff02 Adding dropResults parameter in queryOptions to drop the resultTable field from the response (#10419)
add e01df9a7ce Data visitors (#10361)
add bc9aa75585 Add a PinotLogicalSortExchange to replace usage of LogicalSortExchange as it will be sender and receiver aware (#10408)
add dca5d383c6 [Clean up] Remove getColumnName() from AggregationFunction interface (#10431)
add bf5528c885 [multistage] Catch Throwable To Propagate Proper Error Message (#10438)
add 5673c8e6b2 RebalanceStatus API changes to track the status/progress of rebalance. (#10359)
add d9c4315ca1 Pinot Spark Connector for Spark3 (#10394)
add cb1069f11d Add Spark connector option for passing Pinot query options (#10443)
add 3687b2b732 Trying to setup node before Compatibility Regression Testing (#10440)
add 854e7f8d2a Index spi: index service (#10192)
add ee71befad3 Add "processAll" mode for MergeRollupTask (#10387)
add c0d0896ac3 Upgrade h2 version from 1.x to 2.x (#10456)
add 8452c25a09 fix jersey TerminalWriterInterceptor MessageBodyWriter not found issue (#10462)
add f3c2c0d98f Bug fix: Start counting operator execution time from first NoOp block (#10450)
add abe47bfc52 Fix unavailable instances issues for StrictReplicaGroup (#10466)
add 11272b7eb2 Added optional force param to the table configs update API (#10441)
add 316842f66e [multistage] Support array type for select query (#10434)
add 8bfb0b82b2 Change shell to bash (#10469)
add 40b2a65287 Fix the double destroy of segment data manager during server shutdown (#10475)
add 3f36623c56 Enhance broker reduce to handle different column names from server response (#10454)
add d1227e466d [feature] [null support # 1] selection only literal in broker null support (#10376)
add ea0ecde9ed Remove "isSorted()" precondition check in the ForwardIndexHandler (#10476)
add 173edb4925 Bump json-smart from 2.4.7 to 2.4.10 (#10471)
add 39b87cad45 Bump snakeyaml from 1.33 to 2.0
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 (6f83167f0b)
\
N -- N -- N refs/heads/dependabot/maven/org.yaml-snakeyaml-2.0 (39b87cad45)
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:
.../build-multi-arch-pinot-docker-image.yml | 108 ++
.../workflows/build-pinot-base-docker-image.yml | 50 +
.github/workflows/build-pinot-docker-image.yml | 6 +-
.github/workflows/build-presto-docker-image.yml | 6 +-
.github/workflows/build-superset-docker-image.yml | 6 +-
.github/workflows/pinot_compatibility_tests.yml | 14 +-
.github/workflows/pinot_tests.yml | 40 +-
.../scripts/.pinot_compatibility_verifier.sh | 15 +
.../.pinot_base_docker_image_build_and_push.sh | 37 +
.../scripts/docker/.pinot_build_info_gen.sh | 41 +
...not_multi_arch_docker_image_manifest_package.sh | 62 +
.../.pinot_single_platform_docker_image_build.sh | 66 +
compatibility-verifier/checkoutAndBuild.sh | 31 +-
docker/images/pinot-base/README.md | 34 +-
.../{Dockerfile => amazoncorretto.dockerfile} | 32 +-
.../{Dockerfile => ms-openjdk.dockerfile} | 4 +-
.../{Dockerfile => openjdk.dockerfile} | 4 +-
.../{Dockerfile => amazoncorretto.dockerfile} | 11 +-
.../{Dockerfile => ms-openjdk.dockerfile} | 7 +-
.../{Dockerfile => openjdk.dockerfile} | 4 +-
pinot-broker/pom.xml | 5 +
.../requesthandler/BaseBrokerRequestHandler.java | 17 +-
.../instanceselector/BalancedInstanceSelector.java | 60 +-
.../instanceselector/BaseInstanceSelector.java | 461 +++--
.../routing/instanceselector/InstanceSelector.java | 6 +
.../instanceselector/InstanceSelectorFactory.java | 33 +-
.../MultiStageReplicaGroupSelector.java | 42 +-
.../routing/instanceselector/NewSegmentState.java | 51 +
.../ReplicaGroupInstanceSelector.java | 126 +-
.../instanceselector/SegmentInstanceCandidate.java | 33 +-
.../routing/instanceselector/SegmentStates.java | 57 +
.../StrictReplicaGroupInstanceSelector.java | 165 +-
.../instanceselector/InstanceSelectorTest.java | 803 +++++++-
.../org/apache/pinot/client/utils/DriverUtils.java | 2 +-
.../assignment/InstanceAssignmentConfigUtils.java | 20 +-
.../common/assignment/InstancePartitionsUtils.java | 16 +
.../apache/pinot/common/datatable/DataTable.java | 6 +-
.../pinot/common/exception/QueryException.java | 2 +
.../pinot/common/function/FunctionInvoker.java | 12 +
.../pinot/common/metadata/ZKMetadataProvider.java | 31 +-
.../metadata/controllerjob/ControllerJobType.java | 4 +-
.../request/context/RequestContextUtils.java | 4 +
.../response/broker/BrokerResponseNative.java | 5 +-
.../response/broker/BrokerResponseNativeV2.java | 3 +-
.../response/broker/BrokerResponseStats.java | 32 +-
.../org/apache/pinot/common/utils/DataSchema.java | 69 +-
.../common/utils/config/QueryOptionsUtils.java | 5 +
.../common/utils/config/TableConfigUtils.java | 13 +-
.../pinot/common/utils/request/RequestUtils.java | 20 +-
.../apache/pinot/sql/parsers/CalciteSqlParser.java | 41 +
.../rewriter/CompileTimeFunctionsInvoker.java | 8 +-
pinot-common/src/main/proto/worker.proto | 10 +
.../apache/pinot/common/utils/DataSchemaTest.java | 31 +-
.../common/utils/config/TableConfigSerDeTest.java | 10 +-
.../pinot/sql/parsers/CalciteSqlCompilerTest.java | 44 +
pinot-connectors/pinot-spark-2-connector/README.md | 22 +-
.../documentation/read_model.md | 9 +-
.../spark/datasource/PinotDataSourceReader.scala | 9 +-
.../connector/spark/datasource/TypeConverter.scala | 14 +-
.../spark/datasource/TypeConverterTest.scala | 31 +
.../README.md | 23 +-
...pinot-connector-executor-server-interaction.jpg | Bin
.../documentation/read_model.md | 9 +-
pinot-connectors/pinot-spark-3-connector/pom.xml | 324 ++++
...org.apache.spark.sql.sources.DataSourceRegister | 1 +
.../spark/v3/datasource/PinotDataSource.scala | 55 +
.../spark/v3/datasource/PinotInputPartition.scala | 42 +
.../connector/spark/v3/datasource/PinotScan.scala | 97 +
.../spark/v3/datasource/PinotScanBuilder.scala | 82 +
.../connector/spark/v3/datasource/PinotTable.scala | 50 +
.../spark/v3}/datasource/TypeConverter.scala | 27 +-
.../spark/v3/datasource/query/FilterPushDown.scala | 123 ++
.../src/test/resources/log4j2.xml | 0
.../src/test/resources/schema/pinot-schema.json | 75 +
.../src/test/resources/schema/spark-schema.json | 105 ++
.../connector/spark/v3/datasource/BaseTest.scala | 11 +-
.../ExampleSparkPinotConnectorTest.scala | 212 +++
.../spark/v3/datasource/PinotScanBuilderTest.scala | 51 +
.../spark/v3/datasource/PinotScanTest.scala | 51 +
.../spark/v3}/datasource/TypeConverterTest.scala | 35 +-
.../v3/datasource/query/FilterPushDownTest.scala | 75 +
.../spark/common/PinotDataSourceReadOptions.scala | 11 +-
.../spark/common/query/ScanQueryGenerator.scala | 14 +-
.../common/PinotDataSourceReadOptionsTest.scala | 4 +-
.../connector/spark/common/PinotSplitterTest.scala | 6 +-
.../common/query/ScanQueryGeneratorTest.scala | 22 +-
pinot-connectors/pom.xml | 1 +
.../apache/pinot/controller/ControllerConf.java | 3 +-
.../PinotInstanceAssignmentRestletResource.java | 188 +-
.../api/resources/PinotQueryResource.java | 60 +-
.../api/resources/PinotRealtimeTableResource.java | 8 +-
.../api/resources/PinotSchemaRestletResource.java | 2 +-
.../api/resources/PinotSegmentRestletResource.java | 3 +-
.../api/resources/PinotTableRestletResource.java | 111 +-
.../api/resources/PinotTaskRestletResource.java | 35 +
.../ServerRebalanceJobStatusResponse.java | 36 +-
.../api/resources/TableConfigsRestletResource.java | 11 +-
.../helix/core/PinotHelixResourceManager.java | 120 +-
.../instance/InstanceAssignmentDriver.java | 32 +-
.../core/rebalance/NoOpTableRebalanceObserver.java | 30 +-
.../helix/core/rebalance/RebalanceResult.java | 18 +-
.../core/rebalance/TableRebalanceObserver.java | 46 +
.../rebalance/TableRebalanceProgressStats.java | 130 ++
.../helix/core/rebalance/TableRebalancer.java | 225 ++-
.../rebalance/ZkBasedTableRebalanceObserver.java | 197 ++
.../helix/core/relocation/SegmentRelocator.java | 5 +-
pinot-controller/src/main/resources/app/App.tsx | 240 +--
.../app/components/AppLoadingIndicator.tsx | 36 +-
.../resources/app/components/auth/AuthProvider.tsx | 269 +++
pinot-controller/src/main/resources/app/index.tsx | 42 +
.../src/main/resources/app/interfaces/types.d.ts | 5 +
.../main/resources/app/utils/PinotMethodUtils.ts | 14 +-
.../src/main/resources/app/utils/axios-config.ts | 89 +-
.../src/main/resources/webpack.config.js | 2 +-
.../pinot/controller/ControllerConfTest.java | 23 +
...anceAssignmentRestletResourceStatelessTest.java | 141 +-
.../api/TableConfigsRestletResourceTest.java | 40 +
.../pinot/controller/helix/TableCacheTest.java | 2 +-
.../instance/InstanceAssignmentTest.java | 64 +-
.../TableRebalancerClusterStatelessTest.java | 127 +-
.../TestZkBasedTableRebalanceObserver.java | 106 ++
.../apache/pinot/core/common/MinionConstants.java | 3 +
.../core/common/datablock/DataBlockBuilder.java | 8 +
.../offline/ImmutableSegmentDataManager.java | 2 +-
.../realtime/HLRealtimeSegmentDataManager.java | 6 +-
.../realtime/LLRealtimeSegmentDataManager.java | 10 +-
.../function/BaseBinaryGeoTransformFunction.java | 54 +-
.../function/ConstructFromTextFunction.java | 12 +-
.../function/ConstructFromWKBFunction.java | 12 +-
.../transform/function/GeoToH3Function.java | 22 +-
.../transform/function/StAreaFunction.java | 12 +-
.../transform/function/StAsBinaryFunction.java | 12 +-
.../transform/function/StAsTextFunction.java | 12 +-
.../transform/function/StContainsFunction.java | 6 +-
.../transform/function/StDistanceFunction.java | 6 +-
.../transform/function/StEqualsFunction.java | 6 +-
.../transform/function/StGeometryTypeFunction.java | 12 +-
.../transform/function/StPointFunction.java | 14 +-
.../transform/function/StPolygonFunction.java | 8 +-
.../transform/function/StWithinFunction.java | 6 +-
...ransformBlock.java => BaseProjectOperator.java} | 31 +-
.../core/operator/BitmapDocIdSetOperator.java | 5 +
.../apache/pinot/core/operator/ColumnContext.java | 73 +
.../pinot/core/operator/ProjectionOperator.java | 28 +-
.../core/operator/blocks/ProjectionBlock.java | 13 +-
.../pinot/core/operator/blocks/TransformBlock.java | 29 +-
...sThroughTransformBlock.java => ValueBlock.java} | 35 +-
.../blocks/results/AggregationResultsBlock.java | 20 +-
.../operator/blocks/results/BaseResultsBlock.java | 3 +-
.../blocks/results/DistinctResultsBlock.java | 2 +-
.../blocks/results/ExceptionResultsBlock.java | 4 +-
.../blocks/results/ExplainResultsBlock.java | 3 +-
.../blocks/results/GroupByResultsBlock.java | 2 +-
.../blocks/results/MetadataResultsBlock.java | 4 +-
.../operator/blocks/results/ResultsBlockUtils.java | 14 +-
.../blocks/results/SelectionResultsBlock.java | 47 +-
.../combine/BaseSingleBlockCombineOperator.java | 2 +-
...xValueBasedSelectionOrderByCombineOperator.java | 21 +-
.../combine/merger/ResultsBlockMerger.java | 10 -
.../merger/SelectionOnlyResultsBlockMerger.java | 7 +-
.../merger/SelectionOrderByResultsBlockMerger.java | 15 +-
.../ExpressionScanDocIdIterator.java | 16 +
.../dociditerators/MVScanDocIdIterator.java | 20 +-
.../dociditerators/SVScanDocIdIterator.java | 50 +-
.../dociditerators/ScanBasedDocIdIterator.java | 11 +-
.../core/operator/docidsets/SVScanDocIdSet.java | 4 +-
.../operator/docvalsets/TransformBlockValSet.java | 44 +-
.../operator/filter/CombinedFilterOperator.java | 8 +-
.../operator/filter/ExpressionFilterOperator.java | 19 +-
.../core/operator/filter/FilterOperatorUtils.java | 369 ++--
.../operator/filter/ScanBasedFilterOperator.java | 13 +-
.../predicate/EqualsPredicateEvaluatorFactory.java | 78 +-
.../predicate/InPredicateEvaluatorFactory.java | 67 +-
.../NotEqualsPredicateEvaluatorFactory.java | 72 +-
.../predicate/NotInPredicateEvaluatorFactory.java | 68 +-
.../core/operator/query/AggregationOperator.java | 27 +-
.../core/operator/query/DistinctOperator.java | 29 +-
.../operator/query/EmptySelectionOperator.java | 21 +-
.../query/FilteredAggregationOperator.java | 32 +-
.../operator/query/FilteredGroupByOperator.java | 70 +-
.../pinot/core/operator/query/GroupByOperator.java | 30 +-
.../query/LinearSelectionOrderByOperator.java | 148 +-
.../core/operator/query/SelectionOnlyOperator.java | 34 +-
.../operator/query/SelectionOrderByOperator.java | 86 +-
.../SelectionPartiallyOrderedByAscOperator.java | 16 +-
.../SelectionPartiallyOrderedByDescOperation.java | 16 +-
.../streaming/StreamingSelectionOnlyOperator.java | 33 +-
.../transform/PassThroughTransformOperator.java | 54 -
.../core/operator/transform/TransformOperator.java | 71 +-
.../function/AdditionTransformFunction.java | 22 +-
.../function/ArrayAverageTransformFunction.java | 18 +-
.../function/ArrayLengthTransformFunction.java | 20 +-
.../function/ArrayMaxTransformFunction.java | 46 +-
.../function/ArrayMinTransformFunction.java | 46 +-
.../function/ArraySumTransformFunction.java | 12 +-
.../transform/function/BaseTransformFunction.java | 196 +-
.../function/BinaryOperatorTransformFunction.java | 240 +--
.../transform/function/CaseTransformFunction.java | 84 +-
.../transform/function/CastTransformFunction.java | 170 +-
.../function/CoalesceTransformFunction.java | 101 +-
.../DateTimeConversionTransformFunction.java | 26 +-
.../function/DateTimeTransformFunction.java | 12 +-
.../function/DateTruncTransformFunction.java | 12 +-
.../function/DistinctFromTransformFunction.java | 20 +-
.../function/DivisionTransformFunction.java | 26 +-
.../function/ExtractTransformFunction.java | 12 +-
.../function/GreatestTransformFunction.java | 50 +-
.../function/GroovyTransformFunction.java | 76 +-
.../function/IdentifierTransformFunction.java | 78 +-
.../function/InIdSetTransformFunction.java | 22 +-
.../transform/function/InTransformFunction.java | 56 +-
.../function/IsNotNullTransformFunction.java | 27 +-
.../function/IsNullTransformFunction.java | 26 +-
.../function/JsonExtractKeyTransformFunction.java | 12 +-
.../JsonExtractScalarTransformFunction.java | 183 +-
.../transform/function/LeastTransformFunction.java | 50 +-
.../function/LiteralTransformFunction.java | 52 +-
.../function/LogicalOperatorTransformFunction.java | 14 +-
.../function/LookupTransformFunction.java | 119 +-
.../function/MapValueTransformFunction.java | 14 +-
.../function/ModuloTransformFunction.java | 14 +-
.../function/MultiplicationTransformFunction.java | 22 +-
.../transform/function/NotInTransformFunction.java | 12 +-
.../function/NotOperatorTransformFunction.java | 12 +-
.../transform/function/PowerTransformFunction.java | 14 +-
.../function/RegexpExtractTransformFunction.java | 12 +-
.../function/RoundDecimalTransformFunction.java | 14 +-
.../function/ScalarTransformFunctionWrapper.java | 132 +-
.../SelectTupleElementTransformFunction.java | 4 +-
.../function/SingleParamMathTransformFunction.java | 26 +-
.../function/SubtractionTransformFunction.java | 26 +-
.../function/TimeConversionTransformFunction.java | 12 +-
.../transform/function/TransformFunction.java | 119 +-
.../function/TransformFunctionFactory.java | 20 +-
.../function/TrigonometricTransformFunctions.java | 14 +-
.../function/TruncateDecimalTransformFunction.java | 14 +-
.../function/ValueInTransformFunction.java | 54 +-
.../pinot/core/plan/AggregationPlanNode.java | 32 +-
.../apache/pinot/core/plan/DistinctPlanNode.java | 8 +-
.../apache/pinot/core/plan/GroupByPlanNode.java | 50 +-
...TransformPlanNode.java => ProjectPlanNode.java} | 41 +-
.../apache/pinot/core/plan/ProjectionPlanNode.java | 65 -
.../apache/pinot/core/plan/SelectionPlanNode.java | 37 +-
.../core/plan/StreamingSelectionPlanNode.java | 6 +-
.../query/aggregation/AggregationExecutor.java | 8 +-
.../aggregation/DefaultAggregationExecutor.java | 9 +-
.../aggregation/function/AggregationFunction.java | 5 -
.../function/AggregationFunctionUtils.java | 173 +-
.../BaseSingleInputAggregationFunction.java | 5 -
.../function/CountAggregationFunction.java | 6 -
.../function/CountMVAggregationFunction.java | 5 -
.../function/CovarianceAggregationFunction.java | 5 -
.../function/DistinctAggregationFunction.java | 14 +-
...irstDoubleValueWithTimeAggregationFunction.java | 24 +-
...FirstFloatValueWithTimeAggregationFunction.java | 25 +-
.../FirstIntValueWithTimeAggregationFunction.java | 28 +-
.../FirstLongValueWithTimeAggregationFunction.java | 24 +-
...irstStringValueWithTimeAggregationFunction.java | 20 +-
...LastDoubleValueWithTimeAggregationFunction.java | 24 +-
.../LastFloatValueWithTimeAggregationFunction.java | 25 +-
.../LastIntValueWithTimeAggregationFunction.java | 28 +-
.../LastLongValueWithTimeAggregationFunction.java | 24 +-
...LastStringValueWithTimeAggregationFunction.java | 20 +-
.../function/PercentileAggregationFunction.java | 6 -
.../function/PercentileEstAggregationFunction.java | 6 -
.../PercentileEstMVAggregationFunction.java | 6 -
.../function/PercentileMVAggregationFunction.java | 6 -
.../PercentileRawEstAggregationFunction.java | 9 -
.../PercentileRawTDigestAggregationFunction.java | 9 -
.../PercentileSmartTDigestAggregationFunction.java | 5 -
.../PercentileTDigestAggregationFunction.java | 6 -
.../PercentileTDigestMVAggregationFunction.java | 6 -
.../groupby/DefaultGroupByExecutor.java | 50 +-
.../groupby/DictionaryBasedGroupKeyGenerator.java | 29 +-
.../query/aggregation/groupby/GroupByExecutor.java | 8 +-
.../aggregation/groupby/GroupKeyGenerator.java | 18 +-
.../NoDictionaryMultiColumnGroupKeyGenerator.java | 31 +-
.../NoDictionarySingleColumnGroupKeyGenerator.java | 38 +-
.../core/query/distinct/DistinctExecutor.java | 6 +-
.../query/distinct/DistinctExecutorFactory.java | 79 +-
...ionaryBasedMultiColumnDistinctOnlyExecutor.java | 10 +-
...aryBasedMultiColumnDistinctOrderByExecutor.java | 10 +-
...onaryBasedSingleColumnDistinctOnlyExecutor.java | 8 +-
...ryBasedSingleColumnDistinctOrderByExecutor.java | 8 +-
...BigDecimalSingleColumnDistinctOnlyExecutor.java | 8 +-
...DecimalSingleColumnDistinctOrderByExecutor.java | 8 +-
.../RawBytesSingleColumnDistinctOnlyExecutor.java | 8 +-
...awBytesSingleColumnDistinctOrderByExecutor.java | 8 +-
.../RawDoubleSingleColumnDistinctOnlyExecutor.java | 8 +-
...wDoubleSingleColumnDistinctOrderByExecutor.java | 8 +-
.../RawFloatSingleColumnDistinctOnlyExecutor.java | 8 +-
...awFloatSingleColumnDistinctOrderByExecutor.java | 8 +-
.../RawIntSingleColumnDistinctOnlyExecutor.java | 8 +-
.../RawIntSingleColumnDistinctOrderByExecutor.java | 8 +-
.../RawLongSingleColumnDistinctOnlyExecutor.java | 8 +-
...RawLongSingleColumnDistinctOrderByExecutor.java | 8 +-
.../raw/RawMultiColumnDistinctExecutor.java | 10 +-
.../RawStringSingleColumnDistinctOnlyExecutor.java | 8 +-
...wStringSingleColumnDistinctOrderByExecutor.java | 8 +-
.../query/reduce/AggregationDataTableReducer.java | 38 +-
.../query/reduce/ExecutionStatsAggregator.java | 40 +-
.../query/reduce/SelectionDataTableReducer.java | 92 +-
.../query/selection/SelectionOperatorService.java | 10 +-
.../query/selection/SelectionOperatorUtils.java | 207 +-
.../core/query/utils/OrderByComparatorFactory.java | 118 +-
.../executor/StarTreeAggregationExecutor.java | 8 +-
.../startree/executor/StarTreeGroupByExecutor.java | 12 +-
...mPlanNode.java => StarTreeProjectPlanNode.java} | 56 +-
.../startree/plan/StarTreeProjectionPlanNode.java | 52 -
.../apache/pinot/core/util/trace/TraceContext.java | 7 +-
.../core/common/datablock/DataBlockTestUtils.java | 5 +
.../core/common/datatable/DataTableSerDeTest.java | 7 +
.../blocks/results/ResultsBlockUtilsTest.java | 19 +-
.../combine/SelectionCombineOperatorTest.java | 30 +-
.../predicate/InPredicateEvaluatorFactoryTest.java | 115 ++
.../query/LinearSelectionOrderByOperatorTest.java | 26 +-
.../function/AggregationFunctionFactoryTest.java | 88 +-
.../DictionaryBasedGroupKeyGeneratorTest.java | 54 +-
.../groupby/NoDictionaryGroupKeyGeneratorTest.java | 24 +-
.../selection/SelectionOperatorServiceTest.java | 121 +-
.../pinot/queries/ExplainPlanQueriesTest.java | 1583 ++++++++--------
...dexDisabledMultiValueQueriesWithReloadTest.java | 4 +-
...ForwardIndexDisabledSingleValueQueriesTest.java | 4 +-
.../ForwardIndexHandlerReloadQueriesTest.java | 14 +-
...erSegmentAggregationSingleValueQueriesTest.java | 6 +-
...InnerSegmentSelectionMultiValueQueriesTest.java | 11 +-
...erSegmentSelectionMultiValueRawQueriesTest.java | 9 +-
...nnerSegmentSelectionSingleValueQueriesTest.java | 63 +-
...terSegmentAggregationMultiValueQueriesTest.java | 2 +-
...SegmentAggregationMultiValueRawQueriesTest.java | 2 +-
.../NoDictionaryCompressionQueriesTest.java | 2 +-
.../org/apache/pinot/queries/RangeQueriesTest.java | 8 +-
.../tests/ClusterIntegrationTestUtils.java | 31 +-
.../pinot/integration/tests/ClusterTest.java | 10 +
.../pinot/integration/tests/QueryGenerator.java | 46 +-
.../tests/BaseClusterIntegrationTestSet.java | 7 +-
.../tests/HybridClusterIntegrationTest.java | 15 +
.../MergeRollupMinionClusterIntegrationTest.java | 157 +-
...ltiStageEngineCustomTenantIntegrationTest.java} | 34 +-
.../tests/MultiStageEngineIntegrationTest.java | 15 +-
.../tests/NullHandlingIntegrationTest.java | 100 +
.../tests/OfflineClusterIntegrationTest.java | 9 +-
...rformance_2014_100k_subset.test_queries_10K.sql | 1972 ++++++++++----------
...rformance_2014_100k_subset.test_queries_200.sql | 70 +-
pinot-plugins/pinot-file-system/pinot-s3/pom.xml | 5 +
.../apache/pinot/plugin/filesystem/S3Config.java | 73 +-
.../apache/pinot/plugin/filesystem/S3PinotFS.java | 3 +
.../pinot/plugin/filesystem/S3ConfigTest.java | 47 +
.../mergerollup/MergeRollupTaskGenerator.java | 258 ++-
.../rel/logical/PinotLogicalSortExchange.java | 112 ++
.../calcite/rel/rules/PinotQueryRuleSets.java | 66 +-
.../rel/rules/PinotSortExchangeCopyRule.java | 4 +-
.../rel/rules/PinotSortExchangeNodeInsertRule.java | 11 +-
.../rules/PinotWindowExchangeNodeInsertRule.java | 17 +-
.../org/apache/pinot/query/QueryEnvironment.java | 29 +-
.../query/planner/logical/RelToStageConverter.java | 24 +-
.../pinot/query/planner/logical/StagePlanner.java | 34 +-
.../query/planner/stage/MailboxReceiveNode.java | 46 +
.../pinot/query/planner/stage/MailboxSendNode.java | 42 +-
.../org/apache/pinot/query/type/TypeFactory.java | 27 +-
.../rel/rules/PinotSortExchangeCopyRuleTest.java | 89 +-
.../planner/logical/RelToStageConverterTest.java | 133 ++
.../apache/pinot/query/type/TypeFactoryTest.java | 105 ++
.../src/test/resources/queries/AggregatePlans.json | 60 +-
.../test/resources/queries/BasicQueryPlans.json | 4 +-
.../src/test/resources/queries/GroupByPlans.json | 96 +-
.../src/test/resources/queries/JoinPlans.json | 78 +-
.../src/test/resources/queries/OrderByPlans.json | 16 +-
.../resources/queries/WindowFunctionPlans.json | 176 +-
.../pinot/query/mailbox/GrpcMailboxService.java | 112 +-
.../pinot/query/mailbox/GrpcReceivingMailbox.java | 39 +-
.../pinot/query/mailbox/GrpcSendingMailbox.java | 79 +-
.../query/mailbox/InMemoryMailboxService.java | 65 +-
.../query/mailbox/InMemoryReceivingMailbox.java | 34 +-
.../query/mailbox/InMemorySendingMailbox.java | 49 +-
.../apache/pinot/query/mailbox/MailboxService.java | 44 +-
.../query/mailbox/MultiplexingMailboxService.java | 15 +-
.../pinot/query/mailbox/ReceivingMailbox.java | 50 +-
.../apache/pinot/query/mailbox/SendingMailbox.java | 42 +-
.../mailbox/channel/InMemoryTransferStream.java | 101 +
.../channel/MailboxContentStreamObserver.java | 162 +-
.../channel/MailboxStatusStreamObserver.java | 12 +-
.../apache/pinot/query/runtime/QueryRunner.java | 81 +-
.../runtime/executor/OpChainSchedulerService.java | 40 +-
.../query/runtime/operator/AggregateOperator.java | 20 +-
.../query/runtime/operator/FilterOperator.java | 8 +-
.../query/runtime/operator/HashJoinOperator.java | 8 +-
.../LeafStageTransferableBlockOperator.java | 8 +-
.../runtime/operator/LiteralValueOperator.java | 8 +-
.../runtime/operator/MailboxReceiveOperator.java | 102 +-
.../runtime/operator/MailboxSendOperator.java | 64 +-
.../query/runtime/operator/MultiStageOperator.java | 22 +-
.../pinot/query/runtime/operator/OpChain.java | 5 +
.../pinot/query/runtime/operator/OpChainId.java | 4 +
.../query/runtime/operator/OperatorStats.java | 23 +-
.../pinot/query/runtime/operator/SortOperator.java | 69 +-
.../query/runtime/operator/TransformOperator.java | 8 +-
.../runtime/operator/WindowAggregateOperator.java | 25 +-
.../runtime/operator/exchange/BlockExchange.java | 31 +-
.../operator/exchange/BroadcastExchange.java | 3 +-
.../runtime/operator/exchange/HashExchange.java | 3 +-
.../runtime/operator/exchange/RandomExchange.java | 3 +-
.../operator/exchange/SingletonExchange.java | 3 +-
.../query/runtime/operator/utils/SortUtils.java | 73 +
...stContext.java => OpChainExecutionContext.java} | 61 +-
.../query/runtime/plan/PhysicalPlanVisitor.java | 53 +-
.../query/runtime/plan/PlanRequestContext.java | 16 +-
.../runtime/plan/ServerRequestPlanVisitor.java | 10 +-
.../plan/server/ServerPlanRequestContext.java | 6 +-
.../apache/pinot/query/service/QueryServer.java | 6 +
.../query/service/dispatch/CancelObserver.java | 29 +-
.../query/service/dispatch/DispatchClient.java | 11 +
.../query/service/dispatch/QueryDispatcher.java | 85 +-
.../java/org/apache/pinot/query/QueryTestSet.java | 2 +-
.../query/mailbox/GrpcMailboxServiceTest.java | 224 ++-
.../query/mailbox/InMemoryMailboxServiceTest.java | 121 +-
.../mailbox/MultiplexingMailboxServiceTest.java | 8 +-
.../pinot/query/runtime/QueryRunnerTest.java | 24 +-
.../pinot/query/runtime/QueryRunnerTestBase.java | 163 +-
.../executor/OpChainSchedulerServiceTest.java | 102 +-
.../runtime/operator/AggregateOperatorTest.java | 31 +-
.../query/runtime/operator/FilterOperatorTest.java | 45 +-
.../runtime/operator/HashJoinOperatorTest.java | 44 +-
.../LeafStageTransferableBlockOperatorTest.java | 26 +-
.../runtime/operator/LiteralValueOperatorTest.java | 4 +-
.../operator/MailboxReceiveOperatorTest.java | 587 +++++-
.../runtime/operator/MailboxSendOperatorTest.java | 95 +-
.../query/runtime/operator/OperatorTestUtil.java | 28 +-
.../query/runtime/operator/SortOperatorTest.java | 168 +-
.../runtime/operator/TransformOperatorTest.java | 35 +-
.../operator/WindowAggregateOperatorTest.java | 241 +--
.../operator/exchange/BlockExchangeTest.java | 12 +-
.../operator/exchange/BroadcastExchangeTest.java | 3 +-
.../operator/exchange/HashExchangeTest.java | 3 +-
.../operator/exchange/RandomExchangeTest.java | 3 +-
.../operator/exchange/SingletonExchangeTest.java | 3 +-
.../runtime/queries/ResourceBasedQueriesTest.java | 35 +-
.../service/dispatch/QueryDispatcherTest.java | 59 +
.../src/test/resources/queries/Aggregates.json | 3 +-
.../src/test/resources/queries/BooleanLogic.json | 16 +-
.../src/test/resources/queries/Case.json | 6 +-
.../test/resources/queries/FromExpressions.json | 30 +-
.../src/test/resources/queries/OrderBy.json | 18 +-
.../src/test/resources/queries/Parallelism.json | 10 +-
.../test/resources/queries/SelectExpressions.json | 14 +-
.../src/test/resources/queries/TypeCasting.json | 6 +-
pinot-segment-local/pom.xml | 4 +
.../local/data/manager/SegmentDataManager.java | 14 +-
.../indexsegment/mutable/MutableSegmentImpl.java | 3 +-
.../RealtimeIndexOffHeapMemoryManager.java | 37 +-
.../creator/impl/SegmentColumnarIndexCreator.java | 2 +-
.../impl/bloom/OnHeapGuavaBloomFilterCreator.java | 16 +
.../segment/index/bloom/BloomIndexPlugin.java | 24 +-
.../local/segment/index/bloom/BloomIndexType.java | 113 ++
.../segment/index/loader/BaseIndexHandler.java | 1 +
.../segment/index/loader/ForwardIndexHandler.java | 4 -
.../segment/index/loader/IndexHandlerFactory.java | 1 +
.../segment/index/loader/IndexLoadingConfig.java | 155 +-
...IndexAndDictionaryBasedForwardIndexCreator.java | 5 +-
.../segment/index/loader/SegmentPreProcessor.java | 1 +
.../upsert/BasePartitionUpsertMetadataManager.java | 1 +
.../segment/local/utils/TableConfigUtils.java | 3 +-
.../index/loader/ForwardIndexHandlerTest.java | 212 +--
.../index/loader/SegmentPreProcessorTest.java | 293 ++-
.../segment/local/utils/TableConfigUtilsTest.java | 8 +-
.../segment/spi/creator/IndexCreationContext.java | 2 +-
.../spi/creator/SegmentGeneratorConfig.java | 61 +-
.../pinot/segment/spi/index/FieldIndexConfigs.java | 119 ++
.../pinot/segment/spi/index/IndexCreator.java | 65 +
.../pinot/segment/spi/index}/IndexHandler.java | 2 +-
.../pinot/segment/spi/index/IndexPlugin.java | 35 +
.../pinot/segment/spi/index/IndexReader.java | 11 +-
.../spi/index/IndexReaderConstraintException.java | 39 +-
.../segment/spi/index/IndexReaderFactory.java | 55 +
.../pinot/segment/spi/index/IndexService.java | 148 ++
.../apache/pinot/segment/spi/index/IndexType.java | 121 ++
.../pinot/segment/spi/index/StandardIndexes.java | 59 +
.../spi/index/creator/BloomFilterCreator.java | 31 +-
.../spi/index/reader/BloomFilterReader.java | 4 +-
.../segment/spi/index/FieldIndexConfigsTest.java} | 33 +-
.../pinot/spi/config/table/BloomFilterConfig.java | 34 +-
.../{BloomFilterConfig.java => IndexConfig.java} | 43 +-
.../apache/pinot/spi/config/table/TableConfig.java | 8 +-
.../java/org/apache/pinot/spi/data/FieldSpec.java | 3 +-
.../apache/pinot/spi/data/MultiValueVisitor.java | 99 +
.../apache/pinot/spi/data/SingleValueVisitor.java | 34 +-
.../apache/pinot/spi/utils/CommonConstants.java | 2 +
.../pinot/spi/utils/RebalanceConfigConstants.java | 6 +
.../utils/builder/ControllerRequestURLBuilder.java | 2 +-
.../spi/utils/builder/TableConfigBuilder.java | 4 +-
.../apache/pinot/tools/PinotTableRebalancer.java | 2 +
.../src/main/resources/appAssemblerScriptTemplate | 2 +-
pom.xml | 17 +-
493 files changed, 16701 insertions(+), 8479 deletions(-)
create mode 100644 .github/workflows/build-multi-arch-pinot-docker-image.yml
create mode 100644 .github/workflows/build-pinot-base-docker-image.yml
create mode 100755 .github/workflows/scripts/docker/.pinot_base_docker_image_build_and_push.sh
create mode 100755 .github/workflows/scripts/docker/.pinot_build_info_gen.sh
create mode 100755 .github/workflows/scripts/docker/.pinot_multi_arch_docker_image_manifest_package.sh
create mode 100755 .github/workflows/scripts/docker/.pinot_single_platform_docker_image_build.sh
copy docker/images/pinot-base/pinot-base-build/{Dockerfile => amazoncorretto.dockerfile} (60%)
copy docker/images/pinot-base/pinot-base-build/{Dockerfile => ms-openjdk.dockerfile} (94%)
rename docker/images/pinot-base/pinot-base-build/{Dockerfile => openjdk.dockerfile} (95%)
copy docker/images/pinot-base/pinot-base-runtime/{Dockerfile => amazoncorretto.dockerfile} (84%)
copy docker/images/pinot-base/pinot-base-runtime/{Dockerfile => ms-openjdk.dockerfile} (91%)
rename docker/images/pinot-base/pinot-base-runtime/{Dockerfile => openjdk.dockerfile} (95%)
create mode 100644 pinot-broker/src/main/java/org/apache/pinot/broker/routing/instanceselector/NewSegmentState.java
copy pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/creator/BloomFilterCreator.java => pinot-broker/src/main/java/org/apache/pinot/broker/routing/instanceselector/SegmentInstanceCandidate.java (61%)
create mode 100644 pinot-broker/src/main/java/org/apache/pinot/broker/routing/instanceselector/SegmentStates.java
copy pinot-connectors/{pinot-spark-2-connector => pinot-spark-3-connector}/README.md (68%)
copy pinot-connectors/{pinot-spark-2-connector => pinot-spark-3-connector}/documentation/images/spark-pinot-connector-executor-server-interaction.jpg (100%)
copy pinot-connectors/{pinot-spark-2-connector => pinot-spark-3-connector}/documentation/read_model.md (94%)
create mode 100644 pinot-connectors/pinot-spark-3-connector/pom.xml
create mode 100644 pinot-connectors/pinot-spark-3-connector/src/main/resources/META-INF/services/org.apache.spark.sql.sources.DataSourceRegister
create mode 100644 pinot-connectors/pinot-spark-3-connector/src/main/scala/org/apache/pinot/connector/spark/v3/datasource/PinotDataSource.scala
create mode 100644 pinot-connectors/pinot-spark-3-connector/src/main/scala/org/apache/pinot/connector/spark/v3/datasource/PinotInputPartition.scala
create mode 100644 pinot-connectors/pinot-spark-3-connector/src/main/scala/org/apache/pinot/connector/spark/v3/datasource/PinotScan.scala
create mode 100644 pinot-connectors/pinot-spark-3-connector/src/main/scala/org/apache/pinot/connector/spark/v3/datasource/PinotScanBuilder.scala
create mode 100644 pinot-connectors/pinot-spark-3-connector/src/main/scala/org/apache/pinot/connector/spark/v3/datasource/PinotTable.scala
copy pinot-connectors/{pinot-spark-2-connector/src/main/scala/org/apache/pinot/connector/spark => pinot-spark-3-connector/src/main/scala/org/apache/pinot/connector/spark/v3}/datasource/TypeConverter.scala (87%)
create mode 100644 pinot-connectors/pinot-spark-3-connector/src/main/scala/org/apache/pinot/connector/spark/v3/datasource/query/FilterPushDown.scala
copy {pinot-broker => pinot-connectors/pinot-spark-3-connector}/src/test/resources/log4j2.xml (100%)
create mode 100644 pinot-connectors/pinot-spark-3-connector/src/test/resources/schema/pinot-schema.json
create mode 100644 pinot-connectors/pinot-spark-3-connector/src/test/resources/schema/spark-schema.json
copy pinot-common/src/main/java/org/apache/pinot/common/metadata/controllerjob/ControllerJobType.java => pinot-connectors/pinot-spark-3-connector/src/test/scala/org/apache/pinot/connector/spark/v3/datasource/BaseTest.scala (80%)
create mode 100644 pinot-connectors/pinot-spark-3-connector/src/test/scala/org/apache/pinot/connector/spark/v3/datasource/ExampleSparkPinotConnectorTest.scala
create mode 100644 pinot-connectors/pinot-spark-3-connector/src/test/scala/org/apache/pinot/connector/spark/v3/datasource/PinotScanBuilderTest.scala
create mode 100644 pinot-connectors/pinot-spark-3-connector/src/test/scala/org/apache/pinot/connector/spark/v3/datasource/PinotScanTest.scala
copy pinot-connectors/{pinot-spark-2-connector/src/test/scala/org/apache/pinot/connector/spark => pinot-spark-3-connector/src/test/scala/org/apache/pinot/connector/spark/v3}/datasource/TypeConverterTest.scala (84%)
create mode 100644 pinot-connectors/pinot-spark-3-connector/src/test/scala/org/apache/pinot/connector/spark/v3/datasource/query/FilterPushDownTest.scala
copy pinot-core/src/main/java/org/apache/pinot/core/operator/blocks/results/MetadataResultsBlock.java => pinot-controller/src/main/java/org/apache/pinot/controller/api/resources/ServerRebalanceJobStatusResponse.java (50%)
copy pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/creator/BloomFilterCreator.java => pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/rebalance/NoOpTableRebalanceObserver.java (62%)
create mode 100644 pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/rebalance/TableRebalanceObserver.java
create mode 100644 pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/rebalance/TableRebalanceProgressStats.java
create mode 100644 pinot-controller/src/main/java/org/apache/pinot/controller/helix/core/rebalance/ZkBasedTableRebalanceObserver.java
copy pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/creator/BloomFilterCreator.java => pinot-controller/src/main/resources/app/components/AppLoadingIndicator.tsx (59%)
create mode 100644 pinot-controller/src/main/resources/app/components/auth/AuthProvider.tsx
create mode 100644 pinot-controller/src/main/resources/app/index.tsx
create mode 100644 pinot-controller/src/test/java/org/apache/pinot/controller/helix/core/rebalance/TestZkBasedTableRebalanceObserver.java
copy pinot-core/src/main/java/org/apache/pinot/core/operator/{blocks/PassThroughTransformBlock.java => BaseProjectOperator.java} (57%)
create mode 100644 pinot-core/src/main/java/org/apache/pinot/core/operator/ColumnContext.java
rename pinot-core/src/main/java/org/apache/pinot/core/operator/blocks/{PassThroughTransformBlock.java => ValueBlock.java} (59%)
delete mode 100644 pinot-core/src/main/java/org/apache/pinot/core/operator/transform/PassThroughTransformOperator.java
rename pinot-core/src/main/java/org/apache/pinot/core/plan/{TransformPlanNode.java => ProjectPlanNode.java} (63%)
delete mode 100644 pinot-core/src/main/java/org/apache/pinot/core/plan/ProjectionPlanNode.java
rename pinot-core/src/main/java/org/apache/pinot/core/startree/plan/{StarTreeTransformPlanNode.java => StarTreeProjectPlanNode.java} (53%)
delete mode 100644 pinot-core/src/main/java/org/apache/pinot/core/startree/plan/StarTreeProjectionPlanNode.java
create mode 100644 pinot-core/src/test/java/org/apache/pinot/core/operator/filter/predicate/InPredicateEvaluatorFactoryTest.java
copy pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/{MultiStageEngineIntegrationTest.java => MultiStageEngineCustomTenantIntegrationTest.java} (79%)
create mode 100644 pinot-plugins/pinot-file-system/pinot-s3/src/test/java/org/apache/pinot/plugin/filesystem/S3ConfigTest.java
create mode 100644 pinot-query-planner/src/main/java/org/apache/calcite/rel/logical/PinotLogicalSortExchange.java
create mode 100644 pinot-query-planner/src/test/java/org/apache/pinot/query/planner/logical/RelToStageConverterTest.java
create mode 100644 pinot-query-planner/src/test/java/org/apache/pinot/query/type/TypeFactoryTest.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/mailbox/channel/InMemoryTransferStream.java
create mode 100644 pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/operator/utils/SortUtils.java
copy pinot-query-runtime/src/main/java/org/apache/pinot/query/runtime/plan/{PlanRequestContext.java => OpChainExecutionContext.java} (58%)
copy pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/creator/BloomFilterCreator.java => pinot-query-runtime/src/main/java/org/apache/pinot/query/service/dispatch/CancelObserver.java (64%)
copy pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/creator/BloomFilterCreator.java => pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/index/bloom/BloomIndexPlugin.java (69%)
create mode 100644 pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/index/bloom/BloomIndexType.java
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/FieldIndexConfigs.java
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/IndexCreator.java
rename {pinot-segment-local/src/main/java/org/apache/pinot/segment/local/segment/index/loader => pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index}/IndexHandler.java (96%)
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/IndexPlugin.java
copy pinot-common/src/main/java/org/apache/pinot/common/metadata/controllerjob/ControllerJobType.java => pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/IndexReader.java (84%)
copy pinot-core/src/main/java/org/apache/pinot/core/operator/blocks/results/MetadataResultsBlock.java => pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/IndexReaderConstraintException.java (50%)
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/IndexReaderFactory.java
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/IndexService.java
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/IndexType.java
create mode 100644 pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/StandardIndexes.java
copy pinot-segment-spi/src/{main/java/org/apache/pinot/segment/spi/index/creator/BloomFilterCreator.java => test/java/org/apache/pinot/segment/spi/index/FieldIndexConfigsTest.java} (51%)
copy pinot-spi/src/main/java/org/apache/pinot/spi/config/table/{BloomFilterConfig.java => IndexConfig.java} (53%)
create mode 100644 pinot-spi/src/main/java/org/apache/pinot/spi/data/MultiValueVisitor.java
copy pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/creator/BloomFilterCreator.java => pinot-spi/src/main/java/org/apache/pinot/spi/data/SingleValueVisitor.java (66%)
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@pinot.apache.org
For additional commands, e-mail: commits-help@pinot.apache.org