This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch table_disk_usage_statistics
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 098392ddd24 add it
add aa899ccf8f5 Pipe: Added log control for pipe receiver auth exception
(#16659)
add 74fe8e69c06 Fix some dependencies version fallback (#16664)
add 57fe5734dd3 Optimize the efficiency of DualKeyCacheImpl's mayEvict
(#16445)
add 37388a1d494 implement MergeUnion rule to flatten nested UnionNode
(#16657)
add 0cbe3e16abd Pipe: Add metrics for TsFile parsing to tablets (#16668)
add 51b112340bd Clarify the non-ssl client connects the ssl server error
log information (#16665)
add 2738e7afe91 Pipe: Fix HistoricalDataRegionTsFileAndDeletionSource
`double-living` parameter failure (#16667)
add 6f07e859d89 Fixed the bug that the user deletion may delete audit
TimeSeries (#16670)
add fe37a4b5779 Hide password related parameters in show configuration
result (#16675)
add f8ad340df55 Avoid throwing AuthException to the state machine (#16677)
add acaf594ab46 If the client input uses "-usessl", then force interactive
input of trustStore and trustStorePwd. (#16676)
add 993a7839133 Fix process logic of empty TsBlock in InputLayer of
TransformOperator (#16678)
add 26ca344925e Bump logback version to 1.3.16 (#16671)
add 274fc9ed443 Use the correct value in showConfiguration to override the
value read from the configuration file (#16681)
add 685141a6405 Fixed the bug that the attribute update container may add
extra calculated memory to schema engine (#16682)
add 69cda2da662 Add more optimizers for union (#16689)
add 2488001e808 SeriesScanUtil throws exception when using filters that
could not match any time range (#16691)
add 8420beaaf54 Fix wrong push limit down to AggTableScanNode (#16696)
add b6c6c7a1138 More robust IoTDBRegionReconstructForIoTV1IT (#16697)
add f096b8210ff Implemented the alter encoding compression function for
tree model (#16672)
add ababbf337e2 Support SSL-related parameters and interactive password
input in export/import tools (#16698)
add 4ebb89b91e8 implement the intersect (distinct | all ) for table model
(#16700)
add c406a81f53c Fix the error message of ConfigExecution (#16680)
add 9ae8233091f Fixed the null error message of fetch schema failed when
the regions is removing (#16713)
add a9ba7243ba9 Pipe: Fixed the NPE of commit interval (#16714)
add 3ec8979e42a Follow fix for encoding & compressor (#16712)
add 9d4c41092a8 Avoid unnecessary ssl error log caused by jdk bug (#16709)
add 2de3bb6f534 Active Load: Ignore java.io.UncheckedIOException
exceptions thrown during the file scanning process. (#16705)
add f67526420d0 Delete the tsfile and related attachments When only one
table and dat… (#16687)
add 639de5255ce Fixed the potential non-consistency caused by initialize
of DataNodeTableCache & Cleared the storageGroups in compatible codes (#16693)
add ffa9c562c4e Optimize the configuration logic of
dn_thrift_max_frame_size (#16724)
add b4d5b4235e1 Changed the SQL of AlterEncodingCompressor statement &
banned the "root" timeSeries & handled the empty intersection path & refactored
the IT (#16725)
add 8dbf2003cfd chore!: Bind real config address for Thrift and Raft
services (#16717)
add 93b2d1fe999 Make ErrMsg more readable when the predicate has too many
conjunctions because of too many devices #16715
add 93c55577e6f Pipe: Fix unhandled timeout exceptions in Thrift Client
(#16727)
add 468a91a4d2e Fixed the procedure has_more_state bug & Fixed the IT for
encoding & compressor (#16729)
add a6e8493bfc0 Optimized the lock for encoding & compressor's invalidate
cache (#16733)
add d48347cdc8d Pipe: support path exclusion under tree model (#16632)
add 43b89b9a480 Change the privilege of showVersionStatement #16736
add 49c625bb83e [AINode] Package AINode via PyInstaller (#16707)
add 96e8681dd51 Support the JDBC client to prevent SQL injection (#16734)
add b7f9f8d49af Fix that a deletion test may fail due to inconsistency
caused by leader redistribution (#16744)
add 7515568c8e4 Fixed the NPE caused by concurrent "check for
createTimeSeries" and deleteTimeSeries (#16742)
add 6e8748e0256 Pipe: Optimized the default behavior in meta sync for
retries to wait for other regions (#16740)
add f608a2d2e6a Adjust the exception message cause by the WHERE clause,
which uses a range comparison on the same field, specifically when the left
value of the range is greater than the right value of the range. (#16741)
add e53d27c0ad0 Pipe: Trimmed some of the pipe logs (#16747)
add db7c801d846 Active Load: Fixes errors caused by Load copying resource
files. (#16753)
add a6191d916b2 Pipe: Modify the Pipe configuration item log name to be
consistent with the Properties name. (#16732)
add 91e48f07f63 feat: encode load attributes in active load directories
(#16722)
add 1ebb9515767 [AINode] Enable AINode start as background (-d) (#16762)
add 3a6322028cd fix (#16702)
add a7f1527d04c reduce error log when compaction service is stopped & fix
bugs (#16756)
new ccfb4ece63b Merge branch 'iotdb_master' into
table_disk_usage_statistics
new 3fbf6a3c200 fix
The 2 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:
.github/workflows/cluster-it-1c1d1a.yml | 2 +-
integration-test/pom.xml | 1 +
integration-test/src/assembly/mpp-test.xml | 2 +-
.../it/env/cluster/config/MppCommonConfig.java | 4 +-
.../env/cluster/config/MppSharedCommonConfig.java | 6 +-
.../iotdb/it/env/cluster/node/AINodeWrapper.java | 25 +-
.../apache/iotdb/itbase/constant/TestConstant.java | 14 +-
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +-
.../ainode/it/AINodeConcurrentInferenceIT.java | 62 +--
.../confignode/it/IoTDBConfigNodeSnapshotIT.java | 31 +-
.../it/database/IoTDBDatabaseSetAndDeleteIT.java | 66 +--
.../it/load/IoTDBConfigNodeSwitchLeaderIT.java | 2 +-
.../partition/IoTDBAutoRegionGroupExtensionIT.java | 8 +-
.../IoTDBCustomRegionGroupExtensionIT.java | 2 +-
.../it/partition/IoTDBPartitionCreationIT.java | 4 +-
.../it/partition/IoTDBPartitionDurableIT.java | 4 +-
.../it/partition/IoTDBPartitionGetterIT.java | 41 +-
.../commit/IoTDBRegionReconstructForIoTV1IT.java | 1 +
.../confignode/it/utils/ConfigNodeTestUtils.java | 16 +-
.../org/apache/iotdb/db/it/IoTDBDeletionIT.java | 21 +
.../org/apache/iotdb/db/it/IoTDBExampleIT.java | 4 +-
.../java/org/apache/iotdb/db/it/IoTDBFilterIT.java | 14 +
.../org/apache/iotdb/db/it/IoTDBFlushQueryIT.java | 5 +-
.../iotdb/db/it/IoTDBLoadTsFileWithModIT.java | 60 +-
.../org/apache/iotdb/db/it/IoTDBRestServiceIT.java | 8 +-
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 2 +-
.../db/it/IoTDBSyntaxConventionIdentifierIT.java | 2 +-
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 3 +-
.../it/auth/IoTDBSystemPermissionRelationalIT.java | 3 +-
.../apache/iotdb/db/it/path/IoTDBQuotedPathIT.java | 4 +-
.../it/schema/IoTDBAlterEncodingCompressorIT.java | 209 +++++++
.../db/it/schema/IoTDBAutoCreateSchemaIT.java | 14 +-
.../db/it/schema/IoTDBDeactivateTemplateIT.java | 2 +-
.../db/it/schema/IoTDBDeleteTimeSeriesIT.java | 2 +-
.../iotdb/db/it/schema/IoTDBMetadataFetchIT.java | 2 +-
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 2 +-
.../auto/basic/IoTDBTreePatternFormatIT.java | 616 ++++++++++++---------
.../treemodel/manual/IoTDBPipeInclusionIT.java | 89 ++-
.../IoTDBPipeTsFileDecompositionWithModsIT.java | 14 +-
.../relational/it/db/it/IoTDBDeletionTableIT.java | 374 +++++++++++++
.../it/query/old/IoTDBSimpleQueryTableIT.java | 2 +-
...nionTableIT.java => IoTDBIntersectTableIT.java} | 78 +--
.../it/query/recent/IoTDBMaintainAuthIT.java | 8 +-
.../it/query/recent/IoTDBTableAggregationIT.java | 24 +
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 22 +-
.../session/it/IoTDBSessionSyntaxConventionIT.java | 6 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 19 +-
.../src/main/java/org/apache/iotdb/cli/Cli.java | 6 +-
.../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 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 17 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 154 +++++-
.../iotdb/rpc/NettyTNonblockingTransport.java | 9 +-
.../rpc/TCompressedElasticFramedTransport.java | 8 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 126 +++--
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
iotdb-core/ainode/.gitignore | 6 +-
iotdb-core/ainode/ainode.spec | 199 +++++++
iotdb-core/ainode/ainode.xml | 17 +-
iotdb-core/ainode/build_binary.py | 596 ++++++++++++++++++++
iotdb-core/ainode/iotdb/ainode/core/ai_node.py | 10 +-
iotdb-core/ainode/iotdb/ainode/core/config.py | 28 +-
iotdb-core/ainode/iotdb/ainode/core/constant.py | 18 +-
.../iotdb/ainode/core/inference/pool_controller.py | 49 +-
.../pool_scheduler/basic_pool_scheduler.py | 7 +-
iotdb-core/ainode/iotdb/ainode/core/log.py | 4 +-
.../iotdb/ainode/core/manager/inference_manager.py | 4 +-
iotdb-core/ainode/iotdb/ainode/core/rpc/handler.py | 2 +-
iotdb-core/ainode/iotdb/ainode/core/rpc/service.py | 1 +
iotdb-core/ainode/iotdb/ainode/core/script.py | 80 +--
iotdb-core/ainode/poetry.lock | 111 +++-
iotdb-core/ainode/pom.xml | 92 +--
iotdb-core/ainode/pyproject.toml | 29 +-
.../ainode/resources/syncPythonVersion.groovy | 33 --
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 6 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 8 +
.../client/async/CnToDnAsyncRequestType.java | 2 +
.../CnToDnInternalServiceAsyncRequestManager.java | 6 +
.../rpc/DataNodeAsyncRequestRPCHandler.java | 1 +
.../confignode/conf/SystemPropertiesUtils.java | 2 +
.../consensus/request/ConfigPhysicalPlan.java | 4 +
.../consensus/request/ConfigPhysicalPlanType.java | 1 +
.../request/ConfigPhysicalPlanVisitor.java | 8 +
.../write/database/PreDeleteDatabasePlan.java | 22 +-
.../payload/PipeAlterEncodingCompressorPlan.java | 130 +++++
.../iotdb/confignode/manager/ConfigManager.java | 46 +-
.../apache/iotdb/confignode/manager/IManager.java | 19 +-
.../iotdb/confignode/manager/ProcedureManager.java | 68 +++
.../iotdb/confignode/manager/load/LoadManager.java | 2 +-
.../manager/load/balancer/RegionBalancer.java | 2 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 69 ++-
.../PipeConfigPhysicalPlanTSStatusVisitor.java | 11 +
.../client/IoTDBConfigNodeSyncClientManager.java | 6 +-
.../sink/protocol/IoTDBConfigRegionAirGapSink.java | 2 +
.../pipe/sink/protocol/IoTDBConfigRegionSink.java | 6 +-
.../pipe/source/ConfigRegionListeningFilter.java | 3 +
.../pipe/source/IoTDBConfigRegionSource.java | 6 +-
...eConfigPhysicalPlanTreePatternParseVisitor.java | 69 ++-
.../manager/schema/ClusterSchemaManager.java | 26 +-
.../confignode/persistence/auth/AuthorInfo.java | 83 ++-
.../persistence/auth/AuthorPlanExecutor.java | 7 +-
.../persistence/executor/ConfigPlanExecutor.java | 1 +
.../persistence/partition/PartitionInfo.java | 2 +-
.../schema/AlterEncodingCompressorProcedure.java | 337 +++++++++++
.../impl/schema/DataNodeTSStatusTaskExecutor.java | 74 +++
.../impl/schema/DeactivateTemplateProcedure.java | 26 +-
.../impl/schema/DeleteDatabaseProcedure.java | 28 +-
.../impl/schema/DeleteLogicalViewProcedure.java | 26 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 53 +-
.../table/AbstractAlterOrDropTableProcedure.java | 29 +-
...tate.java => AlterEncodingCompressorState.java} | 7 +-
...ageGroupState.java => DeleteDatabaseState.java} | 2 +-
.../procedure/store/ProcedureFactory.java | 9 +
.../confignode/procedure/store/ProcedureType.java | 2 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
...figPhysicalPlanTreePatternParseVisitorTest.java | 7 +-
.../pipe/receiver/PipeEnrichedProcedureTest.java | 28 +
...a => AlterEncodingCompressorProcedureTest.java} | 26 +-
.../iotdb/consensus/ratis/RatisConsensus.java | 1 +
.../assembly/resources/conf/logback-datanode.xml | 15 -
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 25 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 17 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 4 +
.../schemaregion/SchemaExecutionVisitor.java | 15 +
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 4 +-
.../agent/task/connection/PipeEventCollector.java | 4 +-
.../tsfile/parser/TsFileInsertionEventParser.java | 68 ++-
.../parser/TsFileInsertionEventParserProvider.java | 6 +-
.../query/TsFileInsertionEventQueryParser.java | 14 +-
.../scan/TsFileInsertionEventScanParser.java | 12 +-
.../table/TsFileInsertionEventTableParser.java | 15 +-
.../overview/PipeTsFileToTabletsMetrics.java | 67 +++
.../protocol/thrift/IoTDBDataNodeReceiver.java | 27 +-
.../visitor/PipeStatementTSStatusVisitor.java | 42 +-
.../PipeStatementTreePatternParseVisitor.java | 22 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 9 +-
.../client/IoTDBDataNodeSyncClientManager.java | 6 +-
.../protocol/airgap/IoTDBDataNodeAirGapSink.java | 2 +
.../thrift/async/IoTDBDataRegionAsyncSink.java | 24 +-
.../thrift/sync/IoTDBDataNodeSyncSink.java | 6 +-
.../source/dataregion/IoTDBDataRegionSource.java | 6 +-
...istoricalDataRegionTsFileAndDeletionSource.java | 18 +-
.../realtime/assigner/DisruptorQueue.java | 4 +-
.../PipePlanTreePatternParseVisitor.java | 41 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 7 +
.../impl/DataNodeInternalRPCServiceImpl.java | 95 +++-
.../execution/executor/RegionReadExecutor.java | 10 +-
.../execution/operator/source/SeriesScanUtil.java | 5 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 2 +-
.../queryengine/plan/analyze/PredicateUtils.java | 16 +-
.../schema/dualkeycache/impl/DualKeyCacheImpl.java | 6 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 13 +-
.../plan/execution/config/ConfigExecution.java | 16 +-
.../execution/config/TableConfigTaskVisitor.java | 1 -
.../execution/config/TreeConfigTaskVisitor.java | 17 +-
.../config/executor/ClusterConfigTaskExecutor.java | 62 +++
.../config/executor/IConfigTaskExecutor.java | 4 +
...eTask.java => AlterEncodingCompressorTask.java} | 17 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 101 +++-
.../plan/planner/OperatorTreeGenerator.java | 4 +-
.../memory/PipelineMemoryEstimatorFactory.java | 1 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 10 +
.../plan/planner/plan/node/PlanNodeType.java | 14 +-
.../plan/planner/plan/node/PlanVisitor.java | 10 +
.../write/AlterEncodingCompressorNode.java | 146 +++++
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 6 +-
.../plan/relational/planner/RelationPlanner.java | 24 +-
.../distribute/TableDistributedPlanGenerator.java | 2 +-
.../iterative/rule/ImplementIntersectAll.java | 95 ++++
.../rule/ImplementIntersectDistinctAsUnion.java | 88 +++
...rencedScalarApplyNodes.java => MergeUnion.java} | 24 +-
.../iterative/rule/PruneDistinctAggregation.java | 9 +
.../rule/PushDownOffsetIntoTableScan.java | 25 +-
...thMergeSort.java => PushLimitThroughUnion.java} | 82 +--
.../iterative/rule/PushProjectionThroughUnion.java | 111 ++++
.../iterative/rule/PushTopKThroughUnion.java | 102 ++++
.../iterative/rule/RemoveEmptyUnionBranches.java | 113 ++++
.../planner/iterative/rule/SetOperationMerge.java | 144 +++++
.../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 | 52 +-
.../PushLimitOffsetIntoTableScan.java | 2 +-
.../optimizations/UnaliasSymbolReferences.java | 31 ++
.../security/TreeAccessCheckVisitor.java | 63 ++-
.../db/queryengine/plan/statement/Statement.java | 4 +
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 12 +-
.../crud/InsertMultiTabletsStatement.java | 8 +
.../plan/statement/crud/InsertRowStatement.java | 24 +
.../plan/statement/crud/InsertRowsStatement.java | 5 +
.../plan/statement/crud/InsertTabletStatement.java | 17 +
.../plan/statement/crud/LoadTsFileStatement.java | 16 +-
.../metadata/AlterEncodingCompressorStatement.java | 126 +++++
.../statement/metadata/CountDatabaseStatement.java | 2 +-
.../metadata/DeleteDatabaseStatement.java | 2 +-
.../statement/metadata/ShowDatabaseStatement.java | 2 +-
.../FragmentInstanceStatisticsDrawer.java | 2 +-
.../dag/input/QueryDataSetInputLayer.java | 10 +-
.../schemaengine/schemaregion/ISchemaRegion.java | 8 +-
.../schemaregion/SchemaRegionPlanType.java | 2 +
.../schemaregion/SchemaRegionPlanVisitor.java | 6 +
.../update/DeviceAttributeCacheUpdater.java | 8 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 43 +-
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 14 +-
.../visitor/SchemaRegionPlanDeserializer.java | 7 +
.../visitor/SchemaRegionPlanSerializer.java | 8 +
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 111 ++--
.../schemaengine/schemaregion/utils/MetaUtils.java | 6 +-
.../write/req/SchemaRegionWritePlanFactory.java | 3 +
.../db/schemaengine/table/DataNodeTableCache.java | 17 +
.../java/org/apache/iotdb/db/service/DataNode.java | 4 +
.../db/storageengine/dataregion/DataRegion.java | 121 +++-
.../execute/task/AbstractCompactionTask.java | 3 +-
.../execute/task/InnerSpaceCompactionTask.java | 14 +-
.../dataregion/read/QueryDataSource.java | 5 +
.../dataregion/utils/DiskUsageStatisticUtil.java | 7 +-
.../load/active/ActiveLoadDirScanner.java | 26 +-
.../load/active/ActiveLoadPathHelper.java | 282 ++++++++++
.../load/active/ActiveLoadPendingQueue.java | 17 +-
.../load/active/ActiveLoadTsFileLoader.java | 36 +-
.../storageengine/load/active/ActiveLoadUtil.java | 39 +-
.../load/config/LoadTsFileConfigurator.java | 18 +
.../db/pipe/pattern/TreePatternCoverageTest.java | 133 +++++
.../PipeStatementTreePatternParseVisitorTest.java | 202 ++++---
.../PipePlanTreePatternParseVisitorTest.java | 7 +-
.../execution/operator/TransformOperatorTest.java | 142 +++++
.../plan/relational/analyzer/IntersectTest.java | 121 ++++
.../relational/analyzer/UnionOptimizeTest.java | 158 ++++++
.../compaction/utils/CompactionTestFileWriter.java | 6 +-
.../conf/iotdb-system.properties.template | 4 +-
.../apache/iotdb/commons/client/ThriftClient.java | 3 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 127 +++--
.../iotdb/commons/conf/ConfigurationFileUtils.java | 75 ++-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 -
.../iotdb/commons/exception/MetadataException.java | 2 +-
.../pipe/PipeRuntimeSinkCriticalException.java | 2 +-
...RuntimeSinkRetryTimesConfigurableException.java | 6 +
.../commons/file/SystemPropertiesHandler.java | 2 +
.../apache/iotdb/commons/path/PathPatternNode.java | 7 +
.../apache/iotdb/commons/path/PathPatternTree.java | 13 +-
.../task/progress/interval/PipeCommitInterval.java | 4 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 51 +-
.../iotdb/commons/pipe/config/PipeDescriptor.java | 31 +-
.../pipe/config/constant/PipeSourceConstant.java | 5 +
.../datastructure/pattern/IoTDBTreePattern.java | 68 ++-
.../pattern/IoTDBTreePatternOperations.java | 52 ++
.../datastructure/pattern/PrefixTreePattern.java | 70 ++-
.../datastructure/pattern/SingleTreePattern.java | 59 --
.../pipe/datastructure/pattern/TreePattern.java | 369 ++++++++++--
.../pattern/UnionIoTDBTreePattern.java | 115 ++--
.../datastructure/pattern/UnionTreePattern.java | 17 +-
.../pattern/WithExclusionIoTDBTreePattern.java | 213 +++++++
.../pattern/WithExclusionTreePattern.java | 119 ++++
.../commons/pipe/receiver/IoTDBFileReceiver.java | 6 +
.../pipe/receiver/PipeReceiverStatusHandler.java | 152 ++---
.../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 +-
.../pipe/source/IoTDBNonDataRegionSource.java | 14 +-
.../schema/table/NonCommittableTsTable.java} | 36 +-
.../apache/iotdb/commons/schema/table/TsTable.java | 24 +-
.../service/AbstractThriftServiceThread.java | 15 +-
.../iotdb/commons/service/metric/enums/Metric.java | 3 +
.../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 | 14 +
library-udf/pom.xml | 2 -
pom.xml | 15 +-
scripts/conf/ainode-env.sh | 138 -----
scripts/conf/windows/ainode-env.bat | 129 -----
scripts/sbin/start-ainode.sh | 56 +-
scripts/sbin/windows/start-ainode.bat | 62 +--
289 files changed, 8952 insertions(+), 2460 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/ainode/ainode.spec
create mode 100644 iotdb-core/ainode/build_binary.py
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%)
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/{DeleteStorageGroupState.java
=> DeleteDatabaseState.java} (96%)
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
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{RemoveUnreferencedScalarApplyNodes.java
=> MergeUnion.java} (67%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/{MergeLimitOverProjectWithMergeSort.java
=> PushLimitThroughUnion.java} (57%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/PushProjectionThroughUnion.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/PushTopKThroughUnion.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/RemoveEmptyUnionBranches.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/iterative/rule/SetOperationMerge.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/main/java/org/apache/iotdb/db/storageengine/load/active/ActiveLoadPathHelper.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/pattern/TreePatternCoverageTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/TransformOperatorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/IntersectTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/plan/relational/analyzer/UnionOptimizeTest.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/IoTDBTreePatternOperations.java
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/SingleTreePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/WithExclusionIoTDBTreePattern.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/datastructure/pattern/WithExclusionTreePattern.java
copy
iotdb-core/{datanode/src/main/java/org/apache/iotdb/db/pipe/processor/twostage/state/CountState.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/schema/table/NonCommittableTsTable.java}
(60%)
delete mode 100644 scripts/conf/ainode-env.sh
delete mode 100644 scripts/conf/windows/ainode-env.bat
