You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by gi...@apache.org on 2022/07/27 02:12:01 UTC
[iotdb] branch dependabot/maven/master/org.testcontainers-testcontainers-1.15.3 updated (ff307a96e8 -> 7a7efaf5bd)
This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch dependabot/maven/master/org.testcontainers-testcontainers-1.15.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git
omit ff307a96e8 Bump testcontainers from 1.15.2 to 1.15.3
add c31a35933b Add query retry logic to make the query won't fail when some DataNode shutdown (#6717)
add e51f5ef6a4 [IOTDB-3859] Fix wrong isBlocked() method implementation in AggregationOperator (#6695)
add a1f1c3c2df [IOTDB-3475] Fix ResultSet format for empty query (#6648)
add 58048ecfa6 exclude md5 file when get latest snapshot (#6704)
add 882398b025 Update go client submodule commits for CI (#6732)
add 2c190fc60f [IOTDB-3889]List Privileges Role on Path cannot display a wider range path pattern (#6718)
add 6d4d8c0d73 [IOTDB-3721] Keep each FI's execution timeout consistent with timeout set in session (#6663)
add f465aac433 IOTDB-3901 C++ client method of insertRecordsOfOneDevice sorting optimization (#6734)
add abbf3bfe9f Place the addMetrics for configManager after setUpInternalServices (#6705)
add 62a80790a1 Update README_ZH.md (#6738)
add 7b595aefe4 Refine the Retry logic for QueryExecution because of Execption changed. (#6737)
add 2e04339943 [IOTDB-3883] Support Order By timeseries in last query (part1 - support SQL) (#6728)
add 5721496be8 [IOTDB-3624] Meet error when inserting data in SQL without timestamp (#6642)
add 67d78fe47b [IOTDB-3827]support partition cache for query. (#6673)
add bafcd5b206 fix IOTDB-3899 (#6731)
add 53a15c5a6c Bump jetty.version from 9.4.35.v20201120 to 9.4.48.v20220622 (#6726)
add 6ad9f83cc1 [IOTDB-3881] strength the concurrency control of regionReplicaSetCache. (#6708)
add 3b986fb935 [IoTDB-3842] Fix the issue that GroupByLevel cannot use value filter
add 1ffe93cb27 [IOTDB-3815] replace remove data node to procedure (#6736)
add dfcb0a8903 fix timeout problem while using cli (#6741)
add 842105470d [IOTDB-3880] Optimize asyncclientpool retry logic (#6735)
add e429f89e7a update metric of confignode's number (#6754)
add d4b41bbb71 Modified the processing of metrics for collecting the number of storage groups (#6749)
add d3e71a2b38 [IOTDB-3593] Broadcast latest ConfigNodeGroup (#6744)
add bd1894fb72 fix the potential issue for StateTracker that it cannot be terminated sometimes (#6755)
add 3d73b16fbf [IOTDB-3848] Clear up thrift defined data structures of cluster tools (#6716)
add 2b7dc520a7 [IOTDB-3723] Replace FilterOperator with FilterAndProjectOperator and use batch processing for better performance (#6714)
add 159bdef59d [IOTDB-3954] Show datanodes shows nothing
add d7cb849abd Minor Grammar Changes to README.md (#6760)
add 6fceff0236 [IOTDB-3626] Fix wrong row count in UDTFAlignByTimeQueryIT
add f4d1323f11 [IOTDB-3938] Avoid performance decline caused by fsync twice (#6769)
add c735a127b9 [IOTDB-3578] Support core requirements of template (#6750)
add 878de3a2a4 [IOTDB-3797] Print detailed info when failed opening session (#6765)
add 22f2866325 [IOTDB-3777]Avoid holding sg write lock in the whole processin of deletion (#6743)
add 6d3c0cc4d0 [IOTDB-3945] Fix TTL doesn't take effect bug in mpp
add 5fa8a67f36 [IOTDB-3967]fix-bug for user permission info (#6776)
add 7a7efaf5bd Bump testcontainers from 1.15.2 to 1.15.3
This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version. This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:
* -- * -- B -- O -- O -- O (ff307a96e8)
\
N -- N -- N refs/heads/dependabot/maven/master/org.testcontainers-testcontainers-1.15.3 (7a7efaf5bd)
You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
README.md | 6 +-
README_ZH.md | 2 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 24 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 17 +
.../java/org/apache/iotdb/cli/AbstractScript.java | 5 -
.../iotdb/tool/integration/ExportCsvTestIT.java | 8 +-
.../iotdb/tool/integration/ImportCsvTestIT.java | 8 +-
client-cpp/src/main/Session.cpp | 12 +-
client-go | 2 +-
.../confignode/client/DataNodeRequestType.java | 8 +-
.../async/datanode/AsyncDataNodeClientPool.java | 253 ++++---
.../async/handlers/AbstractRetryHandler.java | 33 +-
.../client/async/handlers/CreateRegionHandler.java | 14 +-
.../client/async/handlers/FlushHandler.java | 16 +-
.../async/handlers/FunctionManagementHandler.java | 11 +-
.../client/async/handlers/SetTTLHandler.java | 7 +-
...dler.java => UpdateConfigNodeGroupHandler.java} | 25 +-
.../handlers/UpdateRegionRouteMapHandler.java | 9 +-
.../sync/datanode/SyncDataNodeClientPool.java | 3 +
.../consensus/request/ConfigPhysicalPlan.java | 24 +-
.../consensus/request/ConfigPhysicalPlanType.java | 8 +-
.../template/CheckTemplateSettablePlan.java} | 14 +-
.../GetAllSchemaTemplatePlan.java} | 22 +-
.../GetAllTemplateSetInfoPlan.java} | 22 +-
.../{ => template}/GetPathsSetTemplatePlan.java | 2 +-
.../GetSchemaTemplatePlan.java} | 24 +-
.../request/write/RemoveDataNodePlan.java | 124 +---
.../{ => template}/CreateSchemaTemplatePlan.java | 27 +-
.../{ => template}/SetSchemaTemplatePlan.java | 2 +-
.../consensus/response/AllTemplateSetInfoResp.java | 25 +-
.../response/DataNodeConfigurationResp.java | 20 +-
.../consensus/response/DataNodeRegisterResp.java | 6 +
.../consensus/response/RegionInfoListResp.java | 2 +-
.../statemachine/PartitionRegionStateMachine.java | 2 -
.../confignode/manager/ClusterSchemaManager.java | 179 +++--
.../iotdb/confignode/manager/ConfigManager.java | 142 ++--
.../confignode/manager/DataNodeRemoveManager.java | 806 ---------------------
.../apache/iotdb/confignode/manager/IManager.java | 15 +-
.../iotdb/confignode/manager/NodeManager.java | 97 +--
.../iotdb/confignode/manager/ProcedureManager.java | 34 +
.../iotdb/confignode/manager/UDFManager.java | 63 +-
.../iotdb/confignode/manager/load/LoadManager.java | 31 +-
.../iotdb/confignode/persistence/AuthorInfo.java | 13 +-
.../iotdb/confignode/persistence/NodeInfo.java | 208 +-----
.../persistence/executor/ConfigPlanExecutor.java | 22 +-
.../persistence/partition/PartitionInfo.java | 4 +-
.../partition/StorageGroupPartitionTable.java | 2 +-
.../{ => schema}/ClusterSchemaInfo.java | 136 ++--
.../persistence/schema/TemplateTable.java | 64 +-
.../procedure/env/ConfigNodeProcedureEnv.java | 35 +-
.../procedure/env/DataNodeRemoveHandler.java | 381 ++++++++++
.../procedure/impl/AbstractNodeProcedure.java | 64 ++
.../procedure/impl/AddConfigNodeProcedure.java | 34 +-
.../procedure/impl/RegionMigrateProcedure.java | 230 ++++++
.../procedure/impl/RemoveConfigNodeProcedure.java | 34 +-
.../procedure/impl/RemoveDataNodeProcedure.java | 184 +++++
.../confignode/procedure/scheduler/LockQueue.java | 63 ++
.../state/RegionTransitionState.java} | 21 +-
.../state/RemoveDataNodeState.java} | 22 +-
.../procedure/store/ProcedureFactory.java | 14 +
.../iotdb/confignode/service/ConfigNode.java | 32 +-
.../confignode/service/ConfigNodeCommandLine.java | 31 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 14 +-
.../request/ConfigPhysicalPlanSerDeTest.java | 45 +-
.../request/write/RemoveDataNodePlanTest.java | 1 -
.../persistence/ClusterSchemaInfoTest.java | 28 +-
.../confignode/persistence/TemplateTableTest.java | 18 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 6 +-
.../iotdb/consensus/ratis/SnapshotStorage.java | 3 +
.../Administration-Management/Administration.md | 88 ++-
.../Administration-Management/Administration.md | 88 ++-
.../main/java/org/apache/iotdb/SessionExample.java | 5 +-
.../iotdb/SyntaxConventionRelatedExample.java | 4 +-
.../iotdb/db/it/IoTDBInsertWithoutTimeIT.java | 122 ++++
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 1 +
.../db/it/alignbydevice/IoTDBAlignByDeviceIT.java | 21 +-
.../apache/iotdb/db/it/query/IoTDBResultSetIT.java | 33 +
.../iotdb/db/it/schema/IoTDBSchemaTemplateIT.java | 315 ++++++++
.../db/it/udf/IoTDBUDTFAlignByTimeQueryIT.java | 5 -
.../org/apache/iotdb/db/it/utils/TestUtils.java | 12 +-
.../withoutNull/IoTDBWithoutNullAnyFilterIT.java | 14 +-
.../db/integration/IoTDBInsertWithoutTimeIT.java | 131 ----
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 220 ------
.../iotdb/session/IoTDBSessionComplexIT.java | 2 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 18 -
.../apache/iotdb/session/pool/SessionPoolTest.java | 2 +-
.../apache/iotdb/session/template/TemplateUT.java | 5 +-
.../iotdb/commons/auth/entity/PrivilegeType.java | 10 +-
.../commons/partition/DataPartitionQueryParam.java | 14 -
.../commons/udf/builtin/String/UDTFEndsWith.java | 3 +
.../commons/udf/builtin/String/UDTFLower.java | 3 +
.../commons/udf/builtin/String/UDTFUpper.java | 3 +
.../apache/iotdb/commons/udf/builtin/UDTFAbs.java | 3 +
.../apache/iotdb/commons/udf/builtin/UDTFMath.java | 3 +
.../iotdb/commons/udf/builtin/UDTFOnOff.java | 3 +
.../org/apache/iotdb/commons/utils/AuthUtils.java | 17 +
.../schemaregion/rocksdb/RSchemaRegion.java | 18 +
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 11 +
.../apache/iotdb/db/client/ConfigNodeClient.java | 6 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 6 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 4 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 154 ++--
.../template/TemplateIsInUseException.java | 5 +-
.../exception/sql/StatementAnalyzeException.java | 4 +
.../iotdb/db/localconfignode/LocalConfigNode.java | 6 +-
.../iotdb/db/metadata/mnode/InternalMNode.java | 1 +
.../iotdb/db/metadata/mtree/ConfigMTree.java | 12 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 128 +++-
.../db/metadata/mtree/traverser/Traverser.java | 59 +-
.../traverser/collector/MeasurementCollector.java | 4 +-
.../traverser/counter/MeasurementCounter.java | 2 +-
.../db/metadata/schemaregion/ISchemaRegion.java | 9 +
.../schemaregion/SchemaRegionMemoryImpl.java | 64 +-
.../schemaregion/SchemaRegionSchemaFileImpl.java | 18 +
.../metadata/template/ClusterTemplateManager.java | 214 +++++-
.../db/metadata/template/ITemplateManager.java | 10 +
.../iotdb/db/metadata/template/Template.java | 72 +-
.../template/TemplateInternalRPCUpdateType.java | 68 ++
.../metadata/visitor/SchemaExecutionVisitor.java | 27 +
.../iotdb/db/mpp/common/MPPQueryContext.java | 36 +
.../iotdb/db/mpp/common/header/DatasetHeader.java | 2 +
.../iotdb/db/mpp/common/header/HeaderConstant.java | 12 +-
.../apache/iotdb/db/mpp/execution/QueryState.java | 1 +
.../iotdb/db/mpp/execution/QueryStateMachine.java | 15 +
.../fragment/FragmentInstanceExecution.java | 5 +-
.../fragment/FragmentInstanceManager.java | 16 +-
.../operator/process/AggregationOperator.java | 23 +-
.../operator/process/FilterAndProjectOperator.java | 193 +++++
.../execution/operator/process/FilterOperator.java | 243 -------
.../operator/process/TimeJoinOperator.java | 7 +-
.../schema/PathsUsingTemplateScanOperator.java | 61 ++
.../operator/schema/SchemaFetchScanOperator.java | 8 +-
.../schema/TimeSeriesSchemaScanOperator.java | 12 +-
.../execution/operator/source/SeriesScanUtil.java | 8 +-
.../db/mpp/execution/schedule/DriverScheduler.java | 9 +-
.../mpp/execution/schedule/IDriverScheduler.java | 3 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 45 +-
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 35 +
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 159 +++-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 63 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 115 ++-
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 18 +
.../iotdb/db/mpp/plan/analyze/ISchemaFetcher.java | 9 +
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 17 +
.../db/mpp/plan/analyze/cache/PartitionCache.java | 166 +++--
.../iotdb/db/mpp/plan/constant/StatementType.java | 2 +-
.../db/mpp/plan/execution/QueryExecution.java | 90 ++-
.../mpp/plan/execution/config/ShowClusterTask.java | 4 +-
.../plan/execution/config/ShowDataNodesTask.java | 19 +-
.../mpp/plan/execution/config/ShowRegionTask.java | 2 +-
.../config/executor/ClusterConfigTaskExecutor.java | 17 +-
.../memory/StatementMemorySourceVisitor.java | 17 +-
.../iotdb/db/mpp/plan/expression/Expression.java | 15 +
.../plan/expression/binary/AdditionExpression.java | 12 +
.../plan/expression/binary/BinaryExpression.java | 73 ++
.../plan/expression/binary/DivisionExpression.java | 12 +
.../plan/expression/binary/EqualToExpression.java | 11 +
.../expression/binary/GreaterEqualExpression.java | 12 +
.../expression/binary/GreaterThanExpression.java | 12 +
.../expression/binary/LessEqualExpression.java | 12 +
.../plan/expression/binary/LessThanExpression.java | 12 +
.../plan/expression/binary/LogicAndExpression.java | 11 +
.../plan/expression/binary/LogicOrExpression.java | 11 +
.../plan/expression/binary/ModuloExpression.java | 12 +
.../binary/MultiplicationExpression.java | 12 +
.../plan/expression/binary/NonEqualExpression.java | 12 +
.../expression/binary/SubtractionExpression.java | 12 +
.../mpp/plan/expression/leaf/ConstantOperand.java | 31 +
.../db/mpp/plan/expression/leaf/LeafOperand.java | 6 +
.../plan/expression/leaf/TimeSeriesOperand.java | 30 +
.../mpp/plan/expression/leaf/TimestampOperand.java | 29 +
.../plan/expression/multi/FunctionExpression.java | 104 ++-
.../plan/expression/ternary/BetweenExpression.java | 25 +
.../plan/expression/ternary/TernaryExpression.java | 92 +++
.../db/mpp/plan/expression/unary/InExpression.java | 9 +
.../plan/expression/unary/IsNullExpression.java | 14 +
.../mpp/plan/expression/unary/LikeExpression.java | 9 +
.../plan/expression/unary/LogicNotExpression.java | 9 +
.../plan/expression/unary/NegationExpression.java | 9 +
.../plan/expression/unary/RegularExpression.java | 9 +
.../mpp/plan/expression/unary/UnaryExpression.java | 60 ++
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 119 +--
.../db/mpp/plan/parser/StatementGenerator.java | 124 ++++
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 180 ++++-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 79 +-
.../db/mpp/plan/planner/LogicalPlanVisitor.java | 77 +-
.../SimpleFragmentParallelPlanner.java | 3 +-
.../plan/planner/distribution/SourceRewriter.java | 32 +-
.../distribution/WriteFragmentParallelPlanner.java | 3 +-
.../db/mpp/plan/planner/plan/FragmentInstance.java | 21 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 10 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 +
.../metedata/read/PathsUsingTemplateScanNode.java | 75 ++
.../node/metedata/read/SchemaFetchScanNode.java | 39 +-
.../metedata/read/TimeSeriesSchemaScanNode.java | 71 +-
.../node/metedata/write/ActivateTemplateNode.java | 154 ++++
.../planner/plan/node/process/AggregationNode.java | 12 +-
.../planner/plan/node/process/DeviceMergeNode.java | 44 +-
.../planner/plan/node/process/DeviceViewNode.java | 42 +-
.../plan/planner/plan/node/process/FillNode.java | 13 +-
.../plan/planner/plan/node/process/FilterNode.java | 8 +-
.../plan/node/process/GroupByLevelNode.java | 12 +-
.../plan/node/process/LastQueryMergeNode.java | 48 +-
.../node/process/SlidingWindowAggregationNode.java | 12 +-
.../plan/planner/plan/node/process/SortNode.java | 12 +-
.../planner/plan/node/process/TimeJoinNode.java | 12 +-
.../planner/plan/node/process/TransformNode.java | 12 +-
.../source/AlignedSeriesAggregationScanNode.java | 10 +-
.../plan/node/source/AlignedSeriesScanNode.java | 12 +-
.../node/source/SeriesAggregationScanNode.java | 10 +-
.../node/source/SeriesAggregationSourceNode.java | 6 +-
.../planner/plan/node/source/SeriesScanNode.java | 14 +-
.../planner/plan/parameter/OrderByParameter.java | 89 +++
.../db/mpp/plan/scheduler/ClusterScheduler.java | 17 +-
.../scheduler/FixedRateFragInsStateTracker.java | 12 +-
.../db/mpp/plan/statement/StatementVisitor.java | 11 +
.../plan/statement/component/OrderByComponent.java | 92 +++
.../component/{OrderBy.java => Ordering.java} | 22 +-
.../db/mpp/plan/statement/component/SortItem.java | 83 +++
.../db/mpp/plan/statement/component/SortKey.java | 21 +-
.../db/mpp/plan/statement/crud/QueryStatement.java | 62 +-
.../statement/internal/SchemaFetchStatement.java | 10 +-
.../template/ActivateTemplateStatement.java} | 35 +-
.../template/CreateSchemaTemplateStatement.java | 2 +-
.../template/SetSchemaTemplateStatement.java | 22 +-
.../template/ShowPathsUsingTemplateStatement.java} | 31 +-
.../mpp/transformation/dag/column/ColumnCache.java | 56 ++
.../dag/column/ColumnTransformer.java | 78 ++
.../ArithmeticAdditionColumnTransformer.java} | 25 +-
.../binary/ArithmeticBinaryColumnTransformer.java | 57 ++
.../ArithmeticDivisionColumnTransformer.java} | 25 +-
.../binary/ArithmeticModuloColumnTransformer.java} | 25 +-
...ArithmeticMultiplicationColumnTransformer.java} | 24 +-
.../ArithmeticSubtractionColumnTransformer.java} | 25 +-
.../dag/column/binary/BinaryColumnTransformer.java | 65 ++
.../binary/CompareBinaryColumnTransformer.java | 89 +++
.../binary/CompareEqualToColumnTransformer.java | 47 ++
.../CompareGreaterEqualColumnTransformer.java} | 25 +-
.../CompareGreaterThanColumnTransformer.java} | 25 +-
.../binary/CompareLessEqualColumnTransformer.java} | 21 +-
.../binary/CompareLessThanColumnTransformer.java} | 21 +-
.../binary/CompareNonEqualColumnTransformer.java | 47 ++
.../column/binary/LogicAndColumnTransformer.java} | 25 +-
.../binary/LogicBinaryColumnTransformer.java | 65 ++
.../column/binary/LogicOrColumnTransformer.java} | 25 +-
.../column/leaf/ConstantColumnTransformer.java} | 26 +-
.../column/leaf/IdentityColumnTransformer.java} | 31 +-
.../dag/column/leaf/LeafColumnTransformer.java} | 28 +-
.../dag/column/leaf/TimeColumnTransformer.java} | 20 +-
.../column/multi/MappableUDFColumnTransformer.java | 91 +++
.../column/ternary/BetweenColumnTransformer.java | 93 +++
.../ternary/CompareTernaryColumnTransformer.java | 74 ++
.../column/ternary/TernaryColumnTransformer.java | 44 ++
.../unary/ArithmeticNegationColumnTransformer.java | 51 ++
.../dag/column/unary/InColumnTransformer.java | 207 ++++++
.../dag/column/unary/IsNullColumnTransformer.java} | 29 +-
.../column/unary/LogicNotColumnTransformer.java | 52 ++
.../dag/column/unary/RegularColumnTransformer.java | 61 ++
.../dag/column/unary/UnaryColumnTransformer.java | 51 ++
.../dag/transformer/Transformer.java | 21 -
.../binary/CompareBinaryTransformer.java | 21 -
.../binary/CompareEqualToTransformer.java | 3 +-
.../binary/CompareGreaterEqualTransformer.java | 3 +-
.../binary/CompareGreaterThanTransformer.java | 3 +-
.../binary/CompareLessEqualTransformer.java | 3 +-
.../binary/CompareLessThanTransformer.java | 3 +-
.../binary/CompareNonEqualTransformer.java | 3 +-
.../transformer/ternary/BetweenTransformer.java | 5 +-
.../mpp/transformation/dag/udf/UDTFExecutor.java | 29 +-
...eInferrer.java => UDTFInformationInferrer.java} | 64 +-
.../transformation/dag/util/TransformUtils.java | 99 +++
.../mpprest/impl/GrafanaApiServiceImpl.java | 26 +-
.../protocol/mpprest/impl/RestApiServiceImpl.java | 14 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 5 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 8 +-
.../org/apache/iotdb/db/qp/logical/Operator.java | 2 +
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 7 +-
.../sys/ActivateTemplateInClusterPlan.java | 110 +++
.../db/qp/physical/sys/ShowTimeSeriesPlan.java | 12 +
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 56 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 108 +--
.../db/service/DataNodeServerCommandLine.java | 120 ++-
.../iotdb/db/service/RegionMigrateService.java | 15 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 207 +++++-
.../impl/DataNodeInternalRPCServiceImpl.java | 33 +
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 4 +
.../org/apache/iotdb/db/utils/SchemaUtils.java | 6 +-
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 44 +-
.../db/engine/storagegroup/DataRegionTest.java | 85 ++-
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 5 +-
.../iotdb/db/metadata/mtree/ConfigMTreeTest.java | 3 +-
.../iotdb/db/mpp/execution/DataDriverTest.java | 4 +-
.../operator/AggregationOperatorTest.java | 54 +-
.../operator/AlignedSeriesScanOperatorTest.java | 6 +-
.../mpp/execution/operator/LimitOperatorTest.java | 4 +-
.../mpp/execution/operator/OffsetOperatorTest.java | 8 +-
.../operator/RawDataAggregationOperatorTest.java | 4 +-
.../execution/operator/TimeJoinOperatorTest.java | 8 +-
.../schema/SchemaFetchScanOperatorTest.java | 2 +-
.../schema/SchemaQueryScanOperatorTest.java | 4 +-
.../execution/schedule/DriverSchedulerTest.java | 9 +-
.../db/mpp/plan/StandaloneCoordinatorTest.java | 9 +-
.../mpp/plan/analyze/cache/PartitionCacheTest.java | 432 +++++++++++
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 20 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 149 ++--
.../distribution/AggregationDistributionTest.java | 34 +-
.../distribution/DistributionPlannerBasicTest.java | 42 +-
.../mpp/plan/plan/distribution/LastQueryTest.java | 3 +-
.../distribution/NoDataRegionPlanningTest.java | 20 +-
.../metadata/read/SchemaFetchScanNodeTest.java | 4 +-
.../node/process/AggregationNodeSerdeTest.java | 6 +-
.../plan/node/process/DeviceViewNodeSerdeTest.java | 16 +-
.../plan/node/process/ExchangeNodeSerdeTest.java | 5 +-
.../plan/plan/node/process/FillNodeSerdeTest.java | 7 +-
.../plan/node/process/FilterNodeSerdeTest.java | 7 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 8 +-
.../plan/plan/node/process/LimitNodeSerdeTest.java | 4 +-
.../plan/node/process/OffsetNodeSerdeTest.java | 4 +-
.../plan/plan/node/process/SortNodeSerdeTest.java | 7 +-
.../plan/node/process/TimeJoinNodeSerdeTest.java | 9 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 4 +-
.../plan/node/source/SeriesScanNodeSerdeTest.java | 4 +-
.../plan/scheduler/StandaloneSchedulerTest.java | 15 +-
.../main/java/org/apache/iotdb/session/Config.java | 2 +
.../java/org/apache/iotdb/session/Session.java | 21 +-
.../apache/iotdb/session/SessionConnection.java | 15 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 5 +-
thrift-commons/src/main/thrift/common.thrift | 21 -
.../src/main/thrift/confignode.thrift | 66 +-
thrift/src/main/thrift/client.thrift | 3 +
thrift/src/main/thrift/datanode.thrift | 17 +
.../iotdb/tsfile/read/common/type/BinaryType.java | 39 +-
.../iotdb/tsfile/read/common/type/BooleanType.java | 39 +-
.../iotdb/tsfile/read/common/type/DoubleType.java | 85 +++
.../iotdb/tsfile/read/common/type/FloatType.java | 85 +++
.../iotdb/tsfile/read/common/type/IntType.java | 85 +++
.../iotdb/tsfile/read/common/type/LongType.java | 85 +++
.../apache/iotdb/tsfile/read/common/type/Type.java | 104 +++
.../iotdb/tsfile/read/common/type/TypeEnum.java | 27 +-
.../iotdb/tsfile/read/common/type/TypeFactory.java | 33 +-
340 files changed, 9982 insertions(+), 4216 deletions(-)
copy confignode/src/main/java/org/apache/iotdb/confignode/client/async/handlers/{UpdateRegionRouteMapHandler.java => UpdateConfigNodeGroupHandler.java} (74%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/{write/SetSchemaTemplatePlan.java => read/template/CheckTemplateSettablePlan.java} (79%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetSchemaTemplatePlan.java => template/GetAllSchemaTemplatePlan.java} (71%)
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetSchemaTemplatePlan.java => template/GetAllTemplateSetInfoPlan.java} (71%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{ => template}/GetPathsSetTemplatePlan.java (96%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/{GetNodesInSchemaTemplatePlan.java => template/GetSchemaTemplatePlan.java} (67%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{ => template}/CreateSchemaTemplatePlan.java (73%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/{ => template}/SetSchemaTemplatePlan.java (96%)
copy server/src/main/java/org/apache/iotdb/db/exception/metadata/template/TemplateIsInUseException.java => confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/AllTemplateSetInfoResp.java (64%)
delete mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/manager/DataNodeRemoveManager.java
rename confignode/src/main/java/org/apache/iotdb/confignode/persistence/{ => schema}/ClusterSchemaInfo.java (85%)
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/env/DataNodeRemoveHandler.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/AbstractNodeProcedure.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/RegionMigrateProcedure.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/RemoveDataNodeProcedure.java
create mode 100644 confignode/src/main/java/org/apache/iotdb/confignode/procedure/scheduler/LockQueue.java
copy confignode/src/main/java/org/apache/iotdb/confignode/{client/DataNodeRequestType.java => procedure/state/RegionTransitionState.java} (71%)
copy confignode/src/main/java/org/apache/iotdb/confignode/{client/DataNodeRequestType.java => procedure/state/RemoveDataNodeState.java} (70%)
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/IoTDBInsertWithoutTimeIT.java
create mode 100644 integration-test/src/test/java/org/apache/iotdb/db/it/schema/IoTDBSchemaTemplateIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBInsertWithoutTimeIT.java
delete mode 100644 integration/src/test/java/org/apache/iotdb/db/integration/IoTDBUDTFAlignByTimeQueryIT.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/metadata/template/TemplateInternalRPCUpdateType.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/FilterAndProjectOperator.java
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/process/FilterOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/execution/operator/schema/PathsUsingTemplateScanOperator.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/read/PathsUsingTemplateScanNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/metedata/write/ActivateTemplateNode.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/parameter/OrderByParameter.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/OrderByComponent.java
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/{OrderBy.java => Ordering.java} (70%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/SortItem.java
copy confignode/src/main/java/org/apache/iotdb/confignode/client/DataNodeRequestType.java => server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/SortKey.java (70%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{internal/SchemaFetchStatement.java => metadata/template/ActivateTemplateStatement.java} (63%)
copy server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{internal/SchemaFetchStatement.java => metadata/template/ShowPathsUsingTemplateStatement.java} (59%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/ColumnCache.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/ColumnTransformer.java
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/expression/leaf/LeafOperand.java => transformation/dag/column/binary/ArithmeticAdditionColumnTransformer.java} (59%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/binary/ArithmeticBinaryColumnTransformer.java
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/expression/leaf/LeafOperand.java => transformation/dag/column/binary/ArithmeticDivisionColumnTransformer.java} (59%)
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/expression/leaf/LeafOperand.java => transformation/dag/column/binary/ArithmeticModuloColumnTransformer.java} (59%)
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/expression/leaf/LeafOperand.java => transformation/dag/column/binary/ArithmeticMultiplicationColumnTransformer.java} (59%)
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/expression/leaf/LeafOperand.java => transformation/dag/column/binary/ArithmeticSubtractionColumnTransformer.java} (59%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/binary/BinaryColumnTransformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/binary/CompareBinaryColumnTransformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/binary/CompareEqualToColumnTransformer.java
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/expression/leaf/LeafOperand.java => transformation/dag/column/binary/CompareGreaterEqualColumnTransformer.java} (59%)
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/expression/leaf/LeafOperand.java => transformation/dag/column/binary/CompareGreaterThanColumnTransformer.java} (59%)
copy server/src/main/java/org/apache/iotdb/db/{exception/metadata/template/TemplateIsInUseException.java => mpp/transformation/dag/column/binary/CompareLessEqualColumnTransformer.java} (59%)
copy server/src/main/java/org/apache/iotdb/db/{exception/metadata/template/TemplateIsInUseException.java => mpp/transformation/dag/column/binary/CompareLessThanColumnTransformer.java} (59%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/binary/CompareNonEqualColumnTransformer.java
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/expression/leaf/LeafOperand.java => transformation/dag/column/binary/LogicAndColumnTransformer.java} (59%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/binary/LogicBinaryColumnTransformer.java
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/expression/leaf/LeafOperand.java => transformation/dag/column/binary/LogicOrColumnTransformer.java} (59%)
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/expression/leaf/LeafOperand.java => transformation/dag/column/leaf/ConstantColumnTransformer.java} (55%)
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/expression/leaf/LeafOperand.java => transformation/dag/column/leaf/IdentityColumnTransformer.java} (54%)
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/expression/leaf/LeafOperand.java => transformation/dag/column/leaf/LeafColumnTransformer.java} (60%)
copy server/src/main/java/org/apache/iotdb/db/{exception/metadata/template/TemplateIsInUseException.java => mpp/transformation/dag/column/leaf/TimeColumnTransformer.java} (65%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/multi/MappableUDFColumnTransformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/ternary/BetweenColumnTransformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/ternary/CompareTernaryColumnTransformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/ternary/TernaryColumnTransformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/ArithmeticNegationColumnTransformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/InColumnTransformer.java
copy server/src/main/java/org/apache/iotdb/db/mpp/{plan/expression/leaf/LeafOperand.java => transformation/dag/column/unary/IsNullColumnTransformer.java} (50%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/LogicNotColumnTransformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/RegularColumnTransformer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/column/unary/UnaryColumnTransformer.java
rename server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/udf/{UDTFTypeInferrer.java => UDTFInformationInferrer.java} (53%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/transformation/dag/util/TransformUtils.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/sys/ActivateTemplateInClusterPlan.java
create mode 100644 server/src/test/java/org/apache/iotdb/db/mpp/plan/analyze/cache/PartitionCacheTest.java
copy confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetSchemaTemplatePlan.java => tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/BinaryType.java (50%)
rename confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/read/GetSchemaTemplatePlan.java => tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/BooleanType.java (51%)
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/DoubleType.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/FloatType.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/IntType.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/LongType.java
create mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/Type.java
copy confignode/src/main/java/org/apache/iotdb/confignode/client/DataNodeRequestType.java => tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/TypeEnum.java (70%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/component/OrderBy.java => tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/type/TypeFactory.java (54%)