This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/addQueryIT
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ab071d105d move IoTDBAliasIT & IoTDBAsIT to newIT
add 0422d48006 [IOTDB-3470] [IOTDB-3471] Add some semantic checks for
InsertStatement (#6298)
add d417b3d6d2 [IOTDB-3505] The region dirs are not deleted when the
storage group is deleted in MultiLeaderConsensus (#6297)
add 149d88e7bf Improve auto create schema (#6295)
add 473070e9c6 [IOTDB-3182] Judge DataNode status through heartbeat(Simple
version) (#6285)
add 1147668b15 [IOTDB-3500] Fix delete storage group failure in new
standable IoTDB (#6302)
add 99279e0352 [IOTDB-3491] Assign an unique id to each ConfigNode (#6287)
add 9562161613 [IOTDB-3433] add metric for cluster. (#6291)
add 3b785c80ca [IOTDB-3449] Fix case sensitive bug of aggregation function
name (#6253)
add 18a514c384 [IOTDB-3456] Optimize PathPattarnTree for improving write
performance (#6294)
add 0ae9985eb2 [IOTDB-3436] Add IT for aggregation, groupby and align by
device query in MPP (#6207)
add a438aaeaaa Change meaning of Flush to Flush on Cluster (#6314)
add ed439a4c4a rest java example (#6274)
add a350004421 rest services add clientAuth (#4965)
add a920737417 [IOTDB-3515] load empty TsFile error message (#6307)
add 65413a28e7 [IOTDB-3323][IOTDB-3506] Support MQTT for MPP framework
(#6311)
add 2313d99c36 [IOTDB-3482] Add IT for UDF management in new Cluster
(#6290)
add 54d0720188 uncomment the data_block_manager_port and change default
data region to StandAlone Consensus (#6317)
add cba438a413 Print sql and corresponding QueryId (#6319)
add 462c0c2c8c [IOTDB-3438] Fix empty WAL file (#6312)
new 2d43e6476b Merge remote-tracking branch 'origin/master' into
lmh/addQueryIT
new 24777acae1 move IoTDBLimitSlimitIT & IoTDBPathNumOverLimitIT to newIT
new 8e852d2b47 move IoTDBResultMetadataIT & IoTDBResultSetIT to newIT
new 8c1cd0799e use executeQuery
The 4 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:
.../resources/conf/iotdb-confignode.properties | 2 +-
.../client/ConfigNodeClientPoolFactory.java | 4 +-
.../client/handlers/HeartbeatHandler.java | 1 -
.../{ConfigNodeConf.java => ConfigNodeConfig.java} | 8 +-
.../confignode/conf/ConfigNodeDescriptor.java | 4 +-
.../confignode/conf/ConfigNodeStartupCheck.java | 4 +-
.../iotdb/confignode/manager/ConfigManager.java | 14 +-
.../iotdb/confignode/manager/ConsensusManager.java | 8 +-
.../apache/iotdb/confignode/manager/Manager.java | 2 +
.../iotdb/confignode/manager/NodeManager.java | 8 +-
.../iotdb/confignode/manager/PartitionManager.java | 8 +-
.../iotdb/confignode/manager/ProcedureManager.java | 11 +-
.../iotdb/confignode/manager/load/LoadManager.java | 83 +-
.../manager/load/heartbeat/HeartbeatCache.java | 74 +-
.../manager/load/heartbeat/HeartbeatPackage.java | 1 +
.../manager/load/heartbeat/HeartbeatWindow.java | 51 -
.../load/heartbeat/IHeartbeatStatistic.java | 19 +-
.../iotdb/confignode/persistence/NodeInfo.java | 74 +-
.../iotdb/confignode/persistence/UDFInfo.java | 4 +-
.../persistence/partition/PartitionInfo.java | 124 +-
.../partition/StorageGroupPartitionTable.java | 85 +-
.../iotdb/confignode/service/ConfigNode.java | 11 +-
.../service/thrift/ConfigNodeRPCService.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessor.java | 2 +-
.../consensus/request/ConfigRequestSerDeTest.java | 2 +-
.../iotdb/confignode/persistence/NodeInfoTest.java | 4 +-
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 33 +-
.../multileader/MultiLeaderConsensus.java | 10 +-
.../consensus/standalone/StandAloneConsensus.java | 10 +-
.../{standalone => }/EmptyStateMachine.java | 3 +-
.../{standalone => multileader}/RecoveryTest.java | 16 +-
.../iotdb/consensus/standalone/RecoveryTest.java | 1 +
.../standalone/StandAloneConsensusTest.java | 1 +
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 26 +-
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 26 +-
example/{rabbitmq => rest-java-example}/pom.xml | 28 +-
.../main/java/org/apache/iotdb/HttpExample.java | 141 +
.../main/java/org/apache/iotdb/HttpsExample.java | 144 +
.../src/main/java/org/apache/iotdb/SSLClient.java | 83 +
...Apache IoTDB ConfigNode Dashboard v0.14.0.json} | 802 ++----
.../Apache IoTDB DataNode Dashboard v0.14.0.json} | 107 +-
.../Apache IoTDB Dashboard v0.13.1.json | 0
.../Apache IoTDB Dashboard v0.14.0.json | 0
integration-test/import-control.xml | 23 +-
.../org/apache/iotdb/itbase/env/BaseConfig.java | 4 +
...regationWithoutValueFilterWithDeletion2IT.java} | 11 +-
...ggregationWithoutValueFilterWithDeletionIT.java | 177 +-
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 2748 ++++++++++++++++++++
...pByQueryWithoutValueFilterWithDeletion2IT.java} | 12 +-
...oupByQueryWithoutValueFilterWithDeletionIT.java | 260 +-
.../db/it/aligned/IoTDBInsertAlignedValuesIT.java | 25 +-
.../org/apache/iotdb/db/it/query/IoTDBAliasIT.java | 159 +-
.../iotdb/db/it/query/IoTDBPaginationIT.java | 50 +-
.../iotdb/db/it/query}/IoTDBResultSetIT.java | 89 +-
.../db/it/udf/BuiltinAggregationFunctionEnum.java | 13 +-
.../BuiltinTimeSeriesGeneratingFunctionEnum.java | 87 +
.../iotdb/db/it/udf/IoTDBUDFManagementIT.java | 336 +++
.../it/{ => udf}/IoTDBUDTFBuiltinFunctionIT.java | 20 +-
.../db/integration/IoTDBPathNumOverLimitIT.java | 74 -
.../db/integration/IoTDBResultMetadataIT.java | 1 -
.../iotdb/db/integration/IoTDBResultSetIT.java | 41 +-
.../IoTDBSyntaxConventionIdentifierIT.java | 5 +
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 398 ---
.../IoTDBAggregationWithoutValueFilter2IT.java | 65 -
.../IoTDBAggregationWithoutValueFilterIT.java | 456 ----
...gregationWithoutValueFilterWithDeletion2IT.java | 82 -
.../integration/aligned/IoTDBAlignByDevice2IT.java | 67 -
.../integration/aligned/IoTDBAlignByDeviceIT.java | 1623 ------------
.../IoTDBGroupByQueryWithoutValueFilter2IT.java | 65 -
.../IoTDBGroupByQueryWithoutValueFilterIT.java | 1128 --------
...upByQueryWithoutValueFilterWithDeletion2IT.java | 77 -
.../apache/iotdb/commons/cluster/NodeStatus.java | 21 +-
.../org/apache/iotdb/commons/utils/FileUtils.java | 2 +-
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 6 +-
.../iotdb/commons/utils/NodeUrlUtilsTest.java | 8 +-
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 3 +-
.../resources/conf/iotdb-engine.properties | 2 +-
.../assembly/resources/conf/iotdb-rest.properties | 3 +
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 11 +
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 3 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 2 +-
.../iotdb/db/engine/storagegroup/DataRegion.java | 13 +-
....java => MeasurementAlreadyExistException.java} | 14 +-
.../iotdb/db/localconfignode/LocalConfigNode.java | 4 +-
.../localconfignode/LocalDataPartitionTable.java | 8 +-
.../iotdb/db/metadata/LocalSchemaProcessor.java | 5 +-
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 19 +-
.../db/metadata/schemaregion/SchemaEngine.java | 4 +-
.../metadata/visitor/SchemaExecutionVisitor.java | 163 +-
.../iotdb/db/mpp/aggregation/AvgAccumulator.java | 3 +
.../iotdb/db/mpp/aggregation/CountAccumulator.java | 3 +
.../db/mpp/aggregation/ExtremeAccumulator.java | 3 +
.../db/mpp/aggregation/FirstValueAccumulator.java | 3 +
.../db/mpp/aggregation/LastValueAccumulator.java | 3 +
.../db/mpp/aggregation/MaxTimeAccumulator.java | 3 +
.../db/mpp/aggregation/MaxValueAccumulator.java | 3 +
.../db/mpp/aggregation/MinTimeAccumulator.java | 3 +
.../db/mpp/aggregation/MinValueAccumulator.java | 3 +
.../iotdb/db/mpp/aggregation/SumAccumulator.java | 3 +
.../iotdb/db/mpp/common/header/DatasetHeader.java | 4 +
.../db/mpp/common/schematree/PathPatternTree.java | 276 +-
.../execution/datatransfer/DataBlockManager.java | 6 +-
.../operator/schema/SchemaFetchScanOperator.java | 2 +-
.../AlignedSeriesAggregationScanOperator.java | 10 +-
.../source/SeriesAggregationScanOperator.java | 8 +-
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 3 +
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 104 +-
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 4 +-
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 141 +-
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 16 +-
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 20 +-
.../iotdb/db/mpp/plan/constant/StatementType.java | 3 +-
.../mpp/plan/execution/config/ConfigExecution.java | 4 +-
.../db/mpp/plan/execution/config/FlushTask.java | 6 +-
.../mpp/plan/execution/config/ShowClusterTask.java | 5 +-
...utor.java => StandaloneConfigTaskExecutor.java} | 14 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 12 +-
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 31 +-
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 30 +-
.../plan/planner/distribution/SourceRewriter.java | 6 +-
.../mpp/plan/planner/plan/node/PlanNodeType.java | 6 +-
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 5 +
.../write/InternalCreateTimeSeriesNode.java} | 125 +-
.../source/AlignedSeriesAggregationScanNode.java | 2 +-
.../plan/parameter/AggregationDescriptor.java | 65 +-
.../plan/parameter/GroupByLevelDescriptor.java | 7 +-
.../db/mpp/plan/scheduler/ClusterScheduler.java | 20 +-
.../db/mpp/plan/statement/StatementVisitor.java | 8 +-
.../mpp/plan/statement/crud/InsertStatement.java | 29 +
.../InternalCreateTimeSeriesStatement.java} | 40 +-
.../statement/internal/SchemaFetchStatement.java | 2 +-
.../db/mpp/plan/statement/sys/FlushStatement.java | 13 +-
...{PublishHandler.java => MPPPublishHandler.java} | 75 +-
.../apache/iotdb/db/protocol/rest/RestService.java | 13 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 16 +-
.../org/apache/iotdb/db/service/MQTTService.java | 12 +-
.../iotdb/db/service/metrics/enums/Metric.java | 7 +-
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 8 +-
.../org/apache/iotdb/db/wal/buffer/IWALBuffer.java | 3 +
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 30 +-
.../org/apache/iotdb/db/wal/io/ILogWriter.java | 3 +-
.../java/org/apache/iotdb/db/wal/io/LogWriter.java | 3 +-
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 19 +-
.../mpp/common/schematree/PathPatternTreeTest.java | 10 +-
.../schema/SchemaFetchScanOperatorTest.java | 4 +-
.../plan/analyze/AggregationDescriptorTest.java | 20 +-
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 90 +-
.../distribution/AggregationDistributionTest.java | 24 +-
.../metadata/read/SchemaFetchScanNodeTest.java | 9 +-
.../node/process/AggregationNodeSerdeTest.java | 36 +-
.../node/process/GroupByLevelNodeSerdeTest.java | 6 +-
.../source/SeriesAggregationScanNodeSerdeTest.java | 2 +-
.../iotdb/db/protocol/mqtt/PublishHandlerTest.java | 7 +-
server/src/test/resources/iotdb-rest.properties | 3 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
session/src/test/resources/iotdb-rest.properties | 3 +
thrift-commons/src/main/thrift/common.thrift | 13 +-
157 files changed, 5779 insertions(+), 6125 deletions(-)
rename
confignode/src/main/java/org/apache/iotdb/confignode/conf/{ConfigNodeConf.java
=> ConfigNodeConfig.java} (98%)
delete mode 100644
confignode/src/main/java/org/apache/iotdb/confignode/manager/load/heartbeat/HeartbeatWindow.java
rename consensus/src/test/java/org/apache/iotdb/consensus/{standalone =>
}/EmptyStateMachine.java (94%)
copy consensus/src/test/java/org/apache/iotdb/consensus/{standalone =>
multileader}/RecoveryTest.java (88%)
copy example/{rabbitmq => rest-java-example}/pom.xml (72%)
create mode 100644
example/rest-java-example/src/main/java/org/apache/iotdb/HttpExample.java
create mode 100644
example/rest-java-example/src/main/java/org/apache/iotdb/HttpsExample.java
create mode 100644
example/rest-java-example/src/main/java/org/apache/iotdb/SSLClient.java
copy grafana-metrics-example/{Apache IoTDB Dashboard v0.13.1.json =>
cluster/Apache IoTDB ConfigNode Dashboard v0.14.0.json} (71%)
copy grafana-metrics-example/{Apache IoTDB Dashboard v0.13.1.json =>
cluster/Apache IoTDB DataNode Dashboard v0.14.0.json} (97%)
rename grafana-metrics-example/{ => standalone}/Apache IoTDB Dashboard
v0.13.1.json (100%)
rename grafana-metrics-example/{ => standalone}/Apache IoTDB Dashboard
v0.14.0.json (100%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithDeletion2IT.java
=> IoTDBAggregationWithoutValueFilterWithDeletion2IT.java} (92%)
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/aligned/IoTDBAggregationWithoutValueFilterWithDeletionIT.java
(65%)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/aligned/{IoTDBLastQueryWithDeletion2IT.java
=> IoTDBGroupByQueryWithoutValueFilterWithDeletion2IT.java} (91%)
rename {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it}/aligned/IoTDBGroupByQueryWithoutValueFilterWithDeletionIT.java
(82%)
rename
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBLimitSlimitIT.java
=>
integration-test/src/test/java/org/apache/iotdb/db/it/query/IoTDBPaginationIT.java
(83%)
copy {integration/src/test/java/org/apache/iotdb/db/integration =>
integration-test/src/test/java/org/apache/iotdb/db/it/query}/IoTDBResultSetIT.java
(58%)
copy
node-commons/src/main/java/org/apache/iotdb/commons/udf/builtin/BuiltinAggregationFunction.java
=>
integration-test/src/test/java/org/apache/iotdb/db/it/udf/BuiltinAggregationFunctionEnum.java
(79%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/udf/BuiltinTimeSeriesGeneratingFunctionEnum.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/udf/IoTDBUDFManagementIT.java
rename integration-test/src/test/java/org/apache/iotdb/db/it/{ =>
udf}/IoTDBUDTFBuiltinFunctionIT.java (99%)
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBPathNumOverLimitIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/IoTDBUDFManagementIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithoutValueFilter2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithoutValueFilterIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAggregationWithoutValueFilterWithDeletion2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAlignByDevice2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBAlignByDeviceIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithoutValueFilter2IT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithoutValueFilterIT.java
delete mode 100644
integration/src/test/java/org/apache/iotdb/db/integration/aligned/IoTDBGroupByQueryWithoutValueFilterWithDeletion2IT.java
copy
server/src/main/java/org/apache/iotdb/db/service/basic/BasicOpenSessionResp.java
=> node-commons/src/main/java/org/apache/iotdb/commons/cluster/NodeStatus.java
(73%)
copy
server/src/main/java/org/apache/iotdb/db/exception/metadata/{PathAlreadyExistException.java
=> MeasurementAlreadyExistException.java} (70%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/execution/config/executor/{StandsloneConfigTaskExecutor.java
=> StandaloneConfigTaskExecutor.java} (95%)
copy
server/src/main/java/org/apache/iotdb/db/mpp/plan/planner/plan/node/{source/AlignedLastQueryScanNode.java
=> metedata/write/InternalCreateTimeSeriesNode.java} (50%)
rename
server/src/main/java/org/apache/iotdb/db/mpp/plan/statement/{metadata/CreateTimeSeriesByDeviceStatement.java
=> internal/InternalCreateTimeSeriesStatement.java} (63%)
copy
server/src/main/java/org/apache/iotdb/db/protocol/mqtt/{PublishHandler.java =>
MPPPublishHandler.java} (59%)
