This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch force_ci/object_type
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 391429b6192 [To force_ci/object_type] Support insert object by sql &
add IT (#16683)
new 0fc8e176e72 Fix wrong push limit down to AggTableScanNode (#16696)
new 4dbb3c620bc More robust IoTDBRegionReconstructForIoTV1IT (#16697)
new 1bb15b2254a Implemented the alter encoding compression function for
tree model (#16672)
new 0971b8fa67f Support SSL-related parameters and interactive password
input in export/import tools (#16698)
new 0e15626c691 implement the intersect (distinct | all ) for table model
(#16700)
new 96d4eae4e15 Fix the error message of ConfigExecution (#16680)
new 5d9baf5b755 Fixed the null error message of fetch schema failed when
the regions is removing (#16713)
new d0de0a67a72 Pipe: Fixed the NPE of commit interval (#16714)
new ba7a7a6fc1b Follow fix for encoding & compressor (#16712)
new 0657671d20f Avoid unnecessary ssl error log caused by jdk bug (#16709)
The 10 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 1 +
.../it/schema/IoTDBAlterEncodingCompressorIT.java | 187 +++++++++++
.../treemodel/manual/IoTDBPipeInclusionIT.java | 9 +-
...nionTableIT.java => IoTDBIntersectTableIT.java} | 78 +++--
.../it/query/recent/IoTDBTableAggregationIT.java | 13 +
.../org/apache/iotdb/tool/common/Constants.java | 12 +
.../org/apache/iotdb/tool/common/OptionsUtil.java | 30 ++
.../apache/iotdb/tool/data/AbstractDataTool.java | 41 ++-
.../apache/iotdb/tool/data/ExportDataTable.java | 10 +-
.../org/apache/iotdb/tool/data/ExportDataTree.java | 29 +-
.../apache/iotdb/tool/data/ImportDataTable.java | 10 +-
.../org/apache/iotdb/tool/data/ImportDataTree.java | 10 +-
.../iotdb/tool/schema/AbstractSchemaTool.java | 43 ++-
.../iotdb/tool/schema/ExportSchemaTable.java | 10 +-
.../apache/iotdb/tool/schema/ExportSchemaTree.java | 12 +-
.../iotdb/tool/schema/ImportSchemaTable.java | 10 +-
.../apache/iotdb/tool/schema/ImportSchemaTree.java | 10 +-
.../iotdb/rpc/NettyTNonblockingTransport.java | 9 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 20 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 6 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../client/async/CnToDnAsyncRequestType.java | 2 +
.../CnToDnInternalServiceAsyncRequestManager.java | 6 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 1 +
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../request/ConfigPhysicalPlanVisitor.java | 8 +
.../payload/PipeAlterEncodingCompressorPlan.java | 130 ++++++++
.../iotdb/confignode/manager/ConfigManager.java | 18 ++
.../apache/iotdb/confignode/manager/IManager.java | 3 +
.../iotdb/confignode/manager/ProcedureManager.java | 41 +++
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 56 +++-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 11 +
.../client/IoTDBConfigNodeSyncClientManager.java | 6 +-
.../sink/protocol/IoTDBConfigRegionAirGapSink.java | 2 +
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 6 +-
.../pipe/source/ConfigRegionListeningFilter.java | 3 +
...eConfigPhysicalPlanTreePatternParseVisitor.java | 25 ++
.../persistence/executor/ConfigPlanExecutor.java | 1 +
.../schema/AlterEncodingCompressorProcedure.java | 334 +++++++++++++++++++
.../impl/schema/DataNodeTSStatusTaskExecutor.java | 74 +++++
.../impl/schema/DeactivateTemplateProcedure.java | 26 +-
.../impl/schema/DeleteLogicalViewProcedure.java | 26 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 46 +--
.../table/AbstractAlterOrDropTableProcedure.java | 29 +-
...tate.java => AlterEncodingCompressorState.java} | 7 +-
.../procedure/store/ProcedureFactory.java | 9 +
.../confignode/procedure/store/ProcedureType.java | 2 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
.../pipe/receiver/PipeEnrichedProcedureTest.java | 28 ++
...a => AlterEncodingCompressorProcedureTest.java} | 26 +-
.../schemaregion/SchemaExecutionVisitor.java | 15 +
.../client/IoTDBDataNodeAsyncClientManager.java | 9 +-
.../client/IoTDBDataNodeSyncClientManager.java | 6 +-
.../protocol/airgap/IoTDBDataNodeAirGapSink.java | 2 +
.../thrift/async/IoTDBDataRegionAsyncSink.java | 6 +-
.../thrift/sync/IoTDBDataNodeSyncSink.java | 6 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 +
.../impl/DataNodeInternalRPCServiceImpl.java | 36 ++-
.../execution/executor/RegionReadExecutor.java | 10 +-
.../plan/execution/config/ConfigExecution.java | 16 +-
.../execution/config/TreeConfigTaskVisitor.java | 14 +-
.../config/executor/ClusterConfigTaskExecutor.java | 57 ++++
.../config/executor/IConfigTaskExecutor.java | 4 +
...eTask.java => AlterEncodingCompressorTask.java} | 17 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 68 +++-
.../plan/planner/plan/node/PlanGraphPrinter.java | 10 +
.../plan/planner/plan/node/PlanNodeType.java | 8 +
.../plan/planner/plan/node/PlanVisitor.java | 10 +
.../write/AlterEncodingCompressorNode.java | 146 +++++++++
.../plan/relational/planner/RelationPlanner.java | 24 +-
.../distribute/TableDistributedPlanGenerator.java | 2 +-
.../iterative/rule/ImplementIntersectAll.java | 95 ++++++
.../rule/ImplementIntersectDistinctAsUnion.java | 88 +++++
.../iterative/rule/PruneDistinctAggregation.java | 9 +
.../rule/PushDownOffsetIntoTableScan.java | 4 +-
.../iterative/rule/SetOperationNodeTranslator.java | 355 +++++++++++++++++++++
.../planner/node/AggregationTableScanNode.java | 10 +
...nforceSingleRowNode.java => IntersectNode.java} | 58 ++--
.../plan/relational/planner/node/Patterns.java | 22 +-
.../optimizations/LogicalOptimizeFactory.java | 13 +
.../PushLimitOffsetIntoTableScan.java | 2 +-
.../optimizations/UnaliasSymbolReferences.java | 31 ++
.../security/TreeAccessCheckVisitor.java | 59 +++-
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 10 +-
.../metadata/AlterEncodingCompressorStatement.java | 126 ++++++++
.../metadata/DeleteDatabaseStatement.java | 2 +-
.../statement/metadata/ShowDatabaseStatement.java | 2 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 3 +
.../schemaregion/SchemaRegionPlanType.java | 2 +
.../schemaregion/SchemaRegionPlanVisitor.java | 6 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 37 ++-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 8 +
.../visitor/SchemaRegionPlanDeserializer.java | 7 +
.../visitor/SchemaRegionPlanSerializer.java | 8 +
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 33 ++
.../write/req/SchemaRegionWritePlanFactory.java | 3 +
.../plan/relational/analyzer/IntersectTest.java | 121 +++++++
.../iotdb/commons/exception/MetadataException.java | 2 +-
.../apache/iotdb/commons/path/PathPatternNode.java | 7 +
.../apache/iotdb/commons/path/PathPatternTree.java | 13 +-
.../task/progress/interval/PipeCommitInterval.java | 4 +-
.../commons/pipe/receiver/IoTDBFileReceiver.java | 6 +
.../pipe/sink/client/IoTDBClientManager.java | 5 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 9 +-
.../common/PipeTransferHandshakeConstant.java | 1 +
.../commons/pipe/sink/protocol/IoTDBSink.java | 3 +-
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 6 +-
.../apache/iotdb/commons/utils/SerializeUtils.java | 18 ++
.../pipe/datastructure/PipeCommitQueueTest.java | 2 +
.../db/relational/grammar/sql/RelationalSql.g4 | 5 +-
.../src/main/thrift/confignode.thrift | 12 +
.../src/main/thrift/datanode.thrift | 13 +
114 files changed, 2866 insertions(+), 319 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBAlterEncodingCompressorIT.java
copy
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/{IoTDBUnionTableIT.java
=> IoTDBIntersectTableIT.java} (62%)
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeAlterEncodingCompressorPlan.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterEncodingCompressorProcedure.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/DataNodeTSStatusTaskExecutor.java
copy
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/{RemoveAINodeState.java
=> AlterEncodingCompressorState.java} (91%)
copy
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/schema/{table/view/DropViewProcedureTest.java
=> AlterEncodingCompressorProcedureTest.java} (60%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/metadata/{ShowDatabaseTask.java
=> AlterEncodingCompressorTask.java} (68%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/planner/plan/node/metadata/write/AlterEncodingCompressorNode.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/ImplementIntersectAll.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/ImplementIntersectDistinctAsUnion.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/SetOperationNodeTranslator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/node/{EnforceSingleRowNode.java
=> IntersectNode.java} (57%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterEncodingCompressorStatement.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/IntersectTest.java
