You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2022/11/10 08:19:44 UTC
[iotdb] branch rename_sg_to_db updated (753bb90069 -> 4a2981bb4a)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch rename_sg_to_db
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 753bb90069 use ColumnHeaderConstant in test
add 9ac112433e [IOTDB-4576]Add NULL Operand and modify operations about it & Use False if the series in the predicate does not exist (#7924)
add 072835c94a [IOTDB-4819] Record concrete failure info in FI State and pass it to client
add 2c5f012540 [IOTDB-4745] Add ADD_NEW_NODE state for ConfigNodeProcedure (#7743)
add c04d3fa9cc [IOTDB-4835] Fix InnerSpaceCompaction may be blocked (#7901)
add 887e49fb2b optimize transfer leader implementation (#7923)
add b22ed4b4ad [IOTDB-4811]Fix snapshot file name error (#7900)
add 05633d6e8c [IOTDB-4894] Fix bug that TsFileSketchTool prints only the first page info when there are multiple pages in a chunk (#7955)
add a5d6e97259 [IOTDB-4726]show cluster return with msg: 500 null (#7952)
add 9f9975eac5 [IOTDB-4876] Fix PathPatternTree missing information on subpaths (#7943)
add 7bc44b5db6 [IOTDB-4753] Error serialized data size in TsFileData (#7953)
add fa4613221a Bump swagger-jersey2-jaxrs from 1.5.18 to 1.5.24 (#7893)
add 43cc564aa5 [IOTDB-4558] Use insertRowsOfOneDevice to execute insert multi rows sql statement (#7918)
add 1bd98662c2 [IOTDB-4887] Tidy the UDF and Trigger folders (#7945)
add c1dafdd072 [IOTDB-4851] Perfect ChangeLeader method in RegionMigrateProcedure (#7948)
add 832e862d2e Merge remote-tracking branch 'origin/master' into rename_sg_to_db
add 487b3edc16 [IOTDB-4784] Control total memory for enabling time partition for storage engine (#7792)
add 4a2981bb4a resolve conflict
No new revisions were added by this update.
Summary of changes:
.../confignode/client/ConfigNodeRequestType.java | 2 +-
.../client/sync/SyncConfigNodeClientPool.java | 5 +-
.../client/sync/SyncDataNodeClientPool.java | 98 ++++++---
.../iotdb/confignode/conf/ConfigNodeConfig.java | 64 +++---
.../confignode/conf/ConfigNodeDescriptor.java | 8 +-
.../iotdb/confignode/manager/ConsensusManager.java | 47 ++--
.../manager/load/balancer/RouteBalancer.java | 5 +
.../iotdb/confignode/persistence/TriggerInfo.java | 2 +-
.../iotdb/confignode/persistence/UDFInfo.java | 2 +-
.../confignode/persistence/node/NodeInfo.java | 4 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 62 +++---
.../procedure/env/DataNodeRemoveHandler.java | 83 ++++---
.../impl/node/AddConfigNodeProcedure.java | 40 ++--
.../impl/node/RemoveDataNodeProcedure.java | 2 +
.../impl/statemachine/RegionMigrateProcedure.java | 19 +-
.../procedure/state/AddConfigNodeState.java | 3 +-
.../iotdb/confignode/service/ConfigNode.java | 4 -
.../thrift/ConfigNodeRPCServiceProcessor.java | 8 +
.../confignode1conf/iotdb-common.properties | 2 +-
.../confignode2conf/iotdb-common.properties | 2 +-
.../confignode3conf/iotdb-common.properties | 2 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 12 +
.../ratis/ApplicationStateMachineProxy.java | 3 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 23 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 18 ++
docs/UserGuide/Cluster/Cluster-Setup.md | 2 +-
docs/UserGuide/Process-Data/Triggers.md | 9 -
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 2 +-
docs/zh/UserGuide/Process-Data/Triggers.md | 8 -
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 1 +
.../iotdb/db/it/query/IoTDBNullOperandIT.java | 242 +++++++++++++++++++++
.../withoutNull/IoTDBWithoutNullAllFilterIT.java | 39 ++--
.../withoutNull/IoTDBWithoutNullAnyFilterIT.java | 55 ++---
.../resources/conf/iotdb-common.properties | 63 +-----
.../apache/iotdb/commons/conf/IoTDBConstant.java | 3 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 58 ++++-
.../apache/iotdb/commons/path/PathPatternTree.java | 16 +-
.../iotdb/commons/path/PathPatternTreeTest.java | 19 ++
pom.xml | 2 +-
.../apache/iotdb/db/client/ConfigNodeClient.java | 5 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 43 ++--
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 34 ++-
.../statemachine/DataRegionStateMachine.java | 16 ++
.../engine/compaction/CompactionTaskManager.java | 1 +
.../sizetiered/SizeTieredCompactionSelector.java | 78 ++++---
.../iotdb/db/engine/load/AlignedChunkData.java | 21 +-
.../iotdb/db/engine/load/NonAlignedChunkData.java | 15 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 9 +
.../engine/memtable/AlignedWritableMemChunk.java | 10 +
.../memtable/AlignedWritableMemChunkGroup.java | 5 +
.../apache/iotdb/db/engine/memtable/IMemTable.java | 2 +
.../db/engine/memtable/IWritableMemChunk.java | 6 +-
.../db/engine/memtable/IWritableMemChunkGroup.java | 2 +
.../iotdb/db/engine/memtable/WritableMemChunk.java | 9 +-
.../db/engine/memtable/WritableMemChunkGroup.java | 25 ++-
.../iotdb/db/engine/snapshot/SnapshotTaker.java | 18 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 240 +++++++++++---------
.../db/engine/storagegroup/DataRegionInfo.java | 2 +-
...hTimeManager.java => HashLastFlushTimeMap.java} | 235 +++++++++-----------
...meManager.java => IDTableLastFlushTimeMap.java} | 179 +++++++--------
...lushTimeManager.java => ILastFlushTimeMap.java} | 34 +--
.../db/engine/storagegroup/TimePartitionInfo.java | 66 ++++++
.../engine/storagegroup/TimePartitionManager.java | 165 ++++++++++++++
.../db/engine/storagegroup/TsFileManager.java | 6 +
.../db/engine/storagegroup/TsFileProcessor.java | 9 +-
.../db/engine/storagegroup/TsFileResource.java | 6 +
.../db/metadata/idtable/entry/DeviceEntry.java | 37 +---
.../fragment/FragmentInstanceContext.java | 11 +-
.../fragment/FragmentInstanceExecution.java | 5 +-
.../fragment/FragmentInstanceFailureInfo.java | 212 ++++++++++++++++++
.../execution/fragment/FragmentInstanceInfo.java | 21 +-
.../fragment/FragmentInstanceManager.java | 5 +-
.../operator/process/FilterAndProjectOperator.java | 10 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 5 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 11 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 31 ++-
.../mpp/plan/analyze/ExpressionTypeAnalyzer.java | 12 +-
.../config/executor/ClusterConfigTaskExecutor.java | 10 +-
.../iotdb/db/mpp/plan/expression/Expression.java | 5 +
.../db/mpp/plan/expression/ExpressionType.java | 2 +
.../{TimestampOperand.java => NullOperand.java} | 43 ++--
.../plan/expression/unary/NegationExpression.java | 2 +
.../visitor/ColumnTransformerVisitor.java | 17 ++
.../plan/expression/visitor/ExpressionVisitor.java | 5 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 3 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 12 +-
.../scheduler/AbstractFragInsStateTracker.java | 33 ++-
.../scheduler/FixedRateFragInsStateTracker.java | 27 ++-
.../dag/column/ColumnTransformer.java | 31 +++
.../binary/CompareBinaryColumnTransformer.java | 7 +-
.../binary/CompareEqualToColumnTransformer.java | 2 +-
.../column/binary/LogicAndColumnTransformer.java | 30 +++
.../binary/LogicBinaryColumnTransformer.java | 24 --
.../column/binary/LogicOrColumnTransformer.java | 30 +++
...Transformer.java => NullColumnTransformer.java} | 14 +-
.../ternary/CompareTernaryColumnTransformer.java | 17 +-
.../dag/column/unary/InColumnTransformer.java | 8 +-
.../column/unary/LogicNotColumnTransformer.java | 2 +-
.../dag/column/unary/RegularColumnTransformer.java | 2 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 31 +--
.../impl/DataNodeInternalRPCServiceImpl.java | 25 ++-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 193 ++++++++++------
.../db/utils/datastructure/AlignedTVList.java | 4 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 17 +-
.../db/utils/datastructure/BooleanTVList.java | 13 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 13 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 13 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 13 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 13 +-
.../iotdb/db/utils/datastructure/TVList.java | 20 +-
.../engine/compaction/CompactionSchedulerTest.java | 103 ++++++++-
.../db/engine/storagegroup/DataRegionTest.java | 2 +-
.../storagegroup/IDTableLastFlushTimeMapTest.java | 129 +++++++++++
.../engine/storagegroup/LastFlushTimeMapTest.java | 223 +++++++++++++++++++
.../iotdb/db/engine/storagegroup/TTLTest.java | 5 +-
.../storagegroup/TimePartitionManagerTest.java | 129 +++++++++++
.../engine/storagegroup/TsFileProcessorV2Test.java | 12 +-
.../db/metadata/idtable/IDTableFlushTimeTest.java | 199 -----------------
.../FragmentInstanceFailureInfoSerdeTest.java | 85 ++++++++
.../datanode1conf/iotdb-common.properties | 2 +-
.../datanode2conf/iotdb-common.properties | 2 +-
.../datanode3conf/iotdb-common.properties | 2 +-
.../src/test/resources/iotdb-datanode.properties | 2 -
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../src/main/thrift/confignode.thrift | 3 +
thrift/src/main/thrift/datanode.thrift | 10 +-
.../iotdb/tsfile/file/header/PageHeader.java | 10 +-
.../read/common/block/column/NullColumn.java | 87 +++++++-
128 files changed, 3044 insertions(+), 1283 deletions(-)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBNullOperandIT.java
rename server/src/main/java/org/apache/iotdb/db/engine/storagegroup/{LastFlushTimeManager.java => HashLastFlushTimeMap.java} (52%)
rename server/src/main/java/org/apache/iotdb/db/engine/storagegroup/{IDTableFlushTimeManager.java => IDTableLastFlushTimeMap.java} (51%)
rename server/src/main/java/org/apache/iotdb/db/engine/storagegroup/{ILastFlushTimeManager.java => ILastFlushTimeMap.java} (67%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TimePartitionInfo.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TimePartitionManager.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceFailureInfo.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/expression/leaf/{TimestampOperand.java => NullOperand.java} (78%)
copy server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/leaf/{TimeColumnTransformer.java => NullColumnTransformer.java} (77%)
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/IDTableLastFlushTimeMapTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/LastFlushTimeMapTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TimePartitionManagerTest.java
delete mode 100644 server/src/test/java/org/apache/iotdb/db/metadata/idtable/IDTableFlushTimeTest.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/execution/fragment/FragmentInstanceFailureInfoSerdeTest.java