You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by hu...@apache.org on 2022/12/24 07:08:53 UTC
[iotdb] branch lmh/removeOldCode updated (479a42b496 -> dce2fe5e9f)
This is an automated email from the ASF dual-hosted git repository.
hui pushed a change to branch lmh/removeOldCode
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 479a42b496 fix IoTDBInfluxDBIT
add acab84d53a fix code smell test
add b203af5e33 [IOTDB-5127]Separate ISession and ISessionPool as a module (#8583)
add fd52a2f378 [IOTDB-5269] Fix PathPatternTree.getAllDevicePatterns (#8589)
add 9b4e8eda57 remove (#8597)
add 424528495c Turn down the max capacity of tsblock from scanOperator (#8599)
add 0e1dd1b8a2 Refine the inner structure of ClusterSchemaFetcher (#8603)
add dce2fe5e9f Merge remote-tracking branch 'origin/master' into lmh/removeOldCode
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 2 +-
.../java/org/apache/iotdb/tool/ExportTsFile.java | 2 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 8 +-
.../iotdb/consensus/ratis/RatisConsensusTest.java | 8 +-
.../iotdb/AlignedTimeseriesSessionExample.java | 4 +-
.../org/apache/iotdb/DataMigrationExample.java | 4 +-
.../iotdb/HybridTimeseriesSessionExample.java | 2 +-
.../org/apache/iotdb/SessionConcurrentExample.java | 2 +-
.../main/java/org/apache/iotdb/SessionExample.java | 8 +-
.../java/org/apache/iotdb/SessionPoolExample.java | 4 +-
.../iotdb/SyntaxConventionRelatedExample.java | 4 +-
.../java/org/apache/iotdb/flink/IoTDBSource.java | 2 +-
.../iotdb/influxdb/session/InfluxDBSession.java | 2 +-
integration-test/import-control.xml | 2 +
.../java/org/apache/iotdb/it/env/AbstractEnv.java | 4 +-
.../org/apache/iotdb/it/env/RemoteServerEnv.java | 2 +-
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 6 +-
.../org/apache/iotdb/db/it/env/StandaloneEnv.java | 6 +-
.../iotdb/session/it/IoTDBConnectionInfoIT.java | 2 +-
.../session/it/IoTDBSessionAlignedInsertIT.java | 4 +-
.../iotdb/session/it/IoTDBSessionComplexIT.java | 4 +-
.../it/IoTDBSessionDisableMemControlIT.java | 4 +-
.../iotdb/session/it/IoTDBSessionInsertNullIT.java | 4 +-
.../IoTDBSessionInsertWithTriggerExecutionIT.java | 2 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 6 +-
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 4 +-
.../session/it/IoTDBSessionSyntaxConventionIT.java | 4 +-
.../org/apache/iotdb/session/it/SessionIT.java | 4 +-
.../iotdb/session/it/pool/SessionPoolIT.java | 6 +-
.../org/apache/iotdb/tools/ExportCsvTestIT.java | 2 +-
.../org/apache/iotdb/tools/ExportTsFileTestIT.java | 2 +-
.../session/IoTDBSessionAlignedABDeviceIT.java | 1 +
.../session/IoTDBSessionAlignedAggregationIT.java | 1 +
.../IoTDBSessionAlignedAggregationWithUnSeqIT.java | 1 +
.../iotdb/session/IoTDBSessionIteratorIT.java | 3 +-
{example/tsfile => isession}/pom.xml | 10 +-
.../java/org/apache/iotdb/isession}/ISession.java | 42 +-
.../org/apache/iotdb/isession}/SessionConfig.java | 4 +-
.../org/apache/iotdb/isession}/SessionDataSet.java | 2 +-
.../apache/iotdb/isession/pool/ISessionPool.java | 388 +++++++------
.../isession}/pool/SessionDataSetWrapper.java | 29 +-
.../apache/iotdb/isession}/template/Template.java | 2 +-
.../iotdb/isession}/template/TemplateNode.java | 2 +-
.../apache/iotdb/isession/util/SystemStatus.java | 24 +-
.../org/apache/iotdb/isession}/util/Version.java | 2 +-
.../reporter/iotdb/SessionIoTDBReporter.java | 2 +-
.../resources/conf/iotdb-common.properties | 2 +-
.../apache/iotdb/commons/path/PathPatternTree.java | 4 +
.../iotdb/commons/path/PathPatternTreeTest.java | 5 +-
pom.xml | 1 +
.../iotdb/db/client/DataNodeInternalClient.java | 4 +-
.../{SQLConstant.java => SqlConstant.java} | 6 +-
.../db/metadata/cache/DataNodeSchemaCache.java | 4 -
.../iotdb/db/mpp/common/DataNodeEndPoints.java | 5 +
.../execution/executor/RegionWriteExecutor.java | 2 +-
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 12 +
.../execution/operator/source/SeriesScanUtil.java | 7 -
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 2 +-
.../iotdb/db/mpp/plan/analyze/AnalyzeVisitor.java | 38 +-
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 2 +
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 599 ---------------------
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 10 +-
.../analyze/schema/AutoCreateSchemaExecutor.java | 230 ++++++++
.../analyze/schema/ClusterSchemaFetchExecutor.java | 207 +++++++
.../plan/analyze/schema/ClusterSchemaFetcher.java | 354 ++++++++++++
.../plan/analyze/{ => schema}/ISchemaFetcher.java | 2 +-
.../plan/analyze/{ => schema}/SchemaValidator.java | 2 +-
.../db/mpp/plan/execution/QueryExecution.java | 2 +-
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 120 ++---
.../{SQLParseError.java => SqlParseError.java} | 5 +-
.../db/mpp/plan/parser/StatementGenerator.java | 12 +-
...fluxSQLConstant.java => InfluxSqlConstant.java} | 6 +-
.../influxdb/function/InfluxFunctionFactory.java | 24 +-
.../function/aggregator/InfluxCountFunction.java | 4 +-
.../function/aggregator/InfluxMeanFunction.java | 4 +-
.../function/aggregator/InfluxMedianFunction.java | 4 +-
.../function/aggregator/InfluxModeFunction.java | 4 +-
.../function/aggregator/InfluxSpreadFunction.java | 4 +-
.../function/aggregator/InfluxStddevFunction.java | 4 +-
.../function/aggregator/InfluxSumFunction.java | 4 +-
.../function/selector/InfluxFirstFunction.java | 4 +-
.../function/selector/InfluxLastFunction.java | 4 +-
.../function/selector/InfluxMaxFunction.java | 4 +-
.../function/selector/InfluxMinFunction.java | 4 +-
.../influxdb/handler/AbstractQueryHandler.java | 22 +-
.../protocol/influxdb/handler/NewQueryHandler.java | 20 +-
.../influxdb/parser/InfluxDBAstVisitor.java | 6 +-
.../parser/InfluxDBStatementGenerator.java | 11 +-
.../influxdb/statement/InfluxQueryStatement.java | 1 +
.../influxdb/statement/InfluxSelectComponent.java | 9 +-
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 4 +-
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 4 +-
.../db/protocol/rest/impl/RestApiServiceImpl.java | 4 +-
.../db/service/metrics/IoTDBInternalReporter.java | 4 +-
.../service/thrift/impl/ClientRPCServiceImpl.java | 4 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 4 +-
.../java/org/apache/iotdb/db/sync/SyncService.java | 2 +-
.../iotdb/db/sync/pipedata/load/ILoader.java | 4 +-
.../db/sync/transport/server/ReceiverManager.java | 2 +-
.../org/apache/iotdb/db/utils/CommonUtils.java | 10 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 20 +-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 46 +-
.../db/wal/recover/file/TsFilePlanRedoer.java | 2 +-
.../db/mpp/execution/exchange/SinkHandleTest.java | 4 +-
.../mpp/execution/operator/OperatorMemoryTest.java | 10 +-
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 1 +
.../iotdb/db/mpp/plan/plan/distribution/Util.java | 2 +-
.../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 10 +-
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 12 +-
session/pom.xml | 6 +
.../java/org/apache/iotdb/session/Session.java | 10 +-
.../apache/iotdb/session/SessionConnection.java | 2 +
.../org/apache/iotdb/session/pool/SessionPool.java | 309 +++++++----
.../iotdb/session/template/InternalNode.java | 1 +
.../iotdb/session/template/MeasurementNode.java | 1 +
.../apache/iotdb/session/SessionCacheLeaderUT.java | 1 +
.../test/java/org/apache/iotdb/db/sql/Cases.java | 2 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 4 +-
.../tsfile/read/common/block/TsBlockBuilder.java | 2 +-
119 files changed, 1651 insertions(+), 1249 deletions(-)
copy {example/tsfile => isession}/pom.xml (86%)
copy {session/src/main/java/org/apache/iotdb/session => isession/src/main/java/org/apache/iotdb/isession}/ISession.java (94%)
rename {session/src/main/java/org/apache/iotdb/session => isession/src/main/java/org/apache/iotdb/isession}/SessionConfig.java (96%)
rename {session/src/main/java/org/apache/iotdb/session => isession/src/main/java/org/apache/iotdb/isession}/SessionDataSet.java (99%)
rename session/src/main/java/org/apache/iotdb/session/ISession.java => isession/src/main/java/org/apache/iotdb/isession/pool/ISessionPool.java (82%)
rename {session/src/main/java/org/apache/iotdb/session => isession/src/main/java/org/apache/iotdb/isession}/pool/SessionDataSetWrapper.java (80%)
rename {session/src/main/java/org/apache/iotdb/session => isession/src/main/java/org/apache/iotdb/isession}/template/Template.java (98%)
rename {session/src/main/java/org/apache/iotdb/session => isession/src/main/java/org/apache/iotdb/isession}/template/TemplateNode.java (97%)
copy confignode/src/main/java/org/apache/iotdb/confignode/procedure/exception/ProcedureYieldException.java => isession/src/main/java/org/apache/iotdb/isession/util/SystemStatus.java (70%)
rename {session/src/main/java/org/apache/iotdb/session => isession/src/main/java/org/apache/iotdb/isession}/util/Version.java (95%)
rename server/src/main/java/org/apache/iotdb/db/constant/{SQLConstant.java => SqlConstant.java} (95%)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/ClusterSchemaFetcher.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/AutoCreateSchemaExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/ClusterSchemaFetchExecutor.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/schema/ClusterSchemaFetcher.java
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/{ => schema}/ISchemaFetcher.java (97%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/analyze/{ => schema}/SchemaValidator.java (98%)
rename server/src/main/java/org/apache/iotdb/db/mpp/plan/parser/{SQLParseError.java => SqlParseError.java} (95%)
rename server/src/main/java/org/apache/iotdb/db/protocol/influxdb/constant/{InfluxSQLConstant.java => InfluxSqlConstant.java} (93%)