You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by xu...@apache.org on 2021/11/04 07:59:09 UTC
[iotdb] branch separate_insert_plan_xkf updated (dc06e75 -> e712ef4)
This is an automated email from the ASF dual-hosted git repository.
xuekaifeng pushed a change to branch separate_insert_plan_xkf
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from dc06e75 Merge branch 'new_vector' of git://github.com/apache/iotdb into separate_insert_plan_xkf
add 3a6ce23 [IOTDB-1887] Fix importing csv data containing null throws exception (#4241)
add a5185a0 [IOTDB-1651]add reconnect to solve out of sequence (#4087) (#4246)
add 5ad6a4b [IOTDB-1880] Compatibility of Apache IoTDB with InfluxDB - Data Record Insertion (#4231)
add 52869f4 [IOTDB-1731]Fix sync error between different os (#4245)
add 85d2a4a [IOTDB-1884] Distinguish between zero and null values in sum aggregation (#4233)
add b5ef4d8 [IOTDB-1620] Support backtick (`) character and double quotes (") to quote identifiers (#4243)
add 461d22b [IOTDB-1280] Solve the performance reduction caused by syntax error in SLL prediction mode (#4234)
add f2382ef [IOTDB-1877] Fix Sync recovery and reconnection bugs in both sender and receiver (#4287)
add 8eb939c [IOTDB-1745] Metagroup snapshots support template (#4244)
add 0013531 Update TSDB-Comparison.md (#4289)
add 25a98ee [IOTDB-1609] Print the actual size of plan when it exceeds the wal_buffer_size (#4279)
add b05e21c [ISSUE-4288] Fix CI issue caused by the invalid pentaho download url (#4299)
add c48b118 [IOTDB-1914] fix information when start iotdb on windows (#4300)
add b89cf91 [IOTDB-1714] fix Could not find or load main class when start with jmx on win (#4306)
add 0eeb0ce [IOTDB-1604] Fix data increase when shut down iotdb in 0.12 and restart iotdb-0.13 (#4240)
add af8b3dc [ISSUE-4293] SessionPool: InterruptedException is not properly handled in synchronized wait() (#4295)
add 2435127 [IOTDB-1886] Support Constant Expressions in Select Clauses (#4257)
add bc47312 [IOTDB-1895] Cache leader optimization for batch write interfaces on multiple devices (#4286)
add 5e1f780 [IOTDB-1775] CAST: data type conversion function (#4292)
add 6fea8ad resolve conflicts and raw query without value filter on disk is ok
add 6fbbf38 change import
add 8ed8d17 fix insert s1 s2 then s2 s1 bug
add dc20299 Merge branch 'new_vector' of https://github.com/apache/iotdb into new_vector
add 1ef88af format code
new e712ef4 Merge branch 'new_vector' of git://github.com/apache/iotdb into separate_insert_plan_xkf
The 1 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:
.github/dependabot.yml | 8 +-
.gitignore | 5 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlLexer.g4 | 74 ++---
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 60 ++--
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 88 +++---
.../iotdb/cluster/coordinator/Coordinator.java | 114 +++++---
.../log/manage/MetaSingleSnapshotLogManager.java | 10 +-
.../cluster/log/snapshot/MetaSimpleSnapshot.java | 38 ++-
.../log/snapshot/MetaSimpleSnapshotTest.java | 42 ++-
.../cluster/server/member/MetaGroupMemberTest.java | 25 +-
.../cluster/utils/CreateTemplatePlanUtil.java | 71 +++++
docs/SystemDesign/DataQuery/AlignByDeviceQuery.md | 12 +-
.../Data-Concept/Data-Model-and-Terminology.md | 72 ++---
.../DML-Data-Manipulation-Language.md | 83 ++++--
.../IoTDB-SQL-Language/Syntax-Conventions.md | 128 +++++++++
.../System-Tools/Monitor-and-Log-Tools.md | 2 +-
.../SystemDesign/DataQuery/AlignByDeviceQuery.md | 12 +-
docs/zh/UserGuide/Comparison/TSDB-Comparison.md | 2 +-
.../Data-Concept/Data-Model-and-Terminology.md | 70 +++--
.../DML-Data-Manipulation-Language.md | 84 ++++--
.../IoTDB-SQL-Language/Syntax-Conventions.md | 129 +++++++++
.../System-Tools/Monitor-and-Log-Tools.md | 10 +-
hive-connector/pom.xml | 16 --
.../influxdb/protocol/input/InfluxLineProtocol.g4 | 93 +++++++
.../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 31 ++-
.../iotdb/influxdb/example/InfluxDBExample.java | 2 +-
.../influxdb/protocol/input/InfluxLineParser.java | 165 +++++++++++
.../influxdb/integration/IoTDBInfluxDBIT.java | 3 +
.../protocol/input/InfluxLineParserTest.java | 55 ++++
pom.xml | 6 +
server/src/assembly/resources/conf/iotdb-env.bat | 20 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 19 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 24 +-
.../SizeTieredCompactionRecoverTask.java | 58 +++-
.../inner/utils/InnerSpaceCompactionUtils.java | 2 +-
.../compaction/task/AbstractCompactionTask.java | 7 +-
.../engine/memtable/AlignedWritableMemChunk.java | 24 +-
.../db/engine/memtable/IWritableMemChunk.java | 4 +-
.../engine/storagegroup/StorageGroupProcessor.java | 30 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 5 +
.../iotdb/db/metadata/template/Template.java | 43 +++
.../db/metadata/template/TemplateManager.java | 11 +
.../iotdb/db/metadata/utils/MetaFormatUtils.java | 2 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 25 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 2 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 8 -
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 17 ++
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 309 +++++++++++++--------
.../iotdb/db/qp/strategy/LogicalGenerator.java | 19 +-
.../utils/EmptyOutputStream.java} | 17 +-
.../db/query/aggregation/impl/SumAggrResult.java | 70 +++--
.../db/query/dataset/UDTFAlignByTimeDataSet.java | 2 +
.../iotdb/db/query/expression/Expression.java | 48 +++-
.../query/expression/binary/BinaryExpression.java | 28 +-
...TimeSeriesOperand.java => ConstantOperand.java} | 66 ++---
.../query/expression/unary/FunctionExpression.java | 12 +-
.../query/expression/unary/NegationExpression.java | 12 +-
.../query/expression/unary/TimeSeriesOperand.java | 8 +-
.../query/reader/series/AlignedSeriesReader.java | 2 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 3 +-
.../db/query/udf/builtin/BuiltinFunction.java | 1 +
.../iotdb/db/query/udf/builtin/UDTFCast.java | 259 +++++++++++++++++
.../udf/core/layer/ConstantIntermediateLayer.java | 66 +++++
.../layer/MultiInputColumnIntermediateLayer.java | 8 +-
.../query/udf/core/layer/RawQueryInputLayer.java | 5 +
...InputColumnMultiReferenceIntermediateLayer.java | 5 +
.../udf/core/reader/ConstantLayerPointReader.java | 132 +++++++++
.../db/query/udf/core/reader/LayerPointReader.java | 2 +
.../transformer/ArithmeticBinaryTransformer.java | 17 ++
.../transformer/ArithmeticNegationTransformer.java | 5 +
.../udf/core/transformer/UDFQueryTransformer.java | 5 +
.../tv/ElasticSerializableTVList.java | 5 +
.../db/sync/receiver/transfer/SyncServiceImpl.java | 44 +--
.../iotdb/db/sync/sender/transfer/SyncClient.java | 69 +++--
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 12 +-
.../db/utils/datastructure/AlignedTVList.java | 54 ++--
.../iotdb/db/utils/datastructure/TVList.java | 4 +-
.../db/writelog/node/ExclusiveWriteLogNode.java | 10 +-
.../iotdb/db/integration/IOTDBGroupByIT.java | 149 ++++++----
.../integration/IOTDBGroupByInnerIntervalIT.java | 2 +-
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 300 --------------------
.../iotdb/db/integration/IoTDBArithmeticIT.java | 7 +-
.../db/integration/IoTDBCreateStorageGroupIT.java | 2 +-
.../iotdb/db/integration/IoTDBDeletionIT.java | 16 +-
.../iotdb/db/integration/IoTDBGroupByMonthIT.java | 2 +-
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 178 ++++++++++++
.../iotdb/db/integration/IoTDBQuotedPathIT.java | 46 +--
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 2 +-
.../db/integration/IoTDBTriggerExecutionIT.java | 160 +++++------
.../db/integration/IoTDBTriggerManagementIT.java | 172 ++++++------
.../db/integration/IoTDBUDFWindowQueryIT.java | 96 +++++++
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 42 +++
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 34 +++
.../aggregation/IoTDBAggregationByLevelIT.java | 8 +-
.../aggregation/IoTDBAggregationSmallDataIT.java | 2 +-
.../db/integration/auth/IoTDBAuthorizationIT.java | 12 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 6 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 30 +-
.../iotdb/db/monitor/IoTDBStatMonitorTest.java | 4 +-
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 4 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 6 +-
.../iotdb/db/query/dataset/ListDataSetTest.java | 2 +-
.../iotdb/db/query/dataset/SingleDataSetTest.java | 2 +-
.../dataset/groupby/GroupByLevelDataSetTest.java | 9 +-
.../dataset/groupby/GroupByTimeDataSetTest.java | 9 +-
.../iotdb/db/query/udf/example/Accumulator.java | 11 +-
.../apache/iotdb/db/writelog/WriteLogNodeTest.java | 52 ++++
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 3 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 3 +-
.../iotdb/session/IoTDBSessionComplexIT.java | 14 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 84 +++++-
site/src/main/.vuepress/config.js | 4 +
112 files changed, 3230 insertions(+), 1353 deletions(-)
create mode 100644 cluster/src/test/java/org/apache/iotdb/cluster/utils/CreateTemplatePlanUtil.java
create mode 100644 docs/UserGuide/IoTDB-SQL-Language/Syntax-Conventions.md
create mode 100644 docs/zh/UserGuide/IoTDB-SQL-Language/Syntax-Conventions.md
create mode 100644 influxdb-protocol/src/main/antlr4/org/apache/iotdb/influxdb/protocol/input/InfluxLineProtocol.g4
create mode 100644 influxdb-protocol/src/main/java/org/apache/iotdb/influxdb/protocol/input/InfluxLineParser.java
create mode 100644 influxdb-protocol/src/test/java/org/apache/iotdb/influxdb/protocol/input/InfluxLineParserTest.java
copy server/src/main/java/org/apache/iotdb/db/{sync/receiver/recover/ISyncReceiverLogAnalyzer.java => qp/utils/EmptyOutputStream.java} (68%)
copy server/src/main/java/org/apache/iotdb/db/query/expression/unary/{TimeSeriesOperand.java => ConstantOperand.java} (56%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/builtin/UDTFCast.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/layer/ConstantIntermediateLayer.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/udf/core/reader/ConstantLayerPointReader.java
[iotdb] 01/01: Merge branch 'new_vector' of
git://github.com/apache/iotdb into separate_insert_plan_xkf
Posted by xu...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
xuekaifeng pushed a commit to branch separate_insert_plan_xkf
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e712ef455872999d6c3843ca09ed64be22207450
Merge: dc06e75 1ef88af
Author: 151250176 <15...@smail.nju.edu.cn>
AuthorDate: Thu Nov 4 15:16:44 2021 +0800
Merge branch 'new_vector' of git://github.com/apache/iotdb into separate_insert_plan_xkf
# Conflicts:
# session/src/main/java/org/apache/iotdb/session/Session.java
.github/dependabot.yml | 8 +-
.gitignore | 5 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlLexer.g4 | 74 ++---
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 60 ++--
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 88 +++---
.../iotdb/cluster/coordinator/Coordinator.java | 114 +++++---
.../log/manage/MetaSingleSnapshotLogManager.java | 10 +-
.../cluster/log/snapshot/MetaSimpleSnapshot.java | 38 ++-
.../log/snapshot/MetaSimpleSnapshotTest.java | 42 ++-
.../cluster/server/member/MetaGroupMemberTest.java | 25 +-
.../cluster/utils/CreateTemplatePlanUtil.java | 71 +++++
docs/SystemDesign/DataQuery/AlignByDeviceQuery.md | 12 +-
.../Data-Concept/Data-Model-and-Terminology.md | 72 ++---
.../DML-Data-Manipulation-Language.md | 83 ++++--
.../IoTDB-SQL-Language/Syntax-Conventions.md | 128 +++++++++
.../System-Tools/Monitor-and-Log-Tools.md | 2 +-
.../SystemDesign/DataQuery/AlignByDeviceQuery.md | 12 +-
docs/zh/UserGuide/Comparison/TSDB-Comparison.md | 2 +-
.../Data-Concept/Data-Model-and-Terminology.md | 70 +++--
.../DML-Data-Manipulation-Language.md | 84 ++++--
.../IoTDB-SQL-Language/Syntax-Conventions.md | 129 +++++++++
.../System-Tools/Monitor-and-Log-Tools.md | 10 +-
hive-connector/pom.xml | 16 --
.../influxdb/protocol/input/InfluxLineProtocol.g4 | 93 +++++++
.../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 31 ++-
.../iotdb/influxdb/example/InfluxDBExample.java | 2 +-
.../influxdb/protocol/input/InfluxLineParser.java | 165 +++++++++++
.../influxdb/integration/IoTDBInfluxDBIT.java | 3 +
.../protocol/input/InfluxLineParserTest.java | 55 ++++
pom.xml | 6 +
server/src/assembly/resources/conf/iotdb-env.bat | 20 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 19 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 24 +-
.../SizeTieredCompactionRecoverTask.java | 58 +++-
.../inner/utils/InnerSpaceCompactionUtils.java | 2 +-
.../compaction/task/AbstractCompactionTask.java | 7 +-
.../engine/memtable/AlignedWritableMemChunk.java | 24 +-
.../db/engine/memtable/IWritableMemChunk.java | 4 +-
.../engine/storagegroup/StorageGroupProcessor.java | 30 +-
.../apache/iotdb/db/metadata/path/AlignedPath.java | 5 +
.../iotdb/db/metadata/template/Template.java | 43 +++
.../db/metadata/template/TemplateManager.java | 11 +
.../iotdb/db/metadata/utils/MetaFormatUtils.java | 2 +-
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 25 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 2 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 8 -
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 17 ++
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 309 +++++++++++++--------
.../iotdb/db/qp/strategy/LogicalGenerator.java | 19 +-
.../utils/EmptyOutputStream.java} | 33 +--
.../db/query/aggregation/impl/SumAggrResult.java | 70 +++--
.../db/query/dataset/UDTFAlignByTimeDataSet.java | 2 +
.../iotdb/db/query/expression/Expression.java | 48 +++-
.../query/expression/binary/BinaryExpression.java | 28 +-
...TimeSeriesOperand.java => ConstantOperand.java} | 66 ++---
.../query/expression/unary/FunctionExpression.java | 12 +-
.../query/expression/unary/NegationExpression.java | 12 +-
.../query/expression/unary/TimeSeriesOperand.java | 8 +-
.../query/reader/series/AlignedSeriesReader.java | 2 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 3 +-
.../db/query/udf/builtin/BuiltinFunction.java | 1 +
.../iotdb/db/query/udf/builtin/UDTFCast.java | 259 +++++++++++++++++
.../udf/core/layer/ConstantIntermediateLayer.java | 66 +++++
.../layer/MultiInputColumnIntermediateLayer.java | 8 +-
.../query/udf/core/layer/RawQueryInputLayer.java | 5 +
...InputColumnMultiReferenceIntermediateLayer.java | 5 +
.../udf/core/reader/ConstantLayerPointReader.java | 132 +++++++++
.../db/query/udf/core/reader/LayerPointReader.java | 2 +
.../transformer/ArithmeticBinaryTransformer.java | 17 ++
.../transformer/ArithmeticNegationTransformer.java | 5 +
.../udf/core/transformer/UDFQueryTransformer.java | 5 +
.../tv/ElasticSerializableTVList.java | 5 +
.../db/sync/receiver/transfer/SyncServiceImpl.java | 44 +--
.../iotdb/db/sync/sender/transfer/SyncClient.java | 69 +++--
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 12 +-
.../db/utils/datastructure/AlignedTVList.java | 54 ++--
.../iotdb/db/utils/datastructure/TVList.java | 4 +-
.../db/writelog/node/ExclusiveWriteLogNode.java | 10 +-
.../iotdb/db/integration/IOTDBGroupByIT.java | 149 ++++++----
.../integration/IOTDBGroupByInnerIntervalIT.java | 2 +-
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 300 --------------------
.../iotdb/db/integration/IoTDBArithmeticIT.java | 7 +-
.../db/integration/IoTDBCreateStorageGroupIT.java | 2 +-
.../iotdb/db/integration/IoTDBDeletionIT.java | 16 +-
.../iotdb/db/integration/IoTDBGroupByMonthIT.java | 2 +-
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 178 ++++++++++++
.../iotdb/db/integration/IoTDBQuotedPathIT.java | 46 +--
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 2 +-
.../db/integration/IoTDBTriggerExecutionIT.java | 160 +++++------
.../db/integration/IoTDBTriggerManagementIT.java | 172 ++++++------
.../db/integration/IoTDBUDFWindowQueryIT.java | 96 +++++++
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 42 +++
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 34 +++
.../aggregation/IoTDBAggregationByLevelIT.java | 8 +-
.../aggregation/IoTDBAggregationSmallDataIT.java | 2 +-
.../db/integration/auth/IoTDBAuthorizationIT.java | 12 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 6 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 30 +-
.../iotdb/db/monitor/IoTDBStatMonitorTest.java | 4 +-
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 4 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 6 +-
.../iotdb/db/query/dataset/ListDataSetTest.java | 2 +-
.../iotdb/db/query/dataset/SingleDataSetTest.java | 2 +-
.../dataset/groupby/GroupByLevelDataSetTest.java | 9 +-
.../dataset/groupby/GroupByTimeDataSetTest.java | 9 +-
.../iotdb/db/query/udf/example/Accumulator.java | 11 +-
.../apache/iotdb/db/writelog/WriteLogNodeTest.java | 52 ++++
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 3 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 3 +-
.../iotdb/session/IoTDBSessionComplexIT.java | 14 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 84 +++++-
site/src/main/.vuepress/config.js | 4 +
112 files changed, 3230 insertions(+), 1369 deletions(-)