This is an automated email from the ASF dual-hosted git repository.
weihao pushed a change to branch addQueryDebug
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 4640774700e perfect it
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)
new 0a80758eedd Merge branch 'master' of github.com:apache/iotdb into
addQueryDebug
The 1 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:
.../IoTDBShowTimeseriesOrderByTimeseriesIT.java | 278 ++++++++
.../treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 3 +-
.../auto/basic/IoTDBTreePatternFormatIT.java | 58 ++
.../IoTDBPipeTsFileDecompositionWithModsIT.java | 316 +++++++++
...tIT.java => IoTDBTablePreparedStatementIT.java} | 2 +-
.../db/it/IoTDBTablePreparedStatementJDBCIT.java | 498 ++++++++++++++
.../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/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 +-
.../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 +-
.../iotdb/db/protocol/thrift/OperationType.java | 5 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 16 +-
.../thrift/impl/NativeStatementRequest.java | 99 +++
.../schema/source/LogicalViewSchemaSource.java | 3 +-
.../schema/source/SchemaSourceFactory.java | 16 +-
.../schema/source/TimeSeriesSchemaSource.java | 9 +-
.../iotdb/db/queryengine/plan/Coordinator.java | 59 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 12 +-
.../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 | 8 +-
.../plan/planner/LogicalPlanVisitor.java | 69 +-
.../plan/planner/OperatorTreeGenerator.java | 3 +-
.../SimpleFragmentParallelPlanner.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/statement/metadata/ShowStatement.java | 7 +
.../metadata/ShowTimeSeriesStatement.java | 15 +
.../apache/iotdb/db/schemaengine/SchemaEngine.java | 21 +
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 8 +
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 198 +++++-
.../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 | 148 +++++
.../schemaregion/read/req/IShowTimeSeriesPlan.java | 4 +
.../read/req/SchemaRegionReadPlanFactory.java | 14 +-
.../read/req/impl/ShowTimeSeriesPlanImpl.java | 18 +-
.../impl/SchemaReaderLimitOffsetWrapper.java | 36 +-
.../template/ClusterTemplateManager.java | 8 +-
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 1 +
.../schemaRegion/SchemaRegionTestUtil.java | 25 +-
.../db/pipe/pattern/TreePatternPruningTest.java | 20 +
.../schema/SchemaQueryScanOperatorTest.java | 3 +-
.../task/subtask/PipeAbstractSinkSubtask.java | 11 +-
.../pipe/datastructure/pattern/TreePattern.java | 28 +-
.../thrift-ainode/src/main/thrift/ainode.thrift | 3 +-
.../thrift-datanode/src/main/thrift/client.thrift | 35 +
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 +-
81 files changed, 3620 insertions(+), 430 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
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
copy scripts/tools/ops/{daemon-datanode.sh => daemon-ainode.sh} (68%)
