This is an automated email from the ASF dual-hosted git repository. hxd pushed a commit to branch jenkins-disable-integration in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit c88028d3cf2de8e23425a4ba09f7d1d43d2adda7 Merge: 2c2323ebc7 30335b3a73 Author: xiangdong huang <[email protected]> AuthorDate: Mon Dec 26 09:43:52 2022 +0800 Merge remote-tracking branch 'origin/master' into jenkins-disable-integration .../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 29 +- .../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 | 10 +- .../iotdb/consensus/ratis/RatisConsensusTest.java | 8 +- docker/ReadMe.md | 4 +- docker/src/main/DockerCompose/do-docker-build.sh | 18 +- ...pose-1c1d.yml => docker-compose-standalone.yml} | 2 +- ...file-1.0.0-1c1d => Dockerfile-1.0.0-standalone} | 0 docs/UserGuide/QuickStart/WayToGetIoTDB.md | 6 +- docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 6 +- .../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 +- isession/pom.xml | 37 + .../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 + .../org/apache/iotdb/db/auth/AuthorityChecker.java | 2 +- .../iotdb/db/client/DataNodeInternalClient.java | 4 +- .../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 2 +- .../org/apache/iotdb/db/constant/SqlConstant.java | 66 + .../db/engine/querycontext/QueryDataSource.java | 2 +- .../iotdb/db/engine/storagegroup/DataRegion.java | 2 +- .../db/engine/storagegroup/TsFileResource.java | 14 +- .../exception/index/DistanceMetricException.java | 28 - .../index/IllegalIndexParamException.java | 28 - .../db/exception/index/IndexManagerException.java | 34 - .../db/exception/index/QueryIndexException.java | 29 - .../exception/query/LogicalOperatorException.java | 54 - .../exception/query/LogicalOptimizeException.java | 46 - .../db/exception/query/OutOfTTLException.java | 2 +- .../exception/query/PathNumOverLimitException.java | 33 - .../query/UnSupportedFillTypeException.java | 33 - .../iotdb/db/exception/sql/SQLParserException.java | 35 - .../exception/sql/StatementAnalyzeException.java | 13 - .../iotdb/db/index/common/IndexConstant.java | 36 - .../apache/iotdb/db/index/common/IndexType.java | 78 -- .../apache/iotdb/db/index/common/IndexUtils.java | 35 - .../iotdb/db/localconfignode/LocalConfigNode.java | 2 +- .../apache/iotdb/db/metadata/MetadataConstant.java | 4 + .../db/metadata/cache/DataNodeSchemaCache.java | 4 - .../mtree/snapshot/MemMTreeSnapshotUtil.java | 4 +- .../db/metadata/utils/ResourceByPathUtils.java | 151 --- .../timerangeiterator/AggrWindowIterator.java | 4 +- .../TimeRangeIteratorFactory.java | 2 +- .../constant => common}/DataNodeEndPoints.java | 7 +- .../db/mpp/common/filter/BasicFilterType.java | 189 --- .../db/mpp/common/filter/BasicFunctionFilter.java | 191 --- .../mpp/common/filter/FilterDeserializeUtil.java | 63 - .../iotdb/db/mpp/common/filter/FunctionFilter.java | 91 -- .../iotdb/db/mpp/common/filter/InFilter.java | 230 ---- .../iotdb/db/mpp/common/filter/LikeFilter.java | 152 --- .../iotdb/db/mpp/common/filter/QueryFilter.java | 354 ----- .../iotdb/db/mpp/common/filter/RegexpFilter.java | 150 -- .../execution/executor/RegionWriteExecutor.java | 2 +- .../iotdb/db/mpp/execution/memory/MemoryPool.java | 12 + .../execution/operator/source/SeriesScanUtil.java | 17 +- .../org/apache/iotdb/db/mpp/plan/Coordinator.java | 4 +- .../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 +- .../iotdb/db/mpp/plan/constant/FilterConstant.java | 103 -- .../db/mpp/plan/execution/QueryExecution.java | 4 +- .../execution/config/sys/sync/ShowPipeTask.java | 2 +- .../iotdb/db/mpp/plan/expression/ResultColumn.java | 146 -- .../visitor/OldIntermediateLayerVisitor.java | 461 ------- .../iotdb/db/mpp/plan/parser/ASTVisitor.java | 216 ++- .../plan/parser/SqlParseError.java} | 7 +- .../db/mpp/plan/parser/StatementGenerator.java | 13 +- .../plan/planner/MemoryDistributionCalculator.java | 2 +- .../db/mpp/plan/planner/OperatorTreeGenerator.java | 2 +- .../SimpleFragmentParallelPlanner.java | 2 +- .../db/mpp/plan/rewriter/DnfFilterOptimizer.java | 163 --- .../db/mpp/plan/rewriter/IFilterOptimizer.java | 29 - .../plan/rewriter/MergeSingleFilterOptimizer.java | 179 --- .../db/mpp/plan/rewriter/RemoveNotOptimizer.java | 103 -- .../iotdb/db/mpp/plan/statement/Statement.java | 1 - .../{constant => statement}/StatementType.java | 2 +- .../plan/statement/component/SelectComponent.java | 2 +- .../plan/statement/crud/DeleteDataStatement.java | 2 +- .../crud/InsertMultiTabletsStatement.java | 2 +- .../plan/statement/crud/InsertRowStatement.java | 2 +- .../crud/InsertRowsOfOneDeviceStatement.java | 2 +- .../plan/statement/crud/InsertRowsStatement.java | 2 +- .../mpp/plan/statement/crud/InsertStatement.java | 2 +- .../plan/statement/crud/InsertTabletStatement.java | 2 +- .../plan/statement/crud/LoadTsFileStatement.java | 2 +- .../db/mpp/plan/statement/crud/QueryStatement.java | 2 +- .../InternalCreateTimeSeriesStatement.java | 2 +- .../statement/internal/SchemaFetchStatement.java | 2 +- .../metadata/AlterTimeSeriesStatement.java | 2 +- .../plan/statement/metadata/CountStatement.java | 2 +- .../metadata/CreateAlignedTimeSeriesStatement.java | 2 +- .../metadata/CreateContinuousQueryStatement.java | 2 +- .../metadata/CreateFunctionStatement.java | 2 +- .../metadata/CreateMultiTimeSeriesStatement.java | 2 +- .../metadata/CreateTimeSeriesStatement.java | 2 +- .../statement/metadata/CreateTriggerStatement.java | 2 +- .../metadata/DeleteStorageGroupStatement.java | 2 +- .../metadata/DeleteTimeSeriesStatement.java | 2 +- .../metadata/DropContinuousQueryStatement.java | 2 +- .../statement/metadata/DropFunctionStatement.java | 2 +- .../statement/metadata/DropTriggerStatement.java | 2 +- .../metadata/SetStorageGroupStatement.java | 2 +- .../plan/statement/metadata/SetTTLStatement.java | 2 +- .../metadata/ShowContinuousQueriesStatement.java | 2 +- .../mpp/plan/statement/metadata/ShowStatement.java | 2 +- .../plan/statement/metadata/UnSetTTLStatement.java | 2 +- .../template/ActivateTemplateStatement.java | 2 +- .../template/CreateSchemaTemplateStatement.java | 2 +- .../template/DeactivateTemplateStatement.java | 2 +- .../template/DropSchemaTemplateStatement.java | 2 +- .../template/SetSchemaTemplateStatement.java | 2 +- .../ShowNodesInSchemaTemplateStatement.java | 2 +- .../template/ShowPathSetTemplateStatement.java | 2 +- .../template/ShowPathsUsingTemplateStatement.java | 2 +- .../template/ShowSchemaTemplateStatement.java | 2 +- .../template/UnsetSchemaTemplateStatement.java | 2 +- .../db/mpp/plan/statement/sys/AuthorStatement.java | 2 +- .../plan/statement/sys/ClearCacheStatement.java | 2 +- .../db/mpp/plan/statement/sys/FlushStatement.java | 2 +- .../statement/sys/LoadConfigurationStatement.java | 2 +- .../db/mpp/plan/statement/sys/MergeStatement.java | 2 +- .../statement/sys/SetSystemStatusStatement.java | 2 +- .../sys/sync/CreatePipeSinkStatement.java | 2 +- .../statement/sys/sync/CreatePipeStatement.java | 2 +- .../statement/sys/sync/DropPipeSinkStatement.java | 2 +- .../plan/statement/sys/sync/DropPipeStatement.java | 2 +- .../statement/sys/sync/StartPipeStatement.java | 2 +- .../plan/statement/sys/sync/StopPipeStatement.java | 2 +- .../db/mpp/transformation/dag/udf/UDTFContext.java | 8 - ...fluxSQLConstant.java => InfluxSqlConstant.java} | 15 +- .../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 | 202 +-- .../protocol/influxdb/handler/NewQueryHandler.java | 20 +- .../protocol/influxdb/input/InfluxLineParser.java | 2 +- .../influxdb/operator/InfluxQueryOperator.java | 38 - .../influxdb/parser/InfluxDBAstVisitor.java | 321 +++++ .../InfluxDBStatementGenerator.java} | 25 +- .../protocol/influxdb/sql/InfluxDBSqlVisitor.java | 298 ---- .../influxdb/statement/InfluxQueryStatement.java | 57 + .../InfluxSelectComponent.java | 21 +- .../db/protocol/influxdb/util/FilterUtils.java | 20 +- .../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 4 +- .../db/protocol/mqtt/PayloadFormatManager.java | 19 +- .../db/protocol/rest/handler/ExceptionHandler.java | 3 +- .../rest/handler/ExecuteStatementHandler.java | 2 +- .../protocol/rest/impl/GrafanaApiServiceImpl.java | 4 +- .../db/protocol/rest/impl/RestApiServiceImpl.java | 4 +- .../iotdb/db/qp/constant/FilterConstant.java | 114 -- .../apache/iotdb/db/qp/constant/SQLConstant.java | 285 ---- .../org/apache/iotdb/db/qp/logical/Operator.java | 200 --- .../db/qp/logical/crud/BasicFunctionOperator.java | 172 --- .../db/qp/logical/crud/BasicOperatorType.java | 191 --- .../iotdb/db/qp/logical/crud/FilterOperator.java | 295 ---- .../iotdb/db/qp/logical/crud/FromComponent.java | 41 - .../iotdb/db/qp/logical/crud/FunctionOperator.java | 48 - .../iotdb/db/qp/logical/crud/QueryOperator.java | 106 -- .../iotdb/db/qp/logical/crud/SelectComponent.java | 139 -- .../db/qp/logical/crud/SpecialClauseComponent.java | 162 --- .../iotdb/db/qp/logical/crud/WhereComponent.java | 40 - .../iotdb/db/qp/utils/GroupByLevelController.java | 327 ----- .../db/query/control/QueryResourceManager.java | 14 - .../apache/iotdb/db/query/filter/TsFileFilter.java | 31 - .../query/reader/series/AlignedSeriesReader.java | 109 -- .../reader/series/SeriesRawDataBatchReader.java | 140 -- .../iotdb/db/query/reader/series/SeriesReader.java | 1430 -------------------- .../db/service/metrics/IoTDBInternalReporter.java | 4 +- .../service/thrift/impl/ClientRPCServiceImpl.java | 4 +- .../impl/DataNodeInternalRPCServiceImpl.java | 4 +- .../thrift/impl/NewInfluxDBServiceImpl.java | 17 +- .../java/org/apache/iotdb/db/sync/SyncService.java | 4 +- .../iotdb/db/sync/pipedata/load/ILoader.java | 4 +- .../db/sync/transport/server/ReceiverManager.java | 2 +- .../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 2 +- .../iotdb/db/tools/TsFileResourcePrinter.java | 2 +- .../db/tools/watermark/WatermarkDetector.java | 9 +- .../iotdb/db/utils/AlignedValueIterator.java | 59 - .../org/apache/iotdb/db/utils/CommonUtils.java | 10 +- .../iotdb/db/{qp => }/utils/DateTimeUtils.java | 2 +- .../apache/iotdb/db/utils/ErrorHandlingUtils.java | 4 - .../org/apache/iotdb/db/utils/FileLoaderUtils.java | 15 - .../java/org/apache/iotdb/db/utils/FilesUtils.java | 43 - .../iotdb/db/utils/IExpressionDeserializeUtil.java | 51 - .../apache/iotdb/db/utils/QueryDataSetUtils.java | 133 -- .../org/apache/iotdb/db/utils/SchemaUtils.java | 20 +- .../apache/iotdb/db/utils/TypeInferenceUtils.java | 46 +- .../org/apache/iotdb/db/utils/ValueIterator.java | 56 - .../timerangeiterator/AggrWindowIterator.java | 165 --- .../timerangeiterator/ITimeRangeIterator.java | 39 - .../timerangeiterator/PreAggrWindowIterator.java | 158 --- .../PreAggrWindowWithNaturalMonthIterator.java | 123 -- .../TimeRangeIteratorFactory.java | 69 - .../db/wal/recover/file/TsFilePlanRedoer.java | 2 +- .../FastCrossCompactionPerformerTest.java | 71 +- .../ReadPointCompactionPerformerTest.java | 66 +- ...eCrossSpaceCompactionWithFastPerformerTest.java | 163 +-- ...sSpaceCompactionWithReadPointPerformerTest.java | 163 +-- .../inner/InnerCompactionMoreDataTest.java | 28 +- .../SizeTieredCompactionRecoverTest.java | 230 ++-- .../compaction/utils/CompactionCheckerUtils.java | 24 +- .../iotdb/db/engine/storagegroup/TTLTest.java | 31 +- .../schemaRegion/SchemaRegionManagementTest.java | 43 + .../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 +- .../influxdb/sql/InfluxDBLogicalGeneratorTest.java | 70 - .../sql/InfluxDBStatementGeneratorTest.java | 87 ++ .../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 10 +- .../db/qp/utils/DatetimeQueryDataSetUtilsTest.java | 2 + .../apache/iotdb/db/utils/EnvironmentUtils.java | 3 + .../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 12 +- .../iotdb/db/utils/TimeRangeIteratorTest.java | 298 ---- 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 +- 281 files changed, 2910 insertions(+), 10699 deletions(-)
