This is an automated email from the ASF dual-hosted git repository.
jackie pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 3bad67db07 feat(ui): persist oidc auth details (#10389)
add 01ff18d47c Introduce BaseProjectOperator and ValueBlock (#10405)
No new revisions were added by this update.
Summary of changes:
.../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 +-
.../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 +-
.../operator/docvalsets/TransformBlockValSet.java | 44 +-
.../operator/filter/ExpressionFilterOperator.java | 19 +-
.../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 | 40 +-
.../pinot/core/operator/query/GroupByOperator.java | 30 +-
.../query/LinearSelectionOrderByOperator.java | 45 +-
.../core/operator/query/SelectionOnlyOperator.java | 34 +-
.../operator/query/SelectionOrderByOperator.java | 66 +-
.../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 | 22 +-
.../apache/pinot/core/plan/DistinctPlanNode.java | 8 +-
.../apache/pinot/core/plan/GroupByPlanNode.java | 30 +-
...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 +-
.../function/AggregationFunctionUtils.java | 48 +-
.../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 +-
.../core/query/utils/OrderByComparatorFactory.java | 19 +-
.../executor/StarTreeAggregationExecutor.java | 8 +-
.../startree/executor/StarTreeGroupByExecutor.java | 12 +-
...mPlanNode.java => StarTreeProjectPlanNode.java} | 56 +-
.../startree/plan/StarTreeProjectionPlanNode.java | 52 -
.../DictionaryBasedGroupKeyGeneratorTest.java | 54 +-
.../groupby/NoDictionaryGroupKeyGeneratorTest.java | 24 +-
.../pinot/queries/ExplainPlanQueriesTest.java | 1583 +++++++++++---------
.../tests/OfflineClusterIntegrationTest.java | 5 +-
130 files changed, 2905 insertions(+), 2942 deletions(-)
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
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
