This is an automated email from the ASF dual-hosted git repository. haonan pushed a commit to branch object_type in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 156dfcc1f62e7c2125c1ff69cf09eb541fdb8e60 Merge: 60dc05ea16b 73c681a7c0d Author: HTHou <[email protected]> AuthorDate: Tue Jul 8 15:04:32 2025 +0800 Merge branch 'object_type' of github.com:apache/iotdb into object_type .../main/java/org/apache/iotdb/pipe/api/type/Type.java | 5 ++++- .../apache/iotdb/jdbc/IoTDBAbstractDatabaseMetadata.java | 1 + .../subscription/payload/SubscriptionSessionDataSet.java | 1 + .../java/org/apache/iotdb/db/conf/IoTDBDescriptor.java | 1 + .../pipe/connector/protocol/opcda/OpcDaServerHandle.java | 2 ++ .../pipe/connector/util/sorter/PipeTabletEventSorter.java | 1 + .../db/pipe/processor/aggregate/AggregateProcessor.java | 3 +++ .../db/protocol/thrift/impl/ClientRPCServiceImpl.java | 2 +- .../execution/aggregation/AccumulatorFactory.java | 1 + .../queryengine/execution/aggregation/AvgAccumulator.java | 1 + .../execution/aggregation/ExtremeAccumulator.java | 6 ++++++ .../execution/aggregation/FirstValueAccumulator.java | 6 ++++++ .../execution/aggregation/LastValueAccumulator.java | 6 ++++++ .../execution/aggregation/MaxMinByBaseAccumulator.java | 6 ++++++ .../execution/aggregation/MaxValueAccumulator.java | 6 ++++++ .../execution/aggregation/MinValueAccumulator.java | 6 ++++++ .../queryengine/execution/aggregation/SumAccumulator.java | 2 +- .../execution/aggregation/VarianceAccumulator.java | 1 + .../queryengine/execution/operator/AggregationUtil.java | 1 + .../execution/operator/process/TopKOperator.java | 2 ++ .../execution/operator/process/TransformOperator.java | 1 + .../operator/process/join/merge/MergeSortComparator.java | 1 + .../process/window/function/value/LagFunction.java | 1 + .../process/window/function/value/LeadFunction.java | 1 + .../operator/process/window/utils/RowComparator.java | 3 +++ .../execution/operator/source/SeriesScanUtil.java | 2 +- .../source/relational/LastQueryAggTableScanOperator.java | 1 + .../source/relational/aggregation/AccumulatorFactory.java | 2 ++ .../aggregation/ApproxCountDistinctAccumulator.java | 1 + .../source/relational/aggregation/AvgAccumulator.java | 2 ++ .../source/relational/aggregation/ExtremeAccumulator.java | 5 +++++ .../source/relational/aggregation/FirstAccumulator.java | 4 ++++ .../source/relational/aggregation/FirstByAccumulator.java | 4 ++++ .../source/relational/aggregation/LastAccumulator.java | 4 ++++ .../source/relational/aggregation/LastByAccumulator.java | 4 ++++ .../source/relational/aggregation/SumAccumulator.java | 2 ++ .../aggregation/TableMaxMinByBaseAccumulator.java | 5 +++++ .../relational/aggregation/TableVarianceAccumulator.java | 2 ++ .../operator/source/relational/aggregation/Utils.java | 2 ++ .../grouped/GroupedApproxCountDistinctAccumulator.java | 1 + .../aggregation/grouped/GroupedAvgAccumulator.java | 1 + .../aggregation/grouped/GroupedExtremeAccumulator.java | 8 ++++++++ .../aggregation/grouped/GroupedFirstAccumulator.java | 8 ++++++++ .../aggregation/grouped/GroupedFirstByAccumulator.java | 9 +++++++++ .../aggregation/grouped/GroupedLastAccumulator.java | 8 ++++++++ .../aggregation/grouped/GroupedLastByAccumulator.java | 9 +++++++++ .../aggregation/grouped/GroupedMaxAccumulator.java | 8 ++++++++ .../grouped/GroupedMaxMinByBaseAccumulator.java | 15 +++++++++++++++ .../aggregation/grouped/GroupedMinAccumulator.java | 8 ++++++++ .../aggregation/grouped/GroupedModeAccumulator.java | 4 ++++ .../aggregation/grouped/GroupedSumAccumulator.java | 1 + .../aggregation/grouped/GroupedVarianceAccumulator.java | 1 + .../execution/operator/window/WindowManagerFactory.java | 2 ++ .../queryengine/plan/planner/plan/node/PlanNodeType.java | 2 ++ .../plan/planner/plan/node/write/FileNode.java | 3 +++ .../plan/planner/plan/node/write/InsertTabletNode.java | 5 +++++ .../plan/relational/type/InternalTypeManager.java | 4 ++-- .../column/unary/scalar/ReadObjectColumnTransformer.java | 1 + .../transformation/dag/input/ConstantInputReader.java | 1 + .../transformer/unary/ArithmeticNegationTransformer.java | 1 + .../dag/transformer/unary/InTransformer.java | 2 ++ .../transformer/unary/scalar/CastFunctionTransformer.java | 7 +++++++ .../transformer/unary/scalar/DiffFunctionTransformer.java | 1 + .../unary/scalar/RoundFunctionTransformer.java | 1 + .../transformation/dag/util/TransformUtils.java | 2 ++ .../db/queryengine/transformation/dag/util/TypeUtils.java | 1 + .../datastructure/row/SerializableRowList.java | 2 ++ .../datastructure/tv/SerializableTVList.java | 1 + .../dataregion/memtable/AlignedReadOnlyMemChunk.java | 1 + .../read/reader/chunk/MemAlignedPageReader.java | 1 + .../db/storageengine/dataregion/wal/node/WALNode.java | 5 +++++ .../load/splitter/BatchedAlignedValueChunkData.java | 2 ++ .../rescon/memory/PrimitiveArrayManager.java | 1 + .../apache/iotdb/db/tools/TsFileSplitByPartitionTool.java | 1 + .../main/java/org/apache/iotdb/db/utils/CommonUtils.java | 1 + .../org/apache/iotdb/db/utils/TypeInferenceUtils.java | 1 + .../MergeSortMultiAlignedTVListIterator.java | 1 + .../utils/datastructure/MergeSortMultiTVListIterator.java | 1 + .../utils/datastructure/MultiAlignedTVListIterator.java | 1 + .../iotdb/db/utils/datastructure/MultiTVListIterator.java | 1 + .../org/apache/iotdb/db/utils/datastructure/TVList.java | 1 + .../iotdb/db/utils/windowing/window/WindowImpl.java | 1 + .../db/utils/datastructure/PrimitiveArrayManagerTest.java | 1 + .../org/apache/iotdb/commons/udf/builtin/UDTFAbs.java | 3 +++ .../org/apache/iotdb/commons/udf/builtin/UDTFBottomK.java | 1 + .../iotdb/commons/udf/builtin/UDTFCommonDerivative.java | 1 + .../commons/udf/builtin/UDTFCommonValueDifference.java | 1 + .../org/apache/iotdb/commons/udf/builtin/UDTFConst.java | 5 +++++ .../commons/udf/builtin/UDTFContinuouslySatisfy.java | 2 ++ .../commons/udf/builtin/UDTFEqualSizeBucketAggSample.java | 1 + .../commons/udf/builtin/UDTFEqualSizeBucketM4Sample.java | 1 + .../udf/builtin/UDTFEqualSizeBucketOutlierSample.java | 1 + .../udf/builtin/UDTFEqualSizeBucketRandomSample.java | 1 + .../org/apache/iotdb/commons/udf/builtin/UDTFInRange.java | 3 +++ .../org/apache/iotdb/commons/udf/builtin/UDTFJexl.java | 3 +++ .../java/org/apache/iotdb/commons/udf/builtin/UDTFM4.java | 1 + .../org/apache/iotdb/commons/udf/builtin/UDTFMath.java | 3 +++ .../commons/udf/builtin/UDTFNonNegativeDerivative.java | 1 + .../udf/builtin/UDTFNonNegativeValueDifference.java | 1 + .../org/apache/iotdb/commons/udf/builtin/UDTFOnOff.java | 1 + .../org/apache/iotdb/commons/udf/builtin/UDTFSelectK.java | 2 ++ .../org/apache/iotdb/commons/udf/builtin/UDTFTopK.java | 1 + .../apache/iotdb/commons/udf/builtin/UDTFValueTrend.java | 1 + .../org/apache/iotdb/commons/utils/SerializeUtils.java | 6 ++++++ 104 files changed, 278 insertions(+), 6 deletions(-)
