This is an automated email from the ASF dual-hosted git repository.
shuwenwei pushed a change to branch table_disk_usage_statistics_with_cache
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from b765dd71d93 fix copilot review comments
add 45d9471befc Fix sort branch release logic of SORT operator #17148
add a93cde24d7c fix the bug that insert null into the time column #17150
add 220ee167be4 Fix occasional CI failures of IoTDBMQTTServiceJsonIT.
(#17146)
add 13513ea12f2 Load: Support same measurement name and type with
different encoding and compression (#17152)
add 52d7245a2b8 Pipe: Banned the illegal names in pipe and pipe plugins
(#17145)
add 1fbef53d801 Pipe: allow exclusion-only pattern lists (#17154)
add 4c821492d29 Fixed the bug that the template may create measurements
under timeSeries && Optimized the logger for meta user exceptions (#17158)
add c1f4682c207 Fixed the NPE when validating legacy sink (#17153)
add 22c6c6c112a Remove netty from service-rpc (#17157)
add 4bf7c3e4a19 Fix set sql_dialect=table will clear current database bug
(#17159)
add 2c903b01328 [AINode] Support register as system service (#17138)
add a03b627a45c Fix: Add Mods data scanning check in scan parser for
non-aligned data (#17162)
add 29aad95ff84 Pipe: Fixed the legacy sink IT (#17164)
add 38410727f74 fix: Fix missing encoding and compression information for
Measurement (#17141)
add 2f07c80c50d Pipe: CI Fix (#17167)
add 6228880ecf9 Pipe: Optimized the logger semantic && the retry logic of
memory error at sink subtask (#17166)
add f7d7f68aff7 [AINode] Sync codes for ainode (#17139)
add 34880db07fd Pipe: preserve exclusions for complex wildcards (#17170)
add 8896075ab1e feat(jdbc): implement PreparedStatement (#17027)
add 67fda53e0c1 feat: show timeseries [order by timseries] clause (#17065)
add bfb0d32284d [AINode] Optimize the statuscode for remove AINode (#17176)
add d9b692bcca7 Pipe: Changed the separator check semantic for pipes /
pipe plugins (#17175)
add 861d3eec35b Pipe: Fixed the idempotent semantic for MULTIPLE_ERROR
(#17177)
add c08dc674c74 Pipe: Reduced the downgraded epochs' downgrading limit to
reduce the latency (#17184)
add 1b0a9d76883 Pipe: Enabled locally retry for PipeConnectionException
(#17182)
add 06537dc2fd0 correct metadata "modified" flags and related logic
(#17172)
add 69142ce7477 Pipe: Enabled retry locally for air gap receiver &
temporary unavailable exception (#17188)
add ba6327e19d0 Remove unused AGGREGATE_TIME_LIST (#17186)
add c43327f9038 Merge branch 'iotdb_master' into
table_disk_usage_statistics_with_cache
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/db/it/IoTDBLoadTsFileIT.java | 53 ++
.../iotdb/db/it/mqtt/IoTDBMQTTServiceJsonIT.java | 132 +++-
.../db/it/schema/IoTDBAlterTimeSeriesTypeIT.java | 6 +-
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 17 +
.../IoTDBShowTimeseriesOrderByTimeseriesIT.java | 278 ++++++++
.../org/apache/iotdb/db/it/utils/TestUtils.java | 41 +-
.../treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 33 +-
.../treemodel/auto/basic/IoTDBPipeSyntaxIT.java | 64 ++
.../auto/basic/IoTDBTreePatternFormatIT.java | 114 ++++
.../auto/enhanced/IoTDBPipeIdempotentIT.java | 2 -
.../IoTDBPipeTsFileDecompositionWithModsIT.java | 316 +++++++++
.../relational/it/db/it/IoTDBInsertTableIT.java | 36 +
...tIT.java => IoTDBTablePreparedStatementIT.java} | 2 +-
.../db/it/IoTDBTablePreparedStatementJDBCIT.java | 498 ++++++++++++++
.../it/query/recent/IoTDBFillTableIT.java | 20 +
.../java/org/apache/iotdb/cli/AbstractCli.java | 1 -
.../src/main/java/org/apache/iotdb/cli/Cli.java | 2 -
.../iotdb/tool/tsfile/ImportTsFileRemotely.java | 9 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 6 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 6 +-
.../iotdb/jdbc/IoTDBTablePreparedStatement.java | 732 +++++++++++++++++++++
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 142 ----
.../jdbc/IoTDBTablePreparedStatementTest.java | 240 +++++++
iotdb-client/service-rpc/pom.xml | 16 -
.../iotdb/rpc/NettyTNonblockingTransport.java | 624 ------------------
.../iotdb/rpc/TNonblockingTransportWrapper.java | 8 +-
.../iotdb/rpc/stmt/PreparedParameterSerde.java | 175 +++++
.../iotdb/rpc/stmt/PreparedParameterSerdeTest.java | 127 ++++
iotdb-core/ainode/ainode.xml | 9 +
iotdb-core/ainode/iotdb/ainode/core/config.py | 15 -
iotdb-core/ainode/iotdb/ainode/core/constant.py | 1 -
.../core/inference/inference_request_pool.py | 4 +-
.../core/inference/pipeline/basic_pipeline.py | 74 ++-
.../iotdb/ainode/core/inference/pool_controller.py | 13 +-
.../ainode/iotdb/ainode/core/ingress/iotdb.py | 8 -
.../iotdb/ainode/core/manager/inference_manager.py | 117 ++--
iotdb-core/ainode/iotdb/ainode/core/rpc/handler.py | 3 +-
.../ainode/resources/conf/iotdb-ainode.properties | 4 -
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 9 +-
.../iotdb/confignode/manager/ProcedureManager.java | 4 +-
.../iotdb/confignode/manager/node/NodeManager.java | 2 +-
.../persistence/pipe/PipePluginInfo.java | 2 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 4 +-
.../pipe/plugin/CreatePipePluginProcedure.java | 2 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 2 +-
.../scan/TsFileInsertionEventScanParser.java | 17 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 2 +-
.../exchange/sender/TwoStageAggregateSender.java | 5 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 62 +-
.../legacy/IoTDBLegacyPipeReceiverAgent.java | 5 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 4 +-
.../visitor/PipeStatementTSStatusVisitor.java | 219 +++---
...leStatementDataTypeConvertExecutionVisitor.java | 12 +-
...eeStatementDataTypeConvertExecutionVisitor.java | 10 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 4 +-
.../sink/protocol/legacy/IoTDBLegacyPipeSink.java | 13 +-
.../pipeconsensus/PipeConsensusSyncSink.java | 2 +-
.../PipeConsensusTsFileInsertionEventHandler.java | 2 +-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 37 +-
.../PipeTransferTabletBatchEventHandler.java | 2 +-
.../PipeTransferTabletInsertionEventHandler.java | 2 +-
.../async/handler/PipeTransferTsFileHandler.java | 8 +-
.../PipeRealtimeDataRegionHybridSource.java | 16 +-
.../iotdb/db/protocol/session/IClientSession.java | 3 +
.../iotdb/db/protocol/thrift/OperationType.java | 5 +-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 279 +++++++-
.../impl/DataNodeInternalRPCServiceImpl.java | 16 +-
.../thrift/impl/NativeStatementRequest.java | 99 +++
.../operator/process/AbstractSortOperator.java | 4 +-
.../schema/source/LogicalViewSchemaSource.java | 3 +-
.../schema/source/SchemaSourceFactory.java | 16 +-
.../schema/source/TimeSeriesSchemaSource.java | 9 +-
.../execution/operator/source/FileLoaderUtils.java | 80 +--
.../execution/operator/source/SeriesScanUtil.java | 47 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 59 +-
.../load/TreeSchemaAutoCreatorAndVerifier.java | 32 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 63 +-
.../execution/config/session/DeallocateTask.java | 19 +-
.../plan/execution/config/session/PrepareTask.java | 27 +-
.../config/session/PreparedStatementHelper.java | 60 ++
.../db/queryengine/plan/parser/ASTVisitor.java | 10 +
.../plan/planner/LogicalPlanBuilder.java | 16 +-
.../plan/planner/LogicalPlanVisitor.java | 75 ++-
.../plan/planner/OperatorTreeGenerator.java | 3 +-
.../SimpleFragmentParallelPlanner.java | 4 +-
.../metadata/read/SeriesSchemaFetchScanNode.java | 4 +-
.../metadata/read/TimeSeriesSchemaScanNode.java | 49 +-
.../node/process/ActiveRegionScanMergeNode.java | 3 +
.../metadata/fetcher/TableDeviceSchemaFetcher.java | 4 +-
.../plan/relational/planner/CteMaterializer.java | 2 +-
...ithUncorrelatedScalarSubqueryReconstructor.java | 2 +-
.../plan/relational/sql/parser/AstBuilder.java | 2 +
.../plan/statement/metadata/ShowStatement.java | 7 +
.../metadata/ShowTimeSeriesStatement.java | 15 +
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 21 +
.../GeneralRegionAttributeSecurityService.java | 4 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 8 +
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 227 ++++++-
.../mtree/impl/mem/mnode/IMemMNode.java | 11 +-
.../mtree/impl/mem/mnode/basic/BasicMNode.java | 16 +-
.../impl/mem/mnode/impl/AboveDatabaseMNode.java | 10 +
.../mtree/impl/mem/mnode/impl/DatabaseMNode.java | 10 +
.../impl/mem/mnode/impl/MeasurementMNode.java | 10 +
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 207 +++++-
.../schemaregion/read/req/IShowTimeSeriesPlan.java | 4 +
.../read/req/SchemaRegionReadPlanFactory.java | 14 +-
.../read/req/impl/ShowTimeSeriesPlanImpl.java | 18 +-
.../impl/SchemaReaderLimitOffsetWrapper.java | 36 +-
.../schemaregion/utils/ResourceByPathUtils.java | 6 +-
.../template/ClusterTemplateManager.java | 8 +-
.../read/reader/chunk/MemAlignedChunkReader.java | 7 +
.../read/reader/chunk/MemAlignedPageReader.java | 9 +-
.../read/reader/chunk/MemChunkReader.java | 7 +
.../read/reader/chunk/MemPageReader.java | 9 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 3 +
.../org/apache/iotdb/db/utils/SchemaUtils.java | 126 +---
.../iotdb/db/utils/sort/FileSpillerReader.java | 5 +
.../apache/iotdb/db/utils/sort/MemoryReader.java | 5 +
.../org/apache/iotdb/db/utils/sort/SortReader.java | 3 +
.../schemaRegion/SchemaRegionTestUtil.java | 25 +-
.../db/pipe/pattern/TreePatternPruningTest.java | 20 +
.../receiver/PipeStatementTsStatusVisitorTest.java | 65 ++
.../operator/SortOperatorSortBranchTest.java | 207 ++++++
.../schema/SchemaQueryScanOperatorTest.java | 3 +-
.../iotdb/commons/client/ClientPoolFactory.java | 20 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 211 ++++--
.../task/subtask/PipeAbstractSinkSubtask.java | 31 +-
.../agent/task/subtask/PipeReportableSubtask.java | 23 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 117 ++--
.../iotdb/commons/pipe/config/PipeDescriptor.java | 57 +-
.../pipe/datastructure/pattern/TreePattern.java | 40 +-
.../pipe/sink/client/IoTDBClientManager.java | 2 +-
.../commons/pipe/sink/client/IoTDBSyncClient.java | 2 +-
.../pipe/sink/client/IoTDBSyncClientManager.java | 4 +-
.../pipe/sink/limiter/GlobalRPCRateLimiter.java | 2 +-
.../pipe/sink/protocol/IoTDBAirGapSink.java | 4 +-
.../commons/pipe/sink/protocol/IoTDBSink.java | 12 +-
.../pipe/sink/protocol/IoTDBSslSyncSink.java | 2 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 12 +
.../thrift-ainode/src/main/thrift/ainode.thrift | 3 +-
.../thrift-datanode/src/main/thrift/client.thrift | 35 +
pom.xml | 2 +-
scripts/sbin/start-ainode.sh | 2 +-
scripts/sbin/stop-ainode.sh | 2 +-
.../ops/{daemon-datanode.sh => daemon-ainode.sh} | 28 +-
scripts/tools/ops/daemon-confignode.sh | 3 +-
scripts/tools/ops/daemon-datanode.sh | 3 +-
148 files changed, 5329 insertions(+), 1806 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBShowTimeseriesOrderByTimeseriesIT.java
rename
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/{IoTDBPreparedStatementIT.java
=> IoTDBTablePreparedStatementIT.java} (99%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/db/it/IoTDBTablePreparedStatementJDBCIT.java
create mode 100644
iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/IoTDBTablePreparedStatement.java
create mode 100644
iotdb-client/jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBTablePreparedStatementTest.java
delete mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/NettyTNonblockingTransport.java
create mode 100644
iotdb-client/service-rpc/src/main/java/org/apache/iotdb/rpc/stmt/PreparedParameterSerde.java
create mode 100644
iotdb-client/service-rpc/src/test/java/org/apache/iotdb/rpc/stmt/PreparedParameterSerdeTest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/thrift/impl/NativeStatementRequest.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/session/PreparedStatementHelper.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/PipeStatementTsStatusVisitorTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/queryengine/execution/operator/SortOperatorSortBranchTest.java
copy scripts/tools/ops/{daemon-datanode.sh => daemon-ainode.sh} (68%)
