This is an automated email from the ASF dual-hosted git repository.
caogaofei pushed a change to branch beyyes/join
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 914554e3e03 fix RewriteVisitor
add 996ce09753b Bump ratis version from 3.1.0 to 3.1.1-0133c90-SNAPSHOT
#13357
add b0501ae6eda Pipe IT: Avoid IoTDBPipeTypeConversionIT from creating too
many DataRegions and SchemaRegions (#13378)
add 71f765b727c Pipe: add timely consistency check for pipe memory control
(#13354)
add 08fc8abe247 Pipe: better memory control for in-memory tablets (#13301)
add f56f388fbbe Pipe IT: req size automatic fragmentation integration test
(#13342)
add 37c58c82840 Pipe: avoid logging warn when clearing event ref after
releasing the event & minor improve for javadoc (#13371)
add ed9d6c0da8b Update iotdb client example reference (#13386)
add 334c457438b Pipe: Fixed the bug that OPCUASink's model effect is
reverted (#13377)
add 9460661d256 Fix WAL Exception catch & support new DataTypes in
QueryDataSetUtils (#13359)
add 0d9fc3a8801 Add query metrics for table model
add 64cf3844c02 Change FileTimeIndexCache to region level (#13353)
add 91f5c6ca921 Fix IoTDBSetConfigurationIT.setClusterNameTest (wait
DataNode's restarting for more time, and slow down requesting frequency) #13373
add aaa72b1161a Fix cpp client IT on macos (#13392)
add 7f6211e80c9 Remove unnecessary type cast log (#13391)
add 10dc7c55fbe merge master
No new revisions were added by this update.
Summary of changes:
.github/workflows/multi-language-client.yml | 11 +-
.../main/java/org/apache/iotdb/TabletExample.java | 4 +
.../java/org/apache/iotdb/udf/UDAFExample.java | 4 +
.../apache/iotdb/db/query/udf/example/UDAFAvg.java | 4 +
.../apache/iotdb/db/query/udf/example/UDAFSum.java | 4 +
.../it/env/cluster/config/MppCommonConfig.java | 10 +
.../env/cluster/config/MppSharedCommonConfig.java | 8 +
.../it/env/remote/config/RemoteCommonConfig.java | 6 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 3 +
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 3 +-
.../pipe/it/autocreate/AbstractPipeDualAutoIT.java | 8 +-
.../pipe/it/manual/AbstractPipeDualManualIT.java | 8 +-
.../pipe/it/manual/IoTDBPipeReqAutoSliceIT.java | 482 +++++++++++++++++++++
.../pipe/it/manual/IoTDBPipeTypeConversionIT.java | 48 +-
.../java/org/apache/iotdb/tool/ImportData.java | 3 +
iotdb-client/client-py/README.md | 2 +-
.../iotdb/jdbc/GroupedLSBWatermarkEncoder.java | 4 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 3 +
.../connector/protocol/opcua/OpcUaConnector.java | 2 +-
.../iotdb/db/pipe/event/common/row/PipeRow.java | 15 +
.../db/pipe/event/common/row/PipeRowCollector.java | 14 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 6 +-
.../container/TsFileInsertionDataContainer.java | 12 +
.../query/TsFileInsertionQueryDataContainer.java | 3 +-
.../TsFileInsertionQueryDataTabletIterator.java | 46 +-
.../scan/TsFileInsertionScanDataContainer.java | 43 +-
.../CustomizedReadableIntermediateResults.java | 16 +
.../numeric/AbstractSameTypeNumericOperator.java | 18 +
.../db/pipe/resource/memory/PipeMemoryManager.java | 86 +++-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 128 ++++++
.../execution/aggregation/AccumulatorFactory.java | 4 +
.../execution/aggregation/AvgAccumulator.java | 4 +
.../execution/aggregation/ExtremeAccumulator.java | 24 +
.../aggregation/MaxMinByBaseAccumulator.java | 2 +
.../execution/aggregation/MaxValueAccumulator.java | 6 +
.../execution/aggregation/MinValueAccumulator.java | 6 +
.../execution/aggregation/SumAccumulator.java | 4 +
.../execution/aggregation/VarianceAccumulator.java | 4 +
.../operator/window/WindowManagerFactory.java | 10 +
.../queryengine/metric/QueryPlanCostMetricSet.java | 149 ++++++-
.../iotdb/db/queryengine/plan/Coordinator.java | 14 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 11 +-
.../db/queryengine/plan/analyze/Analyzer.java | 4 +-
.../queryengine/plan/analyze/TemplatedAnalyze.java | 3 +-
.../queryengine/plan/execution/QueryExecution.java | 9 +-
.../TableModelStatementMemorySourceVisitor.java | 3 +-
.../queryengine/plan/planner/LogicalPlanner.java | 7 +-
.../plan/relational/analyzer/Analyzer.java | 9 +
...ogicalPlanner.java => TableLogicalPlanner.java} | 19 +-
...nalModelPlanner.java => TableModelPlanner.java} | 6 +-
.../distribute/TableDistributedPlanner.java | 12 +-
.../optimizations/PushPredicateIntoTableScan.java | 14 +
.../plan/statement/crud/InsertRowStatement.java | 6 -
.../plan/statement/crud/InsertTabletStatement.java | 6 -
.../dag/column/unary/InColumnTransformer.java | 86 +---
.../unary/scalar/RoundColumnTransformer.java | 6 +
.../scalar/RoundFunctionColumnTransformer.java | 6 +
.../dag/input/ConstantInputReader.java | 4 +
.../unary/ArithmeticNegationTransformer.java | 6 +
.../dag/transformer/unary/InTransformer.java | 2 +
.../unary/scalar/CastFunctionTransformer.java | 34 ++
.../unary/scalar/DiffFunctionTransformer.java | 6 +
.../unary/scalar/RoundFunctionTransformer.java | 6 +
.../transformation/dag/util/TransformUtils.java | 8 +
.../transformation/dag/util/TypeUtils.java | 3 +
.../iotdb/db/storageengine/StorageEngine.java | 4 +
.../db/storageengine/dataregion/DataRegion.java | 73 ++--
.../dataregion/tsfile/TsFileManager.java | 9 +-
.../dataregion/tsfile/TsFileResource.java | 12 +-
.../timeindex/FileTimeIndexCacheRecorder.java | 118 +++--
.../FileTimeIndexCacheReader.java | 10 +-
.../FileTimeIndexCacheWriter.java | 4 +
.../storageengine/dataregion/wal/io/WALReader.java | 12 +-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 4 +
.../plan/relational/analyzer/AnalyzerTest.java | 82 ++--
.../plan/relational/analyzer/JoinTest.java | 6 +-
.../analyzer/LimitOffsetPushDownTest.java | 16 +-
.../plan/relational/analyzer/SortTest.java | 32 +-
.../plan/relational/analyzer/SubQueryTest.java | 14 +-
.../plan/relational/planner/PlanTester.java | 8 +-
.../dataregion/wal/io/WALFileTest.java | 40 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 9 +
.../iotdb/commons/conf/CommonDescriptor.java | 5 +
.../iotdb/commons/pipe/config/PipeConfig.java | 5 +
.../iotdb/commons/pipe/event/EnrichedEvent.java | 10 +-
.../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 20 +
.../iotdb/commons/udf/builtin/UDTFBottomK.java | 2 +
.../commons/udf/builtin/UDTFChangePoints.java | 6 +
.../commons/udf/builtin/UDTFCommonDerivative.java | 6 +
.../udf/builtin/UDTFCommonValueDifference.java | 6 +
.../udf/builtin/UDTFContinuouslySatisfy.java | 10 +
.../udf/builtin/UDTFEqualSizeBucketAggSample.java | 6 +
.../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 6 +
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 6 +
.../builtin/UDTFEqualSizeBucketRandomSample.java | 6 +
.../iotdb/commons/udf/builtin/UDTFInRange.java | 18 +
.../apache/iotdb/commons/udf/builtin/UDTFJexl.java | 15 +
.../apache/iotdb/commons/udf/builtin/UDTFM4.java | 6 +
.../apache/iotdb/commons/udf/builtin/UDTFMath.java | 18 +
.../udf/builtin/UDTFNonNegativeDerivative.java | 6 +
.../builtin/UDTFNonNegativeValueDifference.java | 6 +
.../iotdb/commons/udf/builtin/UDTFOnOff.java | 18 +
.../iotdb/commons/udf/builtin/UDTFSelectK.java | 4 +
.../apache/iotdb/commons/udf/builtin/UDTFTopK.java | 2 +
.../iotdb/commons/udf/builtin/UDTFValueTrend.java | 6 +
.../iotdb/commons/udf/utils/MasterRepairUtil.java | 6 +
.../apache/iotdb/commons/utils/SerializeUtils.java | 24 +
.../apache/iotdb/library/anomaly/UDTFKSigma.java | 12 +
.../apache/iotdb/library/anomaly/UDTFRange.java | 6 +
.../iotdb/library/anomaly/UDTFTwoSidedFilter.java | 6 +
.../iotdb/library/dprofile/UDAFPercentile.java | 24 +
.../iotdb/library/dprofile/UDAFQuantile.java | 18 +
.../apache/iotdb/library/dprofile/UDAFSpread.java | 12 +
.../iotdb/library/dprofile/UDTFDistinct.java | 16 +
.../apache/iotdb/library/dprofile/UDTFSample.java | 6 +
.../dprofile/util/ExactOrderStatistics.java | 30 ++
.../iotdb/library/drepair/UDTFTimestampRepair.java | 6 +
.../iotdb/library/drepair/UDTFValueFill.java | 6 +
.../iotdb/library/drepair/UDTFValueRepair.java | 7 +
.../library/frequency/UDFEnvelopeAnalysis.java | 6 +
.../java/org/apache/iotdb/library/util/Util.java | 15 +
pom.xml | 2 +-
122 files changed, 1920 insertions(+), 435 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/pipe/it/manual/IoTDBPipeReqAutoSliceIT.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/{LogicalPlanner.java
=> TableLogicalPlanner.java} (94%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/{RelationalModelPlanner.java
=> TableModelPlanner.java} (97%)
