This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch fix-pipe-ref-count-leak
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 370a57f6f88 fix ref count leak
add 192d96c4d01 Add MergeFilters, MergeLimits optimize rule (#13332)
add 1fed2c65a15 Speed up recover (#13068)
add 7eed3aac9b5 Fix substring logic proble And add function pi and e
add 6f08ed8c1b0 Merge branch 'master' of https://github.com/apache/iotdb
into fix-pipe-ref-count-leak
No new revisions were added by this update.
Summary of changes:
.../iotdb/db/it/IoTDBPartialInsertionIT.java | 2 +-
.../scalar/IoTDBScalarFunctionTableIT.java | 88 ++++++-
.../scalar/IoTDBSubStringFunctionTableIT.java | 51 ++--
.../iotdb/relational/it/schema/IoTDBDeviceIT.java | 2 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 3 +
.../impl/DataNodeInternalRPCServiceImpl.java | 2 +-
.../relational/ColumnTransformerBuilder.java | 39 +--
.../config/executor/ClusterConfigTaskExecutor.java | 2 +-
.../builtin/helper/SubStringFunctionHelper.java | 2 +-
.../relational/metadata/TableMetadataImpl.java | 20 +-
...teLimitWithTableScan.java => MergeFilters.java} | 35 ++-
.../{MergeLimitWithSort.java => MergeLimits.java} | 48 ++--
.../optimizations/LogicalOptimizeFactory.java | 13 +-
.../dag/column/leaf/LeafColumnTransformer.java | 1 +
.../unary/scalar/SubString2ColumnTransformer.java | 11 +-
.../unary/scalar/SubString3ColumnTransformer.java | 28 ++-
...former.java => SubStringColumnTransformer.java} | 32 ++-
.../unary/scalar/TableBuiltinScalarFunction.java | 2 +
.../scalar/SubStringFunctionColumnTransformer.java | 3 +-
.../unary/scalar/SubStringFunctionTransformer.java | 2 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 40 +++-
.../iotdb/db/storageengine/StorageEngine.java | 100 ++++++--
.../db/storageengine/dataregion/DataRegion.java | 264 +++++++++++++++------
.../dataregion/DeviceLastFlushTime.java | 4 +
.../dataregion/HashLastFlushTimeMap.java | 92 +++++--
.../dataregion/ILastFlushTimeMap.java | 11 +-
.../schedule/CompactionScheduleTaskWorker.java | 2 +-
.../compaction/schedule/TTLScheduleTask.java | 2 +-
.../dataregion/memtable/TsFileProcessor.java | 2 +
.../storageengine/dataregion/tsfile/TsFileID.java | 23 ++
.../dataregion/tsfile/TsFileManager.java | 27 ++-
.../dataregion/tsfile/TsFileResource.java | 15 ++
.../timeindex/FileTimeIndexCacheRecorder.java | 227 ++++++++++++++++++
.../tsfile/timeindex/PlainDeviceTimeIndex.java | 23 +-
.../FileTimeIndexCacheReader.java | 84 +++++++
.../FileTimeIndexCacheWriter.java} | 59 ++---
.../file/UnsealedTsFileRecoverPerformer.java | 2 +
.../plan/relational/analyzer/SortTest.java | 26 +-
.../plan/relational/analyzer/SubQueryTest.java | 39 ++-
.../plan/relational/analyzer/TestUtils.java | 160 +++++++++++++
.../dataregion/LastFlushTimeMapTest.java | 6 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 2 +
.../iotdb/commons/concurrent/ThreadName.java | 2 +
43 files changed, 1275 insertions(+), 323 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{EliminateLimitWithTableScan.java
=> MergeFilters.java} (62%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{MergeLimitWithSort.java
=> MergeLimits.java} (63%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/column/unary/scalar/{SubStringFunctionColumnTransformer.java
=> SubStringColumnTransformer.java} (64%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/transformation/dag/{column
=> transformer}/unary/scalar/SubStringFunctionColumnTransformer.java (96%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/tsfile/timeindex/FileTimeIndexCacheRecorder.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/utils/fileTimeIndexCache/FileTimeIndexCacheReader.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{utils/writelog/LogWriter.java
=>
storageengine/dataregion/utils/fileTimeIndexCache/FileTimeIndexCacheWriter.java}
(64%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/TestUtils.java
