This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch pipe-parallel-connector
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 57bdcc9e202 fix return client bug
new 9e90f853bc7 mvn spotless:apply
add 9ca67d958ca [IOTDB-5972]Limit the number of all source files in
compaction (#10069)
add 4786e3d70e0 Fix SQL parse of privileges on view and pipe (#10129)
add 90f22552ea9 [doc]Fixed errors in configuration items in the
documentation (#10103)
add 4cf7a483ffb Pipe: avoid overriding wal entries when loading entries
from different wal nodes (#10130)
add 0fa2300e582 fix a a coding pattern that could possibly have security
impact (#10136)
add 47c30ee0cdc Avoid useless query in SchemaRegion when executing show
child nodes (#10140)
add c5c3c3262c4 Support not checking `isAligned` in insertion (#10141)
add f3ef81a73ea delay the initialization of DataRegion metrics (#10100)
add 2b2f4bed42f Remove the usage of Validate.isTrue method to avoid
unnecessary construction of string (#10143)
add 9b58bcd6769 [IOTDB-5996] Fix time display of show queries
add 2abadc08928 Update v1.1.1 download urls (#10150)
add 13795eff5d3 Support not checking `isAligned` in select into (#10155)
add 9741bc150f1 Support show timeseries of system db in tail (#10158)
add ebfedc1a159 Fix One of the constructors for the Tablet class in the
client-cpp interface is incorrect (#10152)
add 807d9e07fc8 Fix show latest alias series (#10168)
add 68a8247ec35 Refactor alter view (#10166)
new 2308c5fbce7 Merge branch 'master' of github.com:apache/iotdb into
pipe-parallel-connector
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:
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 49 ++++
.../confignode/client/DataNodeRequestType.java | 2 +
.../client/async/AsyncDataNodeClientPool.java | 29 ++-
.../client/async/handlers/AsyncClientHandler.java | 5 +-
...RPCHandler.java => SchemaUpdateRPCHandler.java} | 6 +-
.../iotdb/confignode/manager/ConfigManager.java | 11 +
.../apache/iotdb/confignode/manager/IManager.java | 3 +
.../iotdb/confignode/manager/ProcedureManager.java | 52 +++-
.../persistence/executor/ConfigPlanExecutor.java | 15 +-
...ocedure.java => AlterLogicalViewProcedure.java} | 288 ++++++++++-----------
.../impl/schema/DeleteLogicalViewProcedure.java | 3 +-
...alViewState.java => AlterLogicalViewState.java} | 5 +-
.../procedure/store/ProcedureFactory.java | 6 +
.../confignode/procedure/store/ProcedureType.java | 3 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 6 +
docs/Download/README.md | 22 +-
docs/UserGuide/Reference/Common-Config-Manual.md | 10 +-
.../Reference/ConfigNode-Config-Manual.md | 8 +-
docs/UserGuide/Reference/DataNode-Config-Manual.md | 12 +-
docs/zh/Download/README.md | 22 +-
.../zh/UserGuide/Reference/Common-Config-Manual.md | 10 +-
.../Reference/ConfigNode-Config-Manual.md | 8 +-
.../UserGuide/Reference/DataNode-Config-Manual.md | 12 +-
.../it/partition/IoTDBPartitionGetterIT.java | 2 +-
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 60 +++--
.../db/it/schema/view/IoTDBAliasSeriesIT.java | 13 +-
.../iotdb/db/it/schema/view/IoTDBAlterViewIT.java | 117 +++++++++
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 38 ++-
iotdb-client/client-cpp/src/main/Session.h | 5 +-
.../src/main/thrift/confignode.thrift | 7 +
.../thrift/src/main/thrift/datanode.thrift | 7 +
.../resources/conf/iotdb-common.properties | 2 +-
.../org/apache/iotdb/commons/path/PartialPath.java | 10 +
.../apache/iotdb/commons/path/PathPatternUtil.java | 4 +
.../builtin/connector/IoTDBThriftConnectorV1.java | 21 +-
.../builtin/connector/IoTDBThriftConnectorV2.java | 21 +-
.../org/apache/iotdb/commons/utils/AuthUtils.java | 8 +
.../apache/iotdb/db/client/ConfigNodeClient.java | 22 ++
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 31 ++-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 8 +-
.../iotdb/db/conf/directories/TierManager.java | 7 +-
...a => CompactionFileCountExceededException.java} | 5 +-
.../execute/task/AbstractCompactionTask.java | 6 +-
.../execute/task/CrossSpaceCompactionTask.java | 30 ++-
.../execute/task/InnerSpaceCompactionTask.java | 7 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 2 +-
.../impl/SizeTieredCompactionSelector.java | 2 +-
.../db/engine/settle/SettleRequestHandler.java | 2 +-
.../metadata/view/ViewNotExistException.java | 25 --
.../db/metadata/cache/TimeSeriesSchemaCache.java | 8 +-
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 4 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 4 +-
.../plan/schemaregion/SchemaRegionPlanType.java | 1 +
.../plan/schemaregion/SchemaRegionPlanVisitor.java | 5 +
.../impl/SchemaRegionPlanDeserializer.java | 9 +
.../impl/SchemaRegionPlanSerializer.java | 13 +
.../impl/SchemaRegionPlanTxtSerializer.java | 11 +
...PlanImpl.java => AlterLogicalViewPlanImpl.java} | 32 ++-
.../impl/write/SchemaRegionWritePlanFactory.java | 8 +
...calViewPlan.java => IAlterLogicalViewPlan.java} | 16 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 3 +
.../schemaregion/SchemaRegionMemoryImpl.java | 23 ++
.../schemaregion/SchemaRegionSchemaFileImpl.java | 7 +
.../metadata/visitor/SchemaExecutionVisitor.java | 20 ++
.../mpp/common/schematree/ClusterSchemaTree.java | 10 +-
.../operator/source/ShowQueriesOperator.java | 6 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 1 +
.../iotdb/db/mpp/plan/analyze/SelectIntoUtils.java | 9 +-
.../mpp/plan/analyze/schema/ISchemaValidation.java | 6 +
.../plan/analyze/schema/NormalSchemaFetcher.java | 66 ++++-
.../config/executor/ClusterConfigTaskExecutor.java | 74 +++---
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 10 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 22 +-
.../plan/planner/distribution/SourceRewriter.java | 122 ++++++---
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 +
...icalViewNode.java => AlterLogicalViewNode.java} | 92 +------
.../plan/statement/crud/InsertRowStatement.java | 11 +-
.../plan/statement/crud/InsertTabletStatement.java | 11 +-
.../metadata/view/AlterLogicalViewStatement.java | 11 -
.../metadata/view/CreateLogicalViewStatement.java | 4 +
.../org/apache/iotdb/db/rescon/SystemInfo.java | 54 ++++
.../iotdb/db/service/metrics/WritingMetrics.java | 20 ++
.../impl/DataNodeInternalRPCServiceImpl.java | 35 +++
.../iotdb/db/utils/TimestampPrecisionUtils.java | 57 ++++
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 4 +
.../apache/iotdb/db/wal/utils/WALEntryHandler.java | 9 +-
.../iotdb/db/wal/utils/WALEntryPosition.java | 15 +-
.../iotdb/db/wal/utils/WALInsertNodeCache.java | 6 +-
.../engine/compaction/AbstractCompactionTest.java | 4 +-
.../engine/compaction/CompactionSchedulerTest.java | 96 +++----
.../CompactionSchedulerWithFastPerformerTest.java | 96 +++----
.../db/engine/compaction/MemoryControlTest.java | 137 +++++++++-
.../cross/CrossSpaceCompactionSelectorTest.java | 46 ++++
...eCompactionWithFastPerformerValidationTest.java | 22 +-
...actionWithReadPointPerformerValidationTest.java | 18 +-
.../cross/RewriteCompactionFileSelectorTest.java | 15 +-
.../inner/InnerCompactionSchedulerTest.java | 10 +-
.../inner/InnerSpaceCompactionSelectorTest.java | 2 +-
.../SizeTieredCompactionSelectorTest.java | 9 +-
.../compaction/utils/CompactionConfigRestorer.java | 4 +-
.../db/engine/settle/SettleRequestHandlerTest.java | 6 +-
.../db/engine/storagegroup/DataRegionTest.java | 10 +-
.../iotdb/db/wal/buffer/WALBufferCommonTest.java | 1 +
.../db/wal/checkpoint/CheckpointManagerTest.java | 1 +
.../iotdb/db/wal/node/ConsensusReqReaderTest.java | 2 +
.../iotdb/db/wal/node/WALEntryHandlerTest.java | 156 ++++++++---
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 2 +
.../db/wal/recover/WALRecoverManagerTest.java | 2 +
site/iotdb-doap.rdf | 10 +-
110 files changed, 1766 insertions(+), 762 deletions(-)
rename
confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/rpc/{DeleteSchemaRPCHandler.java
=> SchemaUpdateRPCHandler.java} (93%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/{DeleteLogicalViewProcedure.java
=> AlterLogicalViewProcedure.java} (51%)
copy
confignode/src/main/java/org/apache/iotdb/confignode/procedure/state/schema/{DeleteLogicalViewState.java
=> AlterLogicalViewState.java} (91%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/view/IoTDBAlterViewIT.java
copy
server/src/main/java/org/apache/iotdb/db/engine/compaction/execute/exception/{CompactionMemoryNotEnoughException.java
=> CompactionFileCountExceededException.java} (87%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/impl/write/{DeleteLogicalViewPlanImpl.java
=> AlterLogicalViewPlanImpl.java} (55%)
copy
server/src/main/java/org/apache/iotdb/db/metadata/plan/schemaregion/write/view/{IDeleteLogicalViewPlan.java
=> IAlterLogicalViewPlan.java} (75%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/view/{CreateLogicalViewNode.java
=> AlterLogicalViewNode.java} (65%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/utils/TimestampPrecisionUtils.java
