This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a change to branch upgrade_jdk_11
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
discard 819f181 move http requests in ControlerTest to use apache http client
lib
discard cd4da13 upgrade jdk to 11
add fb7ceb0 DataTable V3 implementation and measure data table
serialization cost on server (#6710)
add e0c77e3 code style fix: avoid static import; add Override annotations
(#6738)
add 89407f9 Extract common used data structure to static variables to
eliminate duplicate code (#6739)
add d593478 Block backward incompatible schema change (#6737)
add 98faf2b WIP: Pinot SPI refactor. (#6721)
add 04f2831 upgrade jdk to 11
add 76cee9f move http requests in ControlerTest to use apache http client
lib
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 (819f181)
\
N -- N -- N refs/heads/upgrade_jdk_11 (76cee9f)
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:
docs/customizations.rst | 2 +-
.../broker/pruner/PartitionZKMetadataPruner.java | 2 +-
.../requesthandler/BaseBrokerRequestHandler.java | 2 +-
.../segmentpruner/PartitionSegmentPruner.java | 2 +-
.../segmentpruner/interval/IntervalTree.java | 2 +-
pinot-common/pom.xml | 4 +
.../SchemaBackwardIncompatibleException.java | 9 +-
.../function/FunctionDefinitionRegistry.java | 3 +
.../apache/pinot/common/utils/CommonConstants.java | 3 +
.../org/apache/pinot/common/utils/DataTable.java | 78 +++-
.../parsers/PinotQuery2BrokerRequestConverter.java | 2 +-
.../pql/parsers/pql2/ast/FunctionCallAstNode.java | 2 +-
.../apache/pinot/sql/parsers/CalciteSqlParser.java | 2 +-
.../function/AggregationFunctionTypeTest.java | 3 +-
.../pinot/sql/parsers/CalciteSqlCompilerTest.java | 2 +-
.../api/resources/PinotSchemaRestletResource.java | 20 +-
.../PinotSegmentUploadDownloadRestletResource.java | 2 +-
.../controller/api/upload/SegmentValidator.java | 2 +-
.../pinot/controller/api/upload/ZKOperator.java | 2 +-
.../helix/core/PinotHelixResourceManager.java | 28 +-
.../assignment/segment/SegmentAssignmentUtils.java | 2 +-
.../helix/core/util/ZKMetadataUtils.java | 4 +-
.../realtime/provisioning/MemoryEstimator.java | 15 +-
.../NoDictionaryOnHeapDictionaryJointRule.java | 9 +-
.../utils/QueryInvertedSortedIndexRecommender.java | 16 +-
.../pinot/controller/util/FileIngestionHelper.java | 2 +-
.../api/PinotSegmentRestletResourceTest.java | 2 +-
.../controller/api/upload/ZKOperatorTest.java | 9 +-
.../PinotLLCRealtimeSegmentManagerTest.java | 5 +-
.../helix/core/retention/RetentionManagerTest.java | 2 +-
.../controller/utils/SegmentMetadataMockUtils.java | 2 +-
.../validation/ValidationManagerStatelessTest.java | 17 -
.../validation/ValidationManagerTest.java | 4 +-
pinot-core/pom.xml | 4 +
.../pinot/core/common/BlockDocIdIterator.java | 3 +
.../apache/pinot/core/common/BlockMetadata.java | 2 +-
.../org/apache/pinot/core/common/BlockValSet.java | 2 +-
.../org/apache/pinot/core/common/DataFetcher.java | 8 +-
.../{DataTableImplV2.java => BaseDataTable.java} | 294 +++-------------
.../core/common/datatable/DataTableBuilder.java | 20 +-
.../core/common/datatable/DataTableFactory.java | 4 +-
.../core/common/datatable/DataTableImplV2.java | 284 +--------------
.../core/common/datatable/DataTableImplV3.java | 392 +++++++++++++++++++++
.../core/common/datatable/DataTableUtils.java | 45 +++
.../core/data/aggregator/AvgValueAggregator.java | 4 +-
.../core/data/aggregator/CountValueAggregator.java | 2 +-
.../DistinctCountBitmapValueAggregator.java | 2 +-
.../DistinctCountHLLValueAggregator.java | 2 +-
.../core/data/aggregator/MaxValueAggregator.java | 2 +-
.../aggregator/MinMaxRangeValueAggregator.java | 4 +-
.../core/data/aggregator/MinValueAggregator.java | 2 +-
.../aggregator/PercentileEstValueAggregator.java | 4 +-
.../PercentileTDigestValueAggregator.java | 4 +-
.../aggregator/SumPrecisionValueAggregator.java | 2 +-
.../core/data/aggregator/SumValueAggregator.java | 2 +-
.../core/data/aggregator/ValueAggregator.java | 2 +-
.../data/aggregator/ValueAggregatorFactory.java | 2 +-
.../core/data/manager/BaseTableDataManager.java | 2 +-
.../core/data/manager/InstanceDataManager.java | 4 +-
.../core/data/manager/SegmentDataManager.java | 2 +-
.../pinot/core/data/manager/TableDataManager.java | 2 +-
.../manager/offline/DimensionTableDataManager.java | 3 +-
.../offline/ImmutableSegmentDataManager.java | 2 +-
.../realtime/HLRealtimeSegmentDataManager.java | 6 +-
.../realtime/LLRealtimeSegmentDataManager.java | 6 +-
.../realtime/RealtimeSegmentDataManager.java | 2 +-
.../manager/realtime/RealtimeTableDataManager.java | 2 +-
.../data/partition/ByteArrayPartitionFunction.java | 2 +
.../data/partition/HashCodePartitionFunction.java | 2 +
.../data/partition/ModuloPartitionFunction.java | 1 +
.../data/partition/MurmurPartitionFunction.java | 1 +
.../data/partition/PartitionFunctionFactory.java | 1 +
.../data/readers/PinotSegmentColumnReader.java | 10 +-
.../data/readers/PinotSegmentRecordReader.java | 4 +-
.../core/data/readers/sort/PinotSegmentSorter.java | 2 +-
.../apache/pinot/core/data/table/TableResizer.java | 2 -
.../function/ConstructFromTextFunction.java | 2 +-
.../function/ConstructFromWKBFunction.java | 7 +-
.../transform/function/StAreaFunction.java | 7 +-
.../transform/function/StAsBinaryFunction.java | 7 +-
.../transform/function/StAsTextFunction.java | 7 +-
.../transform/function/StContainsFunction.java | 7 +-
.../transform/function/StDistanceFunction.java | 2 +-
.../transform/function/StEqualsFunction.java | 8 +-
.../transform/function/StGeometryTypeFunction.java | 7 +-
.../transform/function/StPointFunction.java | 7 +-
.../indexsegment/immutable/EmptyIndexSegment.java | 13 +-
.../immutable/ImmutableSegmentImpl.java | 15 +-
.../immutable/ImmutableSegmentLoader.java | 7 +-
.../indexsegment/mutable/IntermediateSegment.java | 17 +-
.../indexsegment/mutable/MutableSegmentImpl.java | 21 +-
.../io/compression/ChunkCompressorFactory.java | 23 +-
.../core/io/compression/PassThroughCompressor.java | 1 +
.../io/compression/PassThroughDecompressor.java | 1 +
.../core/io/compression/SnappyCompressor.java | 1 +
.../core/io/compression/SnappyDecompressor.java | 1 +
.../writer/impl/BaseChunkSVForwardIndexWriter.java | 7 +-
.../impl/FixedByteChunkSVForwardIndexWriter.java | 4 +-
.../impl/VarByteChunkSVForwardIndexWriter.java | 4 +-
.../core/metadata/DefaultMetadataExtractor.java | 2 +-
.../pinot/core/metadata/MetadataExtractor.java | 2 +-
.../pinot/core/minion/RawIndexConverter.java | 18 +-
.../apache/pinot/core/minion/SegmentConverter.java | 2 +-
.../apache/pinot/core/minion/SegmentPurger.java | 2 +-
.../core/minion/rollup/RollupRecordAggregator.java | 6 +-
.../pinot/core/operator/DocIdSetOperator.java | 2 +-
.../core/operator/InstanceResponseOperator.java | 6 +-
.../pinot/core/operator/ProjectionOperator.java | 2 +-
.../operator/blocks/IntermediateResultsBlock.java | 67 ++--
.../core/operator/blocks/ProjectionBlock.java | 2 +-
...xValueBasedSelectionOrderByCombineOperator.java | 2 +-
.../operator/dociditerators/AndDocIdIterator.java | 2 +-
.../dociditerators/ArrayBasedDocIdIterator.java | 2 +-
.../dociditerators/BitmapDocIdIterator.java | 2 +-
.../dociditerators/EmptyDocIdIterator.java | 2 +-
.../ExpressionScanDocIdIterator.java | 4 +-
.../dociditerators/MVScanDocIdIterator.java | 6 +-
.../dociditerators/MatchAllDocIdIterator.java | 2 +-
.../operator/dociditerators/OrDocIdIterator.java | 2 +-
.../RangelessBitmapDocIdIterator.java | 2 +-
.../dociditerators/SVScanDocIdIterator.java | 6 +-
.../dociditerators/SortedDocIdIterator.java | 4 +-
.../pinot/core/operator/docidsets/AndDocIdSet.java | 2 +-
.../docidsets/ExpressionFilterDocIdSet.java | 2 +-
.../core/operator/docidsets/MVScanDocIdSet.java | 2 +-
.../pinot/core/operator/docidsets/OrDocIdSet.java | 2 +-
.../core/operator/docidsets/SVScanDocIdSet.java | 2 +-
.../core/operator/docidsets/SortedDocIdSet.java | 2 +-
.../operator/docvalsets/ProjectionBlockValSet.java | 4 +-
.../operator/docvalsets/TransformBlockValSet.java | 2 +-
.../operator/filter/BitmapBasedFilterOperator.java | 5 +-
.../operator/filter/ExpressionFilterOperator.java | 4 +-
.../core/operator/filter/FilterOperatorUtils.java | 2 +-
.../operator/filter/H3IndexFilterOperator.java | 4 +-
.../operator/filter/JsonMatchFilterOperator.java | 16 +-
.../filter/RangeIndexBasedFilterOperator.java | 2 +-
.../operator/filter/ScanBasedFilterOperator.java | 4 +-
.../filter/SortedIndexBasedFilterOperator.java | 6 +-
.../operator/filter/TextMatchFilterOperator.java | 2 +-
.../predicate/EqualsPredicateEvaluatorFactory.java | 2 +-
.../FSTBasedRegexpPredicateEvaluatorFactory.java | 5 +-
.../predicate/InPredicateEvaluatorFactory.java | 2 +-
.../NotEqualsPredicateEvaluatorFactory.java | 2 +-
.../predicate/NotInPredicateEvaluatorFactory.java | 2 +-
.../predicate/PredicateEvaluatorProvider.java | 2 +-
.../predicate/RangePredicateEvaluatorFactory.java | 2 +-
.../RegexpLikePredicateEvaluatorFactory.java | 2 +-
.../query/DictionaryBasedAggregationOperator.java | 2 +-
.../core/operator/query/DistinctOperator.java | 2 +-
.../operator/query/EmptySelectionOperator.java | 2 +-
.../query/MetadataBasedAggregationOperator.java | 6 +-
.../core/operator/query/SelectionOnlyOperator.java | 2 +-
.../operator/query/SelectionOrderByOperator.java | 4 +-
.../streaming/StreamingSelectionOnlyOperator.java | 2 +-
.../core/operator/transform/TransformOperator.java | 4 +-
.../function/AdditionTransformFunction.java | 2 +-
.../function/ArrayAverageTransformFunction.java | 2 +-
.../function/ArrayLengthTransformFunction.java | 2 +-
.../function/ArrayMaxTransformFunction.java | 3 +-
.../function/ArrayMinTransformFunction.java | 2 +-
.../function/ArraySumTransformFunction.java | 2 +-
.../transform/function/BaseTransformFunction.java | 4 +-
.../function/BinaryOperatorTransformFunction.java | 2 +-
.../transform/function/CaseTransformFunction.java | 3 +-
.../transform/function/CastTransformFunction.java | 7 +-
.../DateTimeConversionTransformFunction.java | 4 +-
.../function/DateTruncTransformFunction.java | 2 +-
.../function/DivisionTransformFunction.java | 2 +-
.../GreaterThanOrEqualTransformFunction.java | 3 +-
.../function/GreaterThanTransformFunction.java | 3 +-
.../function/GroovyTransformFunction.java | 2 +-
.../function/IdentifierTransformFunction.java | 6 +-
.../function/InIdSetTransformFunction.java | 4 +-
.../function/JsonExtractKeyTransformFunction.java | 2 +-
.../JsonExtractScalarTransformFunction.java | 2 +-
.../function/LessThanOrEqualTransformFunction.java | 3 +-
.../function/LessThanTransformFunction.java | 3 +-
.../function/LiteralTransformFunction.java | 4 +-
.../function/LogicalOperatorTransformFunction.java | 2 +-
.../function/LookupTransformFunction.java | 6 +-
.../function/MapValueTransformFunction.java | 4 +-
.../function/ModuloTransformFunction.java | 2 +-
.../function/MultiplicationTransformFunction.java | 2 +-
.../function/ScalarTransformFunctionWrapper.java | 2 +-
.../function/SingleParamMathTransformFunction.java | 2 +-
.../function/SubtractionTransformFunction.java | 2 +-
.../function/TimeConversionTransformFunction.java | 2 +-
.../transform/function/TransformFunction.java | 5 +-
.../function/TransformFunctionFactory.java | 2 +-
.../function/ValueInTransformFunction.java | 6 +-
.../plan/AggregationGroupByOrderByPlanNode.java | 6 +-
.../core/plan/AggregationGroupByPlanNode.java | 6 +-
.../pinot/core/plan/AggregationPlanNode.java | 6 +-
.../plan/DictionaryBasedAggregationPlanNode.java | 4 +-
.../apache/pinot/core/plan/DistinctPlanNode.java | 2 +-
.../apache/pinot/core/plan/DocIdSetPlanNode.java | 2 +-
.../org/apache/pinot/core/plan/FilterPlanNode.java | 10 +-
.../plan/MetadataBasedAggregationPlanNode.java | 6 +-
.../apache/pinot/core/plan/ProjectionPlanNode.java | 4 +-
.../apache/pinot/core/plan/SelectionPlanNode.java | 2 +-
.../core/plan/StreamingSelectionPlanNode.java | 2 +-
.../apache/pinot/core/plan/TransformPlanNode.java | 2 +-
.../core/plan/maker/InstancePlanMakerImplV2.java | 6 +-
.../apache/pinot/core/plan/maker/PlanMaker.java | 2 +-
.../aggregation/function/AggregationFunction.java | 2 +-
.../function/AggregationFunctionFactory.java | 2 +-
.../function/AggregationFunctionUtils.java | 4 +-
.../function/AvgAggregationFunction.java | 2 +-
.../function/AvgMVAggregationFunction.java | 2 +-
.../function/CountAggregationFunction.java | 4 +-
.../function/CountMVAggregationFunction.java | 2 +-
.../function/DistinctAggregationFunction.java | 2 +-
.../function/DistinctCountAggregationFunction.java | 4 +-
.../DistinctCountBitmapAggregationFunction.java | 4 +-
.../DistinctCountBitmapMVAggregationFunction.java | 4 +-
.../DistinctCountHLLAggregationFunction.java | 2 +-
.../DistinctCountHLLMVAggregationFunction.java | 2 +-
.../DistinctCountMVAggregationFunction.java | 4 +-
.../DistinctCountRawHLLAggregationFunction.java | 2 +-
.../DistinctCountRawHLLMVAggregationFunction.java | 2 +-
...inctCountRawThetaSketchAggregationFunction.java | 2 +-
...istinctCountThetaSketchAggregationFunction.java | 2 +-
.../function/FastHLLAggregationFunction.java | 2 +-
.../function/IdSetAggregationFunction.java | 2 +-
.../function/MaxAggregationFunction.java | 2 +-
.../function/MaxMVAggregationFunction.java | 2 +-
.../function/MinAggregationFunction.java | 2 +-
.../function/MinMVAggregationFunction.java | 2 +-
.../function/MinMaxRangeAggregationFunction.java | 2 +-
.../function/MinMaxRangeMVAggregationFunction.java | 2 +-
.../function/PercentileAggregationFunction.java | 2 +-
.../function/PercentileEstAggregationFunction.java | 2 +-
.../PercentileEstMVAggregationFunction.java | 2 +-
.../function/PercentileMVAggregationFunction.java | 2 +-
.../PercentileTDigestAggregationFunction.java | 2 +-
.../PercentileTDigestMVAggregationFunction.java | 2 +-
...artitionedDistinctCountAggregationFunction.java | 2 +-
.../function/StUnionAggregationFunction.java | 2 +-
.../function/SumAggregationFunction.java | 2 +-
.../function/SumMVAggregationFunction.java | 2 +-
.../function/SumPrecisionAggregationFunction.java | 2 +-
.../groupby/DictionaryBasedGroupKeyGenerator.java | 2 +-
.../NoDictionaryMultiColumnGroupKeyGenerator.java | 2 +-
.../query/distinct/DistinctExecutorFactory.java | 2 +-
...DictionaryBasedMultiColumnDistinctExecutor.java | 2 +-
...ictionaryBasedSingleColumnDistinctExecutor.java | 2 +-
...ionaryBasedMultiColumnDistinctOnlyExecutor.java | 2 +-
...aryBasedMultiColumnDistinctOrderByExecutor.java | 2 +-
...onaryBasedSingleColumnDistinctOnlyExecutor.java | 2 +-
...ryBasedSingleColumnDistinctOrderByExecutor.java | 2 +-
.../BaseRawFloatSingleColumnDistinctExecutor.java | 2 +-
.../query/executor/ServerQueryExecutorV1Impl.java | 19 +-
.../query/pruner/ColumnValueSegmentPruner.java | 10 +-
.../core/query/pruner/DataSchemaSegmentPruner.java | 2 +-
.../pinot/core/query/pruner/SegmentPruner.java | 2 +-
.../core/query/pruner/SegmentPrunerService.java | 2 +-
.../query/pruner/SelectionQuerySegmentPruner.java | 4 +-
.../core/query/pruner/ValidSegmentPruner.java | 4 +-
.../core/query/reduce/BrokerReduceService.java | 7 +-
.../core/query/reduce/ResultReducerFactory.java | 2 +-
.../BrokerRequestToQueryContextConverter.java | 2 +-
.../context/utils/QueryContextConverterUtils.java | 2 +-
.../pinot/core/query/scheduler/QueryScheduler.java | 75 ++--
.../query/selection/SelectionOperatorUtils.java | 2 +-
.../converter/RealtimeSegmentConverter.java | 12 +-
.../converter/stats/MutableColumnStatistics.java | 12 +-
.../stats/MutableNoDictionaryColStatistics.java | 12 +-
.../RealtimeSegmentSegmentCreationDataSource.java | 10 +-
.../stats/RealtimeSegmentStatsContainer.java | 6 +-
.../core/realtime/impl/RealtimeSegmentConfig.java | 4 +-
.../dictionary/BaseOffHeapMutableDictionary.java | 2 +-
.../dictionary/BaseOnHeapMutableDictionary.java | 2 +-
.../impl/dictionary/MutableDictionaryFactory.java | 2 +-
.../forward/FixedByteMVMutableForwardIndex.java | 2 +-
.../forward/FixedByteSVMutableForwardIndex.java | 2 +-
.../impl/forward/VarByteSVMutableForwardIndex.java | 2 +-
.../realtime/impl/geospatial/MutableH3Index.java | 4 +-
.../invertedindex/RealtimeInvertedIndexReader.java | 2 +-
.../RealtimeLuceneTextIndexReader.java | 2 +-
.../core/realtime/impl/json/MutableJsonIndex.java | 16 +-
.../impl/nullvalue/MutableNullValueVector.java | 2 +-
...termediateSegmentSegmentCreationDataSource.java | 3 +
.../creator/IntermediateSegmentStatsContainer.java | 4 +-
.../RecordReaderSegmentCreationDataSource.java | 11 +-
.../creator/impl/SegmentColumnarIndexCreator.java | 38 +-
.../creator/impl/SegmentCreationDriverFactory.java | 4 +-
.../impl/SegmentIndexCreationDriverImpl.java | 22 +-
.../impl/bloom/OnHeapGuavaBloomFilterCreator.java | 2 +-
.../fwd/MultiValueUnsortedForwardIndexCreator.java | 2 +-
.../fwd/SingleValueFixedByteRawIndexCreator.java | 8 +-
.../fwd/SingleValueSortedForwardIndexCreator.java | 2 +-
.../SingleValueUnsortedForwardIndexCreator.java | 2 +-
.../fwd/SingleValueVarByteRawIndexCreator.java | 8 +-
.../inv/OffHeapBitmapInvertedIndexCreator.java | 2 +-
.../impl/inv/OnHeapBitmapInvertedIndexCreator.java | 2 +-
.../creator/impl/inv/RangeIndexCreator.java | 4 +-
.../impl/inv/geospatial/BaseH3IndexCreator.java | 3 +-
.../impl/inv/geospatial/OffHeapH3IndexCreator.java | 1 +
.../impl/inv/geospatial/OnHeapH3IndexCreator.java | 1 +
.../impl/inv/json/BaseJsonIndexCreator.java | 2 +-
.../impl/inv/json/OffHeapJsonIndexCreator.java | 3 +-
.../impl/inv/json/OnHeapJsonIndexCreator.java | 3 +-
.../impl/inv/text/LuceneFSTIndexCreator.java | 9 +-
.../stats/AbstractColumnStatisticsCollector.java | 18 +-
.../stats/BytesColumnPredIndexStatsCollector.java | 2 +-
.../stats/DoubleColumnPreIndexStatsCollector.java | 2 +-
.../stats/FloatColumnPreIndexStatsCollector.java | 2 +-
.../stats/IntColumnPreIndexStatsCollector.java | 2 +-
.../stats/LongColumnPreIndexStatsCollector.java | 2 +-
.../stats/SegmentPreIndexStatsCollectorImpl.java | 6 +-
.../stats/StringColumnPreIndexStatsCollector.java | 2 +-
.../creator/impl/text/LuceneTextIndexCreator.java | 4 +-
.../index/column/BaseVirtualColumnProvider.java | 1 +
.../DefaultNullValueVirtualColumnProvider.java | 6 +-
.../index/column/IntermediateIndexContainer.java | 8 +-
.../index/column/PhysicalColumnIndexContainer.java | 18 +-
.../converter/SegmentFormatConverterFactory.java | 3 +-
.../converter/SegmentV1V2ToV3FormatConverter.java | 5 +-
.../segment/index/datasource/BaseDataSource.java | 20 +-
.../segment/index/datasource/EmptyDataSource.java | 4 +-
.../index/datasource/ImmutableDataSource.java | 6 +-
.../index/datasource/MutableDataSource.java | 20 +-
.../segment/index/loader/IndexLoadingConfig.java | 4 +-
.../core/segment/index/loader/LoaderUtils.java | 2 +-
.../segment/index/loader/SegmentPreProcessor.java | 2 +-
.../loader/bloomfilter/BloomFilterHandler.java | 6 +-
.../defaultcolumn/BaseDefaultColumnHandler.java | 10 +-
.../defaultcolumn/DefaultColumnHandlerFactory.java | 2 +-
.../defaultcolumn/DefaultColumnStatistics.java | 4 +-
.../index/loader/invertedindex/H3IndexHandler.java | 10 +-
.../loader/invertedindex/InvertedIndexHandler.java | 6 +-
.../loader/invertedindex/JsonIndexHandler.java | 8 +-
.../invertedindex/LuceneFSTIndexHandler.java | 4 +-
.../loader/invertedindex/RangeIndexHandler.java | 6 +-
.../loader/invertedindex/TextIndexHandler.java | 8 +-
.../segment/index/metadata/ColumnMetadata.java | 2 +-
.../index/metadata/SegmentMetadataImpl.java | 7 +-
.../index/readers/BaseImmutableDictionary.java | 1 +
.../index/readers/BitmapInvertedIndexReader.java | 1 +
.../index/readers/LuceneFSTIndexReader.java | 8 +-
.../index/readers/NullValueVectorReaderImpl.java | 1 +
.../segment/index/readers/RangeIndexReader.java | 1 +
.../index/readers/ValidDocIndexReaderImpl.java | 1 +
.../readers/bloom/BaseGuavaBloomFilterReader.java | 2 +-
.../readers/bloom/BloomFilterReaderFactory.java | 2 +-
.../constant/ConstantMVForwardIndexReader.java | 4 +-
.../constant/ConstantMVInvertedIndexReader.java | 2 +-
.../constant/ConstantSortedIndexReader.java | 6 +-
.../forward/BaseChunkSVForwardIndexReader.java | 15 +-
.../forward/FixedBitMVForwardIndexReader.java | 4 +-
.../forward/FixedBitSVForwardIndexReader.java | 4 +-
.../forward/FixedBitSVForwardIndexReaderV2.java | 4 +-
.../readers/geospatial/ImmutableH3IndexReader.java | 4 +-
.../readers/json/ImmutableJsonIndexReader.java | 14 +-
.../readers/sorted/SortedIndexReaderImpl.java | 6 +-
.../index/readers/text/LuceneTextIndexReader.java | 2 +-
.../processing/framework/SegmentMapper.java | 2 +-
.../framework/SegmentProcessorFramework.java | 2 +-
.../partitioner/ColumnValuePartitioner.java | 1 +
.../processing/partitioner/NoOpPartitioner.java | 1 +
.../processing/partitioner/PartitionerFactory.java | 1 +
.../partitioner/RoundRobinPartitioner.java | 1 +
.../partitioner/TableConfigPartitioner.java | 3 +-
.../partitioner/TransformFunctionPartitioner.java | 1 +
.../core/segment/store/SegmentDirectoryPaths.java | 3 +-
.../segment/store/SegmentLocalFSDirectory.java | 2 +-
.../virtualcolumn/DocIdVirtualColumnProvider.java | 12 +-
.../virtualcolumn/VirtualColumnIndexContainer.java | 20 +-
.../virtualcolumn/VirtualColumnProvider.java | 8 +-
.../pinot/core/startree/OffHeapStarTree.java | 4 +-
.../pinot/core/startree/OffHeapStarTreeNode.java | 1 +
.../apache/pinot/core/startree/StarTreeUtils.java | 12 +-
.../executor/StarTreeAggregationExecutor.java | 2 +-
.../startree/executor/StarTreeGroupByExecutor.java | 2 +-
.../startree/operator/StarTreeFilterOperator.java | 8 +-
.../startree/plan/StarTreeDocIdSetPlanNode.java | 2 +-
.../core/startree/plan/StarTreeFilterPlanNode.java | 2 +-
.../startree/plan/StarTreeProjectionPlanNode.java | 4 +-
.../startree/plan/StarTreeTransformPlanNode.java | 4 +-
.../startree/v2/builder/BaseSingleTreeBuilder.java | 22 +-
.../startree/v2/builder/MultipleTreesBuilder.java | 6 +-
.../v2/builder/OffHeapSingleTreeBuilder.java | 4 +-
.../v2/builder/OnHeapSingleTreeBuilder.java | 4 +-
.../startree/v2/builder/StarTreeIndexCombiner.java | 4 +-
.../v2/builder/StarTreeV2BuilderConfig.java | 4 +-
.../core/startree/v2/store/StarTreeDataSource.java | 8 +-
.../startree/v2/store/StarTreeIndexContainer.java | 6 +-
.../startree/v2/store/StarTreeLoaderUtils.java | 12 +-
.../core/transport/InstanceRequestHandler.java | 11 +-
.../org/apache/pinot/core/util/IngestionUtils.java | 10 +-
.../core/util/IntDoubleIndexedPriorityQueue.java | 2 +-
.../core/util/IntObjectIndexedPriorityQueue.java | 2 +-
.../pinot/core/util/SortedRangeIntersection.java | 4 +-
.../apache/pinot/core/util/TableConfigUtils.java | 2 +-
.../apache/pinot/core/common/DataFetcherTest.java | 5 +-
.../core/common/datatable/DataTableSerDeTest.java | 329 ++++++++++++++---
.../data/manager/BaseTableDataManagerTest.java | 4 +-
.../offline/DimensionTableDataManagerTest.java | 9 +-
.../core/data/partition/PartitionFunctionTest.java | 1 +
.../pinot/core/data/readers/PinotSegmentUtil.java | 6 +-
.../core/geospatial/transform/GeoFunctionTest.java | 7 +-
.../core/indexsegment/IntermediateSegmentTest.java | 11 +-
.../MutableSegmentImplNullValueVectorTest.java | 4 +-
.../mutable/MutableSegmentImplTest.java | 18 +-
.../minion/MergeRollupSegmentConverterTest.java | 10 +-
.../pinot/core/minion/SegmentConverterTest.java | 11 +-
.../pinot/core/minion/SegmentPurgerTest.java | 2 +-
.../combine/SelectionCombineOperatorTest.java | 4 +-
.../dociditerators/AndDocIdIteratorTest.java | 2 +-
.../dociditerators/BitmapDocIdIteratorTest.java | 2 +-
.../dociditerators/OrDocIdIteratorTest.java | 2 +-
.../dociditerators/SortedDocIdIteratorTest.java | 4 +-
.../operator/filter/AndFilterOperatorTest.java | 2 +-
.../core/operator/filter/OrFilterOperatorTest.java | 2 +-
.../core/operator/filter/TestFilterOperator.java | 2 +-
...ngeOfflineDictionaryPredicateEvaluatorTest.java | 2 +-
.../function/ArrayLengthTransformFunctionTest.java | 6 -
.../function/BaseTransformFunctionTest.java | 6 +-
.../function/DateTruncTransformFunctionTest.java | 6 +-
.../LogicalOperatorTransformFunctionTest.java | 2 -
.../function/LookupTransformFunctionTest.java | 10 +-
.../ScalarTransformFunctionWrapperTest.java | 4 +-
.../function/ValueInTransformFunctionTest.java | 2 +-
...adataAndDictionaryAggregationPlanMakerTest.java | 6 +-
.../DefaultAggregationExecutorTest.java | 6 +-
.../function/AggregationFunctionFactoryTest.java | 2 +-
.../DictionaryBasedGroupKeyGeneratorTest.java | 4 +-
.../groupby/NoDictionaryGroupKeyGeneratorTest.java | 4 +-
.../core/query/executor/QueryExecutorTest.java | 8 +-
.../query/pruner/ColumnValueSegmentPrunerTest.java | 10 +-
.../pruner/SelectionQuerySegmentPrunerTest.java | 10 +-
.../query/scheduler/PrioritySchedulerTest.java | 33 +-
.../selection/SelectionOperatorServiceTest.java | 2 +-
.../impl/dictionary/MutableDictionaryTest.java | 2 +-
.../core/segment/index/ColumnMetadataTest.java | 6 +-
.../pinot/core/segment/index/H3IndexTest.java | 6 +-
.../pinot/core/segment/index/JsonIndexTest.java | 20 +-
.../segment/index/SegmentMetadataImplTest.java | 4 +-
.../DefaultNullValueVirtualColumnProviderTest.java | 2 +-
.../SegmentV1V2ToV3FormatConverterTest.java | 8 +-
.../index/creator/BloomFilterCreatorTest.java | 4 +-
.../segment/index/creator/RawIndexCreatorTest.java | 2 +-
.../SegmentGenerationWithBytesTypeTest.java | 8 +-
.../SegmentGenerationWithFilterRecordsTest.java | 4 +-
.../SegmentGenerationWithMultipleRecordsTest.java | 2 +-
.../SegmentGenerationWithNoRecordsTest.java | 2 +-
.../SegmentGenerationWithNullValueVectorTest.java | 17 +-
.../SegmentGenerationWithTimeColumnTest.java | 4 +-
.../index/creator/SegmentPartitionTest.java | 4 +-
.../core/segment/index/loader/LoaderTest.java | 11 +-
.../index/loader/SegmentPreProcessorTest.java | 6 +-
.../BaseDefaultColumnHandlerTest.java | 4 +-
.../readers/NullValueVectorReaderImplTest.java | 6 +-
.../processing/framework/PartitionerTest.java | 8 +-
.../processing/framework/RecordFilterTest.java | 2 +-
.../framework/RecordTransformerTest.java | 4 +-
.../processing/framework/SegmentMapperTest.java | 8 +-
.../framework/SegmentProcessingFrameworkTest.java | 2 +-
.../store/ColumnIndexDirectoryTestHelper.java | 2 +-
.../segment/store/FilePerIndexDirectoryTest.java | 2 +-
.../segment/store/SegmentDirectoryPathsTest.java | 2 +-
.../segment/store/SegmentLocalFSDirectoryTest.java | 2 +-
.../store/SingleFileIndexDirectoryTest.java | 2 +-
.../pinot/core/startree/v2/BaseStarTreeV2Test.java | 18 +-
.../v2/builder/StarTreeV2BuilderConfigTest.java | 6 +-
.../pinot/core/transport/QueryRoutingTest.java | 8 +-
.../org/apache/pinot/core/util/CrcUtilsTest.java | 8 +-
.../core/util/SortedRangeIntersectionTest.java | 4 +-
.../pinot/core/util/TableConfigUtilsTest.java | 4 +-
.../forward/FixedByteChunkSVForwardIndexTest.java | 14 +-
.../forward/VarByteChunkSVForwardIndexTest.java | 38 +-
.../pinot/queries/BaseMultiValueQueriesTest.java | 8 +-
.../org/apache/pinot/queries/BaseQueriesTest.java | 2 +-
.../pinot/queries/BaseSingleValueQueriesTest.java | 8 +-
.../queries/DistinctCountBitmapQueriesTest.java | 6 +-
.../pinot/queries/DistinctCountQueriesTest.java | 6 +-
.../DistinctCountThetaSketchQueriesTest.java | 6 +-
.../apache/pinot/queries/DistinctQueriesTest.java | 6 +-
.../queries/FSTBasedRegexpLikeQueriesTest.java | 6 +-
.../apache/pinot/queries/FastHllQueriesTest.java | 8 +-
.../apache/pinot/queries/H3IndexQueriesTest.java | 6 +-
.../org/apache/pinot/queries/IdSetQueriesTest.java | 6 +-
.../pinot/queries/JsonMatchPredicateTest.java | 6 +-
.../queries/PercentileTDigestMVQueriesTest.java | 2 +-
.../queries/PercentileTDigestQueriesTest.java | 6 +-
.../RangePredicateWithSortedInvertedIndexTest.java | 8 +-
...SegmentPartitionedDistinctCountQueriesTest.java | 6 +-
.../pinot/queries/SerializedBytesQueriesTest.java | 6 +-
.../apache/pinot/queries/StUnionQueriesTest.java | 6 +-
.../pinot/queries/SumPrecisionQueriesTest.java | 6 +-
.../pinot/queries/TextSearchQueriesTest.java | 6 +-
.../apache/pinot/queries/TransformQueriesTest.java | 6 +-
.../converter/RealtimeSegmentConverterTest.java | 2 +-
.../v1/creator/BitmapInvertedIndexTest.java | 14 +-
.../pinot/segments/v1/creator/BlocksTest.java | 4 +-
.../segments/v1/creator/DictionariesTest.java | 12 +-
.../pinot/segments/v1/creator/IntArraysTest.java | 10 +-
.../v1/creator/OnHeapDictionariesTest.java | 10 +-
.../segments/v1/creator/SegmentTestUtils.java | 4 +-
.../util/IntDoubleIndexedPriorityQueueTest.java | 2 +-
.../util/IntObjectIndexedPriorityQueueTest.java | 2 +-
.../org/apache/pinot/compat/tests/SegmentOp.java | 4 +-
.../tests/ClusterIntegrationTestUtils.java | 4 +-
...vertToRawIndexMinionClusterIntegrationTest.java | 4 +-
.../tests/OfflineClusterIntegrationTest.java | 8 +-
.../tests/StarTreeClusterIntegrationTest.java | 4 +-
.../pinot/perf/BenchmarkOfflineIndexReader.java | 4 +-
.../pinot/perf/BenchmarkOrDocIdIterator.java | 2 +-
.../org/apache/pinot/perf/DictionaryDumper.java | 4 +-
.../org/apache/pinot/perf/RawIndexBenchmark.java | 6 +-
.../pinot/perf/StringDictionaryPerfTest.java | 6 +-
.../batch/common/SegmentGenerationTaskRunner.java | 10 +-
.../apache/pinot/hadoop/io/PinotOutputFormat.java | 2 +-
.../apache/pinot/hadoop/io/PinotRecordWriter.java | 4 +-
.../hadoop/job/mappers/SegmentCreationMapper.java | 10 +-
.../job/mappers/SegmentPreprocessingMapper.java | 3 +-
.../job/partitioners/GenericPartitioner.java | 2 +-
.../job/partitioners/PartitionFunctionFactory.java | 2 +-
.../spark/jobs/SparkSegmentCreationFunction.java | 10 +-
.../pinot/spark/jobs/SparkSegmentCreationJob.java | 2 +-
.../src/test/java/SegmentCreationSparkTest.java | 2 +-
.../merge_rollup/MergeRollupTaskExecutorTest.java | 2 +-
.../minion/tasks/purge/PurgeTaskExecutorTest.java | 2 +-
.../RealtimeToOfflineSegmentsTaskExecutorTest.java | 2 +-
.../filebased/FileBasedSegmentWriter.java | 2 +-
pinot-segment-spi/pom.xml | 84 +++++
.../segment/spi}/AggregationFunctionType.java | 2 +-
.../org/apache/pinot/segment/spi}/Constants.java | 2 +-
.../pinot/segment/spi}/ImmutableSegment.java | 9 +-
.../apache/pinot/segment/spi}/IndexSegment.java | 9 +-
.../apache/pinot/segment/spi}/MutableSegment.java | 3 +-
.../apache/pinot/segment/spi}/SegmentMetadata.java | 2 +-
.../spi/compression/ChunkCompressionType.java | 17 +-
.../segment/spi}/compression/ChunkCompressor.java | 2 +-
.../spi}/compression/ChunkDecompressor.java | 3 +-
.../spi}/converter/SegmentFormatConverter.java | 2 +-
.../spi}/creator/ColumnIndexCreationInfo.java | 6 +-
.../segment/spi}/creator/ColumnStatistics.java | 4 +-
.../spi}/creator/SegmentCreationDataSource.java | 2 +-
.../pinot/segment/spi}/creator/SegmentCreator.java | 4 +-
.../spi/creator}/SegmentGeneratorConfig.java | 26 +-
.../spi}/creator/SegmentIndexCreationDriver.java | 3 +-
.../creator/SegmentPreIndexStatsCollector.java | 2 +-
.../creator/SegmentPreIndexStatsContainer.java | 3 +-
.../pinot/segment/spi/creator}/SegmentVersion.java | 2 +-
.../segment/spi}/creator/StatsCollectorConfig.java | 11 +-
.../creator}/name/FixedSegmentNameGenerator.java | 3 +-
.../name/NormalizedDateSegmentNameGenerator.java | 9 +-
.../spi/creator}/name/SegmentNameGenerator.java | 2 +-
.../creator}/name/SimpleSegmentNameGenerator.java | 3 +-
.../pinot/segment/spi/datasource}/DataSource.java | 18 +-
.../spi/datasource}/DataSourceMetadata.java | 4 +-
.../spi}/index/column/ColumnIndexContainer.java | 21 +-
.../spi/index}/creator/BloomFilterCreator.java | 2 +-
.../DictionaryBasedInvertedIndexCreator.java | 2 +-
.../spi/index}/creator/ForwardIndexCreator.java | 2 +-
.../spi/index}/creator/GeoSpatialIndexCreator.java | 4 +-
.../segment/spi/index/creator}/H3IndexConfig.java | 3 +-
.../spi/index}/creator/InvertedIndexCreator.java | 2 +-
.../spi/index}/creator/JsonIndexCreator.java | 2 +-
.../creator/RawValueBasedInvertedIndexCreator.java | 5 +-
.../index}/creator/SegmentIndexCreationInfo.java | 2 +-
.../spi/index}/creator/TextIndexCreator.java | 2 +-
.../spi/index/reader}/BloomFilterReader.java | 2 +-
.../segment/spi/index/reader}/Dictionary.java | 2 +-
.../spi/index/reader}/ForwardIndexReader.java | 2 +-
.../index/reader}/ForwardIndexReaderContext.java | 2 +-
.../segment/spi/index/reader}/H3IndexReader.java | 3 +-
.../spi/index/reader}/H3IndexResolution.java | 2 +-
.../spi/index/reader}/InvertedIndexReader.java | 2 +-
.../segment/spi/index/reader}/JsonIndexReader.java | 5 +-
.../spi/index/reader}/MutableDictionary.java | 2 +-
.../spi/index/reader}/MutableForwardIndex.java | 6 +-
.../spi/index/reader}/NullValueVectorReader.java | 2 +-
.../spi/index/reader}/SortedIndexReader.java | 4 +-
.../segment/spi/index/reader}/TextIndexReader.java | 2 +-
.../spi/index/reader}/ValidDocIndexReader.java | 2 +-
.../startree}/AggregationFunctionColumnPair.java | 4 +-
.../segment/spi/index}/startree/StarTree.java | 4 +-
.../segment/spi/index}/startree/StarTreeNode.java | 2 +-
.../segment/spi/index/startree}/StarTreeV2.java | 5 +-
.../spi/index/startree}/StarTreeV2Constants.java | 2 +-
.../spi/index/startree}/StarTreeV2Metadata.java | 4 +-
.../segment/spi}/partition/PartitionFunction.java | 2 +-
.../pinot/segment/spi/partition}/Partitioner.java | 2 +-
.../spi/creator}/SegmentGeneratorConfigTest.java | 3 +-
.../NormalizedDateSegmentNameGeneratorTest.java | 5 +-
.../name/SimpleSegmentNameGeneratorTest.java | 4 +-
.../misc}/AggregationFunctionColumnPairTest.java | 5 +-
.../segment/spi/reader}/H3IndexResolutionTest.java | 3 +-
.../api/resources/SegmentMetadataFetcher.java | 4 +-
.../server/api/resources/TableSizeResource.java | 2 +-
.../starter/helix/HelixInstanceDataManager.java | 4 +-
.../server/starter/helix/HelixServerStarter.java | 6 +
.../starter/helix/SegmentFetcherAndLoader.java | 2 +-
.../apache/pinot/server/api/BaseResourceTest.java | 6 +-
.../pinot/server/api/TableSizeResourceTest.java | 2 +-
.../pinot/server/api/TablesResourceTest.java | 4 +-
.../java/org/apache/pinot/spi}/utils/Pairs.java | 2 +-
.../org/apache/pinot/tools/SegmentDumpTool.java | 6 +-
.../apache/pinot/tools/StarTreeIndexViewer.java | 10 +-
.../tools/admin/command/CreateSegmentCommand.java | 6 +-
.../anonymizer/PinotDataAndQueryAnonymizer.java | 6 +-
.../pinot/tools/perf/PerfBenchmarkDriver.java | 2 +-
.../query/comparison/SegmentInfoProvider.java | 4 +-
.../apache/pinot/tools/scan/query/Aggregation.java | 4 +-
.../tools/scan/query/EqualsPredicateFilter.java | 2 +-
.../pinot/tools/scan/query/InPredicateFilter.java | 2 +-
.../tools/scan/query/NotInPredicateFilter.java | 2 +-
.../pinot/tools/scan/query/NotPredicateFilter.java | 2 +-
.../apache/pinot/tools/scan/query/Projection.java | 8 +-
.../tools/scan/query/RangePredicateFilter.java | 2 +-
.../tools/scan/query/SegmentQueryProcessor.java | 10 +-
.../apache/pinot/tools/scan/query/Selection.java | 4 +-
.../converter/DictionaryToRawIndexConverter.java | 20 +-
.../segment/converter/SegmentMergeCommand.java | 4 +-
.../converter/PinotSegmentConverterTest.java | 2 +-
pom.xml | 6 +
618 files changed, 2508 insertions(+), 2062 deletions(-)
copy pinot-core/src/main/java/org/apache/pinot/core/common/Constants.java =>
pinot-common/src/main/java/org/apache/pinot/common/exception/SchemaBackwardIncompatibleException.java
(80%)
copy
pinot-core/src/main/java/org/apache/pinot/core/common/datatable/{DataTableImplV2.java
=> BaseDataTable.java} (51%)
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/common/datatable/DataTableImplV3.java
create mode 100644 pinot-segment-spi/pom.xml
rename {pinot-common/src/main/java/org/apache/pinot/common/function =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/AggregationFunctionType.java
(98%)
rename {pinot-core/src/main/java/org/apache/pinot/core/common =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/Constants.java
(96%)
rename {pinot-core/src/main/java/org/apache/pinot/core/indexsegment/immutable
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/ImmutableSegment.java
(84%)
rename {pinot-core/src/main/java/org/apache/pinot/core/indexsegment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/IndexSegment.java
(90%)
rename {pinot-core/src/main/java/org/apache/pinot/core/indexsegment/mutable =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/MutableSegment.java
(93%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment/index/metadata
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/SegmentMetadata.java
(98%)
copy
pinot-core/src/main/java/org/apache/pinot/core/segment/index/readers/InvertedIndexReader.java
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/compression/ChunkCompressionType.java
(76%)
rename {pinot-core/src/main/java/org/apache/pinot/core/io =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/compression/ChunkCompressor.java
(96%)
rename {pinot-core/src/main/java/org/apache/pinot/core/io =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/compression/ChunkDecompressor.java
(92%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment/index =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/converter/SegmentFormatConverter.java
(95%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/creator/ColumnIndexCreationInfo.java
(95%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/creator/ColumnStatistics.java
(95%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/creator/SegmentCreationDataSource.java
(96%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/creator/SegmentCreator.java
(94%)
rename {pinot-core/src/main/java/org/apache/pinot/core/indexsegment/generator
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/creator}/SegmentGeneratorConfig.java
(95%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/creator/SegmentIndexCreationDriver.java
(94%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/creator/SegmentPreIndexStatsCollector.java
(95%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/creator/SegmentPreIndexStatsContainer.java
(90%)
rename {pinot-core/src/main/java/org/apache/pinot/core/indexsegment/generator
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/creator}/SegmentVersion.java
(94%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/creator/StatsCollectorConfig.java
(83%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/creator}/name/FixedSegmentNameGenerator.java
(92%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/creator}/name/NormalizedDateSegmentNameGenerator.java
(92%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/creator}/name/SegmentNameGenerator.java
(96%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/creator}/name/SimpleSegmentNameGenerator.java
(94%)
rename {pinot-core/src/main/java/org/apache/pinot/core/common =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/datasource}/DataSource.java
(82%)
rename {pinot-core/src/main/java/org/apache/pinot/core/common =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/datasource}/DataSourceMetadata.java
(95%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/index/column/ColumnIndexContainer.java
(77%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index}/creator/BloomFilterCreator.java
(95%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index}/creator/DictionaryBasedInvertedIndexCreator.java
(98%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index}/creator/ForwardIndexCreator.java
(98%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index}/creator/GeoSpatialIndexCreator.java
(95%)
rename
{pinot-core/src/main/java/org/apache/pinot/core/segment/creator/impl/inv/geospatial
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/creator}/H3IndexConfig.java
(93%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index}/creator/InvertedIndexCreator.java
(95%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index}/creator/JsonIndexCreator.java
(95%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index}/creator/RawValueBasedInvertedIndexCreator.java
(93%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index}/creator/SegmentIndexCreationInfo.java
(95%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index}/creator/TextIndexCreator.java
(95%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment/index/readers
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/reader}/BloomFilterReader.java
(96%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment/index/readers
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/reader}/Dictionary.java
(99%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment/index/readers
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/reader}/ForwardIndexReader.java
(99%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment/index/readers
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/reader}/ForwardIndexReaderContext.java
(95%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment/index/readers
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/reader}/H3IndexReader.java
(90%)
rename
{pinot-core/src/main/java/org/apache/pinot/core/segment/creator/impl/inv/geospatial
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/reader}/H3IndexResolution.java
(96%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment/index/readers
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/reader}/InvertedIndexReader.java
(94%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment/index/readers
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/reader}/JsonIndexReader.java
(85%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment/index/readers
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/reader}/MutableDictionary.java
(96%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment/index/readers
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/reader}/MutableForwardIndex.java
(98%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment/index/readers
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/reader}/NullValueVectorReader.java
(96%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment/index/readers
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/reader}/SortedIndexReader.java
(93%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment/index/readers
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/reader}/TextIndexReader.java
(96%)
rename {pinot-core/src/main/java/org/apache/pinot/core/segment/index/readers
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/reader}/ValidDocIndexReader.java
(95%)
rename {pinot-core/src/main/java/org/apache/pinot/core/startree/v2 =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/startree}/AggregationFunctionColumnPair.java
(96%)
rename {pinot-core/src/main/java/org/apache/pinot/core =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index}/startree/StarTree.java
(91%)
rename {pinot-core/src/main/java/org/apache/pinot/core =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index}/startree/StarTreeNode.java
(97%)
rename {pinot-core/src/main/java/org/apache/pinot/core/startree/v2 =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/startree}/StarTreeV2.java
(91%)
rename {pinot-core/src/main/java/org/apache/pinot/core/startree/v2 =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/startree}/StarTreeV2Constants.java
(97%)
rename {pinot-core/src/main/java/org/apache/pinot/core/startree/v2 =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/index/startree}/StarTreeV2Metadata.java
(95%)
rename {pinot-core/src/main/java/org/apache/pinot/core/data =>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi}/partition/PartitionFunction.java
(96%)
rename
{pinot-core/src/main/java/org/apache/pinot/core/segment/processing/partitioner
=>
pinot-segment-spi/src/main/java/org/apache/pinot/segment/spi/partition}/Partitioner.java
(94%)
rename {pinot-core/src/test/java/org/apache/pinot/core/indexsegment/generator
=>
pinot-segment-spi/src/test/java/org/apache/pinot/segment/spi/creator}/SegmentGeneratorConfigTest.java
(97%)
rename {pinot-core/src/test/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/test/java/org/apache/pinot/segment/spi/creator}/name/NormalizedDateSegmentNameGeneratorTest.java
(97%)
rename {pinot-core/src/test/java/org/apache/pinot/core/segment =>
pinot-segment-spi/src/test/java/org/apache/pinot/segment/spi/creator}/name/SimpleSegmentNameGeneratorTest.java
(93%)
rename {pinot-core/src/test/java/org/apache/pinot/core/startree/v2 =>
pinot-segment-spi/src/test/java/org/apache/pinot/segment/spi/misc}/AggregationFunctionColumnPairTest.java
(96%)
rename
{pinot-core/src/test/java/org/apache/pinot/core/segment/creator/impl/inv/geospatial
=>
pinot-segment-spi/src/test/java/org/apache/pinot/segment/spi/reader}/H3IndexResolutionTest.java
(91%)
rename {pinot-common/src/main/java/org/apache/pinot/common =>
pinot-spi/src/main/java/org/apache/pinot/spi}/utils/Pairs.java (99%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
