This is an automated email from the ASF dual-hosted git repository.
mcvsubbu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-pinot.git.
from f8c2cf3 Put order-by expressions in front of selection expreesions in
selection DataSchema (#4629)
add a0c84fe Implement DISTINCT (#4535)
No new revisions were added by this update.
Summary of changes:
.../requesthandler/BaseBrokerRequestHandler.java | 19 +-
.../common/function/AggregationFunctionType.java | 3 +-
.../apache/pinot/common/request/BrokerRequest.java | 199 ++++--
.../parsers/PinotQuery2BrokerRequestConverter.java | 77 ++-
.../org/apache/pinot/pql/parsers/Pql2Compiler.java | 3 +-
.../pql/parsers/pql2/ast/FunctionCallAstNode.java | 59 +-
.../parsers/pql2/ast/OutputColumnListAstNode.java | 91 +++
.../pinot/pql/parsers/pql2/ast/SelectAstNode.java | 25 +-
.../apache/pinot/sql/parsers/CalciteSqlParser.java | 55 +-
.../apache/pinot/pql/parsers/Pql2CompilerTest.java | 38 ++
.../pinot/sql/parsers/CalciteSqlCompilerTest.java | 327 ++++++++++
pinot-common/src/thrift/request.thrift | 1 +
.../apache/pinot/core/common/ObjectSerDeUtils.java | 54 +-
.../core/operator/CombineGroupByOperator.java | 2 +-
.../transform/TransformBlockDataFetcher.java | 68 +-
.../core/plan/AggregationGroupByPlanNode.java | 2 +-
.../pinot/core/plan/AggregationPlanNode.java | 2 +-
.../plan/DictionaryBasedAggregationPlanNode.java | 9 +-
.../plan/MetadataBasedAggregationPlanNode.java | 13 +-
.../apache/pinot/core/plan/TransformPlanNode.java | 15 +-
.../core/plan/maker/InstancePlanMakerImplV2.java | 6 +-
.../aggregation/DefaultAggregationExecutor.java | 52 +-
.../core/query/aggregation/DistinctTable.java | 235 +++++++
.../function/AggregationFunctionFactory.java | 15 +-
.../function/AggregationFunctionUtils.java | 34 +-
.../function/DistinctAggregationFunction.java | 169 +++++
.../core/query/reduce/BrokerReduceService.java | 63 +-
.../function/AggregationFunctionFactoryTest.java | 107 ++-
.../apache/pinot/queries/DistinctQueriesTest.java | 719 +++++++++++++++++++++
...erSegmentAggregationSingleValueQueriesTest.java | 73 +++
...erSegmentAggregationSingleValueQueriesTest.java | 68 +-
.../AggregationGroupByTrimmingServiceTest.java | 7 +-
.../tests/ClusterIntegrationTestUtils.java | 15 +-
.../tests/OfflineClusterIntegrationTest.java | 29 +
34 files changed, 2443 insertions(+), 211 deletions(-)
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/DistinctTable.java
create mode 100644
pinot-core/src/main/java/org/apache/pinot/core/query/aggregation/function/DistinctAggregationFunction.java
create mode 100644
pinot-core/src/test/java/org/apache/pinot/queries/DistinctQueriesTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
