This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch TableModelIngestion
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 6c24a6f9ec6 temp save
add d72429fbe11 Merge master0611 (#12703)
add 50d8708f2ec [Table Model] Schema Validation Interface (#12707)
new a8cb5296002 Merge branch 'master' into ty/TableModelGrammarTest
new f09ad546ee4 temp save
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:
distribution/src/assembly/all.xml | 9 +
distribution/src/assembly/confignode.xml | 9 +
distribution/src/assembly/datanode.xml | 9 +
.../org/apache/iotdb/db/it/IoTDBRepairDataIT.java | 2 +-
.../iotdb/db/it/IoTDBSetConfigurationIT.java | 89 +++++++
.../java/org/apache/iotdb/db/it/IoTDBSettleIT.java | 2 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 5 +-
.../db/it/aggregation/IoTDBAggregationIT.java | 15 +-
.../db/it/aggregation/maxby/IoTDBMaxByIT.java | 3 +-
.../db/it/aggregation/minby/IoTDBMinByIT.java | 3 +-
.../iotdb/db/it/udf/IoTDBUDFWindowQuery2IT.java | 216 ++++++++++++++++
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 4 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 34 ++-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 8 +
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 4 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 4 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 11 +-
.../assembly/resources/sbin/stop-confignode.bat | 19 +-
.../confignode/client/ConfigNodeRequestType.java | 4 +-
.../confignode/client/DataNodeRequestType.java | 2 +
.../client/async/AsyncDataNodeClientPool.java | 7 +
.../client/sync/SyncConfigNodeClientPool.java | 3 +
.../client/sync/SyncDataNodeClientPool.java | 8 +-
.../confignode/conf/ConfigNodeDescriptor.java | 6 +-
.../iotdb/confignode/manager/ConfigManager.java | 52 ++++
.../apache/iotdb/confignode/manager/IManager.java | 8 +
.../iotdb/confignode/manager/node/NodeManager.java | 107 +++++++-
.../manager/partition/PartitionManager.java | 2 +-
.../persistence/pipe/PipePluginInfo.java | 39 +--
.../procedure/env/ConfigNodeProcedureEnv.java | 22 +-
.../procedure/env/RegionMaintainHandler.java | 78 +++---
.../impl/sync/AuthOperationProcedure.java | 11 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 12 +
.../src/assembly/resources/sbin/stop-datanode.bat | 24 +-
.../org/apache/iotdb/db/audit/AuditLogger.java | 1 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 13 +-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 14 ++
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 117 +++++++--
.../impl/DataNodeInternalRPCServiceImpl.java | 22 ++
.../iotdb/db/queryengine/plan/Coordinator.java | 1 -
.../db/queryengine/plan/analyze/Analysis.java | 11 +
.../db/queryengine/plan/analyze/AnalyzeUtils.java | 64 +++--
.../queryengine/plan/analyze/AnalyzeVisitor.java | 49 +++-
.../db/queryengine/plan/analyze/IAnalysis.java | 17 +-
.../plan/analyze/LoadTsfileAnalyzer.java | 8 +
.../plan/analyze/schema/ISchemaAutoCreation.java | 5 +-
.../plan/analyze/schema/SchemaValidator.java | 7 +-
.../plan/execution/config/ConfigTaskVisitor.java | 8 +
.../config/executor/ClusterConfigTaskExecutor.java | 87 +++++--
.../config/executor/IConfigTaskExecutor.java | 3 +
...tleQuotaTask.java => SetConfigurationTask.java} | 17 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 20 ++
.../plan/parser/StatementGenerator.java | 15 +-
.../queryengine/plan/planner/LogicalPlanner.java | 3 +-
.../distribution/WriteFragmentParallelPlanner.java | 11 +-
.../plan/planner/plan/node/WritePlanNode.java | 4 +-
.../plan/node/load/LoadSingleTsFileNode.java | 4 +-
.../planner/plan/node/load/LoadTsFileNode.java | 10 +-
.../plan/node/load/LoadTsFilePieceNode.java | 4 +-
.../node/metedata/write/ActivateTemplateNode.java | 4 +-
.../node/metedata/write/AlterTimeSeriesNode.java | 4 +-
.../metedata/write/BatchActivateTemplateNode.java | 4 +-
.../write/CreateAlignedTimeSeriesNode.java | 4 +-
.../metedata/write/CreateMultiTimeSeriesNode.java | 4 +-
.../node/metedata/write/CreateTimeSeriesNode.java | 4 +-
.../write/InternalBatchActivateTemplateNode.java | 4 +-
.../write/InternalCreateMultiTimeSeriesNode.java | 4 +-
.../write/InternalCreateTimeSeriesNode.java | 4 +-
.../metedata/write/view/CreateLogicalViewNode.java | 4 +-
.../plan/node/pipe/PipeEnrichedDeleteDataNode.java | 4 +-
.../plan/node/pipe/PipeEnrichedInsertNode.java | 4 +-
.../plan/node/pipe/PipeEnrichedWritePlanNode.java | 4 +-
.../planner/plan/node/write/DeleteDataNode.java | 5 +-
.../plan/node/write/InsertMultiTabletsNode.java | 4 +-
.../planner/plan/node/write/InsertRowNode.java | 4 +-
.../planner/plan/node/write/InsertRowsNode.java | 4 +-
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 4 +-
.../planner/plan/node/write/InsertTabletNode.java | 4 +-
.../plan/relational/analyzer/Analysis.java | 28 +++
.../relational/analyzer/StatementAnalyzer.java | 32 +--
.../metadata/ITableDeviceSchemaValidation.java | 66 +++++
.../plan/relational/metadata/Metadata.java | 30 ++-
.../relational/metadata/TableMetadataImpl.java | 13 +
.../distribute/TableDistributionPlanner.java | 5 +-
...or.java => TableModelQueryFragmentPlanner.java} | 7 +-
.../plan/relational/sql/ast/InsertTablet.java | 36 +--
.../relational/sql/ast/WrappedInsertStatement.java | 96 +++----
.../plan/relational/sql/ast/WrappedStatement.java | 13 +-
.../plan/relational/utils/ConversionUtils.java} | 12 +-
.../queryengine/plan/statement/StatementType.java | 1 +
.../plan/statement/StatementVisitor.java | 5 +
.../plan/statement/crud/InsertBaseStatement.java | 22 ++
.../plan/statement/crud/InsertTabletStatement.java | 24 +-
...atement.java => SetConfigurationStatement.java} | 30 +--
.../dag/intermediate/MultiInputLayer.java | 5 +-
.../SingleInputMultiReferenceLayer.java | 12 +-
.../SingleInputSingleReferenceLayer.java | 12 +-
.../iotdb/db/storageengine/StorageEngine.java | 42 ++++
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 4 +-
.../plan/relational/analyzer/TestMatadata.java | 14 ++
iotdb-core/node-commons/pom.xml | 76 ++++++
.../resources/conf/generate_properties.bat | 64 +++++
.../assembly/resources/conf/generate_properties.sh | 59 +++++
.../resources/conf/iotdb-system.properties | 2 +-
.../iotdb/commons/conf/CommonDescriptor.java | 5 +-
.../commons/conf/ConfigFileAutoUpdateTool.java | 126 ----------
.../iotdb/commons/conf/ConfigurationFileUtils.java | 275 +++++++++++++++++++++
.../commons/partition/SeriesPartitionTable.java | 28 +--
.../pipe/connector/protocol/IoTDBConnector.java | 28 ++-
.../schema/table/column/TsTableColumnCategory.java | 2 +-
.../thrift-commons/src/main/thrift/common.thrift | 18 +-
.../src/main/thrift/confignode.thrift | 6 +
.../thrift-datanode/src/main/thrift/client.thrift | 4 +
.../src/main/thrift/datanode.thrift | 4 +
114 files changed, 2011 insertions(+), 618 deletions(-)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBSetConfigurationIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDFWindowQuery2IT.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/execution/config/sys/{quota/SetThrottleQuotaTask.java
=> SetConfigurationTask.java} (68%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/metadata/ITableDeviceSchemaValidation.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/planner/distribute/{FragmentInstanceGenerator.java
=> TableModelQueryFragmentPlanner.java} (97%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{audit/AuditLogStorage.java
=> queryengine/plan/relational/utils/ConversionUtils.java} (84%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/sys/{SetSystemStatusStatement.java
=> SetConfigurationStatement.java} (71%)
create mode 100644
iotdb-core/node-commons/src/assembly/resources/conf/generate_properties.bat
create mode 100644
iotdb-core/node-commons/src/assembly/resources/conf/generate_properties.sh
delete mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/ConfigFileAutoUpdateTool.java
create mode 100644
iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/conf/ConfigurationFileUtils.java
