This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch fix-15426
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from aff99cef462 Update LoadTsFileDispatcherImpl.java
add 6b38b5d5415 Optimize sort properties of JoinNode in case of JOIN USING
add a70575f6fdc Correct error messages when encountered
IllegalPathException (#15559)
add 4342166741b Feat: Add APPROX_MOST_FREQUENT Aggregation Function
add f0ff739c624 Merge branch 'master' of https://github.com/apache/iotdb
into fix-15426
No new revisions were added by this update.
Summary of changes:
LICENSE | 15 ++
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 12 +-
.../it/query/recent/IoTDBTableAggregationIT.java | 53 ++++
.../AbstractApproxMostFrequentAccumulator.java | 57 ++++
.../relational/aggregation/AccumulatorFactory.java | 62 +++++
.../ApproxCountDistinctAccumulator.java | 5 +-
.../BinaryApproxMostFrequentAccumulator.java | 130 +++++++++
.../BlobApproxMostFrequentAccumulator.java | 39 +++
.../BooleanApproxMostFrequentAccumulator.java | 129 +++++++++
.../DoubleApproxMostFrequentAccumulator.java | 129 +++++++++
.../FloatApproxMostFrequentAccumulator.java | 129 +++++++++
.../IntApproxMostFrequentAccumulator.java | 129 +++++++++
.../LongApproxMostFrequentAccumulator.java | 128 +++++++++
.../ApproxMostFrequentBucketDeserializer.java | 21 ++
.../ApproxMostFrequentBucketSerializer.java | 21 ++
.../aggregation/approximate/Counter.java | 71 +++++
.../aggregation/approximate/DoublyLinkedList.java | 173 ++++++++++++
.../approximate/ExternalizableUtil.java | 31 +++
.../aggregation/{ => approximate}/HyperLogLog.java | 2 +-
.../{ => approximate}/HyperLogLogStateFactory.java | 2 +-
.../relational/aggregation/approximate/ITopK.java | 43 +++
.../aggregation/approximate/ListNode2.java | 42 +++
.../relational/aggregation/approximate/Pair.java | 56 ++++
.../aggregation/approximate/SpaceSaving.java | 147 +++++++++++
.../approximate/SpaceSavingByteCalculator.java | 21 ++
.../approximate/SpaceSavingStateFactory.java | 90 +++++++
.../aggregation/approximate/StreamSummary.java | 294 +++++++++++++++++++++
...stractGroupedApproxMostFrequentAccumulator.java | 67 +++++
...BinaryGroupedApproxMostFrequentAccumulator.java | 105 ++++++++
.../BlobGroupedApproxMostFrequentAccumulator.java | 40 +++
...ooleanGroupedApproxMostFrequentAccumulator.java | 104 ++++++++
...DoubleGroupedApproxMostFrequentAccumulator.java | 104 ++++++++
.../FloatGroupedApproxMostFrequentAccumulator.java | 104 ++++++++
.../GroupedApproxCountDistinctAccumulator.java | 6 +-
.../IntGroupedApproxMostFrequentAccumulator.java | 104 ++++++++
.../LongGroupedApproxMostFrequentAccumulator.java | 104 ++++++++
.../grouped/array/HyperLogLogBigArray.java | 2 +-
.../grouped/array/SpaceSavingBigArray.java | 93 +++++++
.../analyze/cache/partition/PartitionCache.java | 6 +-
.../relational/metadata/TableMetadataImpl.java | 11 +-
.../distribute/TableDistributedPlanGenerator.java | 79 +++++-
.../plan/relational/sql/parser/AstBuilder.java | 10 +
.../iotdb/db/utils/constant/SqlConstant.java | 1 +
.../plan/relational/analyzer/JoinTest.java | 124 +++++++++
.../planner/assertions/PlanMatchPattern.java | 4 +
.../TableBuiltinAggregationFunction.java | 2 +-
.../thrift-commons/src/main/thrift/common.thrift | 3 +-
47 files changed, 3085 insertions(+), 19 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/AbstractApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/BinaryApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/BlobApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/BooleanApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/DoubleApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/FloatApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/IntApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/LongApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/approximate/ApproxMostFrequentBucketDeserializer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/approximate/ApproxMostFrequentBucketSerializer.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/approximate/Counter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/approximate/DoublyLinkedList.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/approximate/ExternalizableUtil.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/{
=> approximate}/HyperLogLog.java (99%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/{
=> approximate}/HyperLogLogStateFactory.java (98%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/approximate/ITopK.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/approximate/ListNode2.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/approximate/Pair.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/approximate/SpaceSaving.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/approximate/SpaceSavingByteCalculator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/approximate/SpaceSavingStateFactory.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/approximate/StreamSummary.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/AbstractGroupedApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/BinaryGroupedApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/BlobGroupedApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/BooleanGroupedApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/DoubleGroupedApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/FloatGroupedApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/IntGroupedApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/LongGroupedApproxMostFrequentAccumulator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/operator/source/relational/aggregation/grouped/array/SpaceSavingBigArray.java
