This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ea68bc31d49 Avoid deleting wal files pinned by the iot consensus
(#12006)
add f9893075b42 Introduce aggregate function MaxBy
No new revisions were added by this update.
Summary of changes:
.../constant/BuiltinAggregationFunctionEnum.java | 2 +-
.../db/it/aggregation/IoTDBAggregationIT.java | 52 +++
.../IoTDBMaxBy2IT.java} | 9 +-
.../maxby/IoTDBMaxBy3IT.java} | 21 +-
.../maxby/IoTDBMaxByAlignedSeriesIT.java | 71 +++
.../db/it/aggregation/maxby/IoTDBMaxByIT.java | 487 +++++++++++++++++++++
.../java/org/apache/iotdb/tool/ExportTsFile.java | 3 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 1 +
.../sql/factory/IoTDBDynamicTableFactory.java | 1 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 3 +-
.../execution/aggregation/AccumulatorFactory.java | 43 +-
.../execution/aggregation/Aggregator.java | 18 +-
.../execution/aggregation/MaxByAccumulator.java | 424 ++++++++++++++++++
.../SlidingWindowAggregatorFactory.java | 35 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 21 +-
.../plan/analyze/ExpressionTypeAnalyzer.java | 39 +-
.../db/queryengine/plan/analyze/TypeProvider.java | 4 +
.../ReplaceRawPathWithGroupedPathVisitor.java | 7 +-
.../cartesian/BindSchemaForExpressionVisitor.java | 7 +-
.../cartesian/BindSchemaForPredicateVisitor.java | 6 +-
...catDeviceAndBindSchemaForExpressionVisitor.java | 7 +-
.../ConcatExpressionWithSuffixPathsVisitor.java | 23 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 1 +
.../plan/planner/LogicalPlanBuilder.java | 52 ++-
.../plan/planner/OperatorTreeGenerator.java | 47 +-
.../distribution/DistributionPlanContext.java | 7 +-
.../plan/planner/distribution/SourceRewriter.java | 45 +-
.../plan/parameter/AggregationDescriptor.java | 36 +-
.../CrossSeriesAggregationDescriptor.java | 146 ++++--
.../org/apache/iotdb/db/utils/SchemaUtils.java | 4 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 3 +
.../iotdb/db/utils/constant/SqlConstant.java | 1 +
.../iotdb/db/utils/constant/TestConstant.java | 4 +
.../execution/aggregation/AccumulatorTest.java | 81 +++-
.../AlignedSeriesAggregationScanOperatorTest.java | 22 +-
.../execution/operator/OperatorMemoryTest.java | 8 +-
.../SlidingWindowAggregationOperatorTest.java | 2 +-
.../plan/analyze/AggregationDescriptorTest.java | 8 +-
.../plan/planner/LogicalPlannerTest.java | 2 +-
.../plan/planner/QueryLogicalPlanUtil.java | 27 +-
.../distribution/AggregationDistributionTest.java | 31 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 3 +-
.../node/process/GroupByTagNodeSerdeTest.java | 22 +-
.../udf/builtin/BuiltinAggregationFunction.java | 5 +-
.../thrift-commons/src/main/thrift/common.thrift | 3 +-
45 files changed, 1602 insertions(+), 242 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/{IoTDBAggregationByLevel2IT.java
=> maxby/IoTDBMaxBy2IT.java} (82%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{selectinto/IoTDBSelectInto3IT.java
=> aggregation/maxby/IoTDBMaxBy3IT.java} (69%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/maxby/IoTDBMaxByAlignedSeriesIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/maxby/IoTDBMaxByIT.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/aggregation/MaxByAccumulator.java
