This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/maven/master/metrics.version-4.2.10
in repository https://gitbox.apache.org/repos/asf/iotdb.git
discard 6d921e341b Bump metrics.version from 4.2.7 to 4.2.10
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 2fa21ee9ab Bump metrics.version from 4.2.7 to 4.2.10
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 (6d921e341b)
\
N -- N -- N
refs/heads/dependabot/maven/master/metrics.version-4.2.10 (2fa21ee9ab)
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%)
