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 b5dfbfd4129 [IOTDB-6299] Fix bug in merging overlapped data process
caused by filter & offset push down
add 2a91bb5904e Introduce Aggregation Function MinBy
No new revisions were added by this update.
Summary of changes:
.../constant/BuiltinAggregationFunctionEnum.java | 3 +-
.../db/it/aggregation/IoTDBAggregationIT.java | 52 +++
.../db/it/aggregation/maxby/IoTDBMaxByIT.java | 3 +-
.../IoTDBMinBy2IT.java} | 4 +-
.../IoTDBMinBy3IT.java} | 4 +-
.../IoTDBMinByAlignedSeriesIT.java} | 24 +-
.../IoTDBMaxByIT.java => minby/IoTDBMinByIT.java} | 131 ++++---
.../java/org/apache/iotdb/tool/ExportTsFile.java | 3 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 1 +
.../sql/factory/IoTDBDynamicTableFactory.java | 1 +
.../execution/aggregation/AccumulatorFactory.java | 4 +
.../execution/aggregation/MaxByAccumulator.java | 404 +--------------------
...cumulator.java => MaxMinByBaseAccumulator.java} | 63 ++--
.../execution/aggregation/MinByAccumulator.java} | 39 +-
.../SlidingWindowAggregatorFactory.java | 34 ++
.../plan/analyze/ExpressionTypeAnalyzer.java | 1 +
.../db/queryengine/plan/parser/ASTVisitor.java | 1 +
.../plan/parameter/AggregationDescriptor.java | 3 +
.../org/apache/iotdb/db/utils/SchemaUtils.java | 5 +
.../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 | 33 ++
.../udf/builtin/BuiltinAggregationFunction.java | 5 +-
.../thrift-commons/src/main/thrift/common.thrift | 1 +
25 files changed, 300 insertions(+), 527 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/{maxby/IoTDBMaxBy2IT.java
=> minby/IoTDBMinBy2IT.java} (93%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/{maxby/IoTDBMaxBy3IT.java
=> minby/IoTDBMinBy3IT.java} (93%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/{maxby/IoTDBMaxByAlignedSeriesIT.java
=> minby/IoTDBMinByAlignedSeriesIT.java} (89%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aggregation/{maxby/IoTDBMaxByIT.java
=> minby/IoTDBMinByIT.java} (78%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/aggregation/{MaxByAccumulator.java
=> MaxMinByBaseAccumulator.java} (86%)
copy
iotdb-core/{tsfile/src/test/java/org/apache/iotdb/tsfile/read/reader/FakedBatchReader.java
=>
datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/aggregation/MinByAccumulator.java}
(57%)
