This is an automated email from the ASF dual-hosted git repository.
hxd pushed a change to branch cluster-
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 4f92cc5 a temporary submit..
add 25f7f55 [IOTDB-1506] CI fails because of JDBC connection exceptions
(#3577)
add 56ea509 Optimize the implementation of singleton (#3585)
add df46873 add checkDeviceIdExist method to ITimeIndex (#3562)
add 2797007 [IOTDB-1459] Unify integration test class names (#3588)
add 2bff46a [IOTDB-1492] Fix mLogParser.sh cannot parse the device
template (#3573)
add ed6d848 Add Google Analytics (#3592)
add 31bf7e9 Wordings improvement of website nav bar (#3591)
add af567ee [IOTDB-1456] Fix Error occurred while executing delete
timeseries statement (#3474)
add 534bb93 Update Google Analytics tag id (#3594)
add 7a09ecb Add privacy disclosure (#3597)
add 9ecb7a0 [IOTDB-1491] UDTF query supported in cluster mode (#3565)
add 18e5ff7 add SessionConcurrentExample & fix template restart
PathNotExistException (#3595)
add 79e50d6 fix recover TsFileResource time interval bug (#3604)
add c8edbcf improve mlog compatibility from 0.12.2 to 0.13.0 (#3553)
add 6e9f340 [IOTDB-1059] Support sql statement insert without timestamp
(#3067)
add 5a348a4 [IOTDB-1478]The whole IoTDB can not read/write if any one sg
is not ready (#3554)
add 3c6925c [IOTDB-959]Add createStorageGroup Grammar (#3608)
add 0791e07 mod note (#3615)
add 72799f3 [IOTDB-1503] 1 node crash causes whole cluster cannot work
(#3579)
add 469f78b Remove path registration in IoTDBSink (#3620)
add 511d5f4 Update ContributeGuide.md (#3611)
add 2ba8c78 [IOTDB-1509] show timeseries throw a bug (#3556)
add e0ce236 remove unnecessary testcontainer IT (#3625)
add c05a7c5 [IOTDB-1528] CQ IT unstable: sometimes fails on
checkCQExecutionResult() (#3624)
add 4fcd755 [IOTDB-1500] Remove current dynamic query memory control
(#3563)
add 9437339 Fix compile error in assignQueryId (#3629)
add 47fa594 [IoTDB-1499] Remove series registeration using IoTDBSink ->
master (#3574)
add d984fe8 [IOTDB-1496] Timed flush memtable (#3610)
add de1a622 [IOTDB-1524] Support SELECT ... INTO ... clause (#3614)
add 716710c [IOTDB-1519]add metadata checking option and change grammar
for loading tsfile (#3576)
add 95e3b69 [IOTDB-1529]Fix mlog recover idx bug and synchronize
setStorageGroup (#3635)
add d1729ea [IOTDB-1530] Make documents style better by adding a space
between full-corner and half-corner characters (#3632)
add 1d0b6ff [IOTDB-1477] Optimize code logic of
generateAlignByDevicePlan() (#3607)
add 0b2d0af make sure memtable flush task has submitted before check
(#3641)
add c023443 add an example to customize MQTT Message (#3572)
add ce385ab [IOTDB-1532] CI fails on testSelectInto() in E2E test (#3639)
add 868821c Add a testcase of dataApplier about batch insert. (#3645)
add ca3a4c2 [IOTDB-1517][IOTDB-1521] Refactor TsFile Index for Vector
(multi-variable timeseries) (#3627)
add 05a8f7c [IOTDB-1498] MNode Abstraction and Structure Improvement
(#3589)
add 3a38a89 Function Improvement: add overlapped page rate in Tracing
(#3602)
add 9c4cd4b introduction modify for README_ZH.md (#3646)
add 902dbfb [IOTDB-1511] Extract IStorageGroupMNode and IMeasurementMNode
Interface (#3647)
add 1a31750 Fix master order by time desc bug (#3655)
add 2ed58eb [IOTDB-1511] Implement EntityMNode (#3650)
add 319674d [IOTDB-1511] Rename DeviceTemplate to SchemaTemplate (#3656)
add b484f2e [IOTDB-1511] Rename Template Enum (#3657)
new 5bdf918 temporary commit for refactor thrift rpc
add ecf7bf2 add committer wangchao316 (#3661)
add 9b89113 [IOTDB-1526] New Template Constraint (#3659)
add 635a43e skip non exist measurement in where clause (#3590) (#3665)
add e3171bd [Docs] Update expired link (#3663)
add 443845c [IOTDB-1542] Cpp client segment fault: char[] buffer overflow
caused by long exception message (#3671)
add 0427d28 Add Jenkins CI timeout threshold (#3677)
add 204b7d3 [ISSUE-3674] Disable thrift code gen for Javascript (#3675)
new 19c9456 Merge remote-tracking branch 'origin/master' into cluster-
new bba25de temporary commit
add b5bc63a add .asf.yaml file for updating website automatically (#3678)
add 37f5c7a [IOTDB-1545] Query dataset momory leak on server caused by
cpp client (#3682)
add 785e316 close compaction by default (#3686)
add b1f30d0 [IOTDB-1486] Add a createTemplate Session example (#3697)
add 3234abf Cherry-pick 4 bug-fixing commits about upgrade tool from
rel/0.12 to master branch (#3698)
add a2c446a [ISSUE-3690] Memory leaks on the server when cpp client
invokes checkTimeseriesExists (#3692)
add 40fa7b3 [ISSUE-3693] Memory leaks when executing select-into clauses
(#3694)
new ae1e677 Merge remote-tracking branch 'origin/master' into cluster-
new 4246406 almost pass
add 4dcae2b [IOTDB-1372] delete devices field in FileTimeIndex (#3606)
add 860c8de JDBC - Adjust method not supported to specific prompt (#2444)
add 8168911 fix defaut max_sync_log_lag (#3704)
add 4884dc8 [IOTDB-1546] Optimize the Upgrade/Rewrite Tool rewrite logic
to reduce the temp memory cost (#3701)
new aae37ad Merge remote-tracking branch 'origin/master' into cluster-
new 0625334 pass manually test
The 7 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:
CONTRIBUTING.md | 2 +-
Jenkinsfile | 2 +-
README.md | 2 +-
README_ZH.md | 6 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 73 +-
client-cpp/src/main/Session.cpp | 761 +++---
client-cpp/src/main/Session.h | 565 ++--
client-cpp/src/test/main.cpp | 6 +-
cluster/pom.xml | 6 +
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 367 ++-
...adOnlyException.java => ClusterIoTDBMBean.java} | 18 +-
.../cluster/client/async/AsyncClientPool.java | 4 +
.../cluster/client/async/AsyncDataClient.java | 4 +-
.../client/async/AsyncDataHeartbeatClient.java | 4 +-
.../cluster/client/async/AsyncMetaClient.java | 4 +-
.../client/async/AsyncMetaHeartbeatClient.java | 4 +-
.../cluster/client/sync/SyncClientAdaptor.java | 56 +-
.../cluster/client/sync/SyncClientFactory.java | 5 +-
.../iotdb/cluster/client/sync/SyncClientPool.java | 29 +-
.../iotdb/cluster/client/sync/SyncDataClient.java | 13 +-
.../client/sync/SyncDataHeartbeatClient.java | 14 +-
.../iotdb/cluster/client/sync/SyncMetaClient.java | 15 +-
.../client/sync/SyncMetaHeartbeatClient.java | 12 +-
.../iotdb/cluster/config/ClusterConstant.java | 63 +
.../iotdb/cluster/config/ClusterDescriptor.java | 2 +-
.../iotdb/cluster/coordinator/Coordinator.java | 22 +-
.../iotdb/cluster/log/applier/BaseApplier.java | 17 +-
.../iotdb/cluster/log/applier/DataLogApplier.java | 9 +-
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 5 +-
.../log/manage/PartitionedSnapshotLogManager.java | 8 +-
.../cluster/log/snapshot/MetaSimpleSnapshot.java | 2 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 277 +-
.../apache/iotdb/cluster/metadata/MetaPuller.java | 46 +-
.../iotdb/cluster/partition/PartitionGroup.java | 5 +
.../cluster/partition/slot/SlotPartitionTable.java | 1 -
.../cluster/query/ClusterPhysicalGenerator.java | 18 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 83 +-
.../apache/iotdb/cluster/query/ClusterPlanner.java | 17 +-
.../iotdb/cluster/query/ClusterQueryRouter.java | 40 +
.../cluster/query/ClusterUDTFQueryExecutor.java | 12 +-
.../iotdb/cluster/query/LocalQueryExecutor.java | 32 +-
.../cluster/query/aggregate/ClusterAggregator.java | 20 +-
.../cluster/query/fill/ClusterPreviousFill.java | 24 +-
.../query/groupby/RemoteGroupByExecutor.java | 44 +-
.../query/last/ClusterLastQueryExecutor.java | 37 +-
.../cluster/query/manage/ClusterQueryManager.java | 8 +-
.../cluster/query/reader/ClusterReaderFactory.java | 20 +-
.../cluster/query/reader/ClusterTimeGenerator.java | 14 +-
.../iotdb/cluster/query/reader/DataSourceInfo.java | 45 +-
.../reader/RemoteSeriesReaderByTimestamp.java | 11 +-
.../query/reader/RemoteSimpleSeriesReader.java | 11 +-
.../query/reader/mult/MultDataSourceInfo.java | 27 +-
.../query/reader/mult/RemoteMultSeriesReader.java | 18 +-
.../iotdb/cluster/server/ClusterRPCService.java | 17 +-
.../iotdb/cluster/server/ClusterTSServiceImpl.java | 111 +-
.../iotdb/cluster/server/MetaClusterServer.java | 369 ---
.../apache/iotdb/cluster/server/RaftServer.java | 263 --
.../org/apache/iotdb/cluster/server/Response.java | 3 +
.../iotdb/cluster/server/StoppedMemberManager.java | 9 +-
.../server/clusterinfo/ClusterInfoServer.java | 1 +
.../handlers/caller/AppendNodeEntryHandler.java | 9 +-
.../server/handlers/caller/HeartbeatHandler.java | 7 +-
.../server/heartbeat/DataHeartbeatServer.java | 83 -
.../cluster/server/heartbeat/HeartbeatServer.java | 212 --
.../cluster/server/heartbeat/HeartbeatThread.java | 33 +-
.../server/heartbeat/MetaHeartbeatServer.java | 91 -
.../server/heartbeat/MetaHeartbeatThread.java | 7 +-
.../cluster/server/member/DataGroupMember.java | 46 +-
.../server/member/DataGroupMemberMBean.java} | 6 +-
.../cluster/server/member/MetaGroupMember.java | 440 ++--
...package-info.java => MetaGroupMemberMBean.java} | 20 +-
.../iotdb/cluster/server/member/RaftMember.java | 70 +-
.../member/RaftMemberMBean.java} | 38 +-
.../DataGroupServiceImpls.java} | 133 +-
...e-info.java => DataGroupServiceImplsMBean.java} | 16 +-
.../cluster/server/service/MetaSyncService.java | 35 +-
.../apache/iotdb/cluster/utils/PartitionUtils.java | 4 +-
.../cluster/utils/nodetool/ClusterMonitor.java | 26 +-
.../cluster/client/async/AsyncDataClientTest.java | 11 +-
.../cluster/client/async/AsyncMetaClientTest.java | 11 +-
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 7 +-
.../org/apache/iotdb/cluster/common/TestUtils.java | 7 +-
.../cluster/integration/BaseSingleNodeTest.java | 8 +-
.../cluster/log/applier/DataLogApplierTest.java | 175 +-
.../cluster/log/logtypes/SerializeLogTest.java | 4 +-
.../cluster/log/snapshot/FileSnapshotTest.java | 2 +-
.../log/snapshot/MetaSimpleSnapshotTest.java | 2 +-
.../iotdb/cluster/partition/MManagerWhiteBox.java | 2 +-
.../query/ClusterAggregateExecutorTest.java | 4 +-
.../query/ClusterDataQueryExecutorTest.java | 10 +-
.../cluster/query/ClusterFillExecutorTest.java | 4 +-
.../query/ClusterPhysicalGeneratorTest.java | 3 +-
.../cluster/query/ClusterPlanExecutorTest.java | 8 +-
.../cluster/query/ClusterQueryRouterTest.java | 44 +-
.../query/ClusterUDTFQueryExecutorTest.java | 116 +
.../iotdb/cluster/query/LoadConfigurationTest.java | 2 +-
.../ClusterGroupByNoVFilterDataSetTest.java | 2 +-
.../groupby/ClusterGroupByVFilterDataSetTest.java | 2 +-
.../query/groupby/MergeGroupByExecutorTest.java | 4 +-
.../query/groupby/RemoteGroupByExecutorTest.java | 4 +-
.../query/manage/ClusterQueryManagerTest.java | 12 +-
.../query/reader/ClusterReaderFactoryTest.java | 2 +-
.../query/reader/ClusterTimeGeneratorTest.java | 4 +-
.../cluster/query/reader/DatasourceInfoTest.java | 26 +-
.../reader/RemoteSeriesReaderByTimestampTest.java | 113 +-
.../query/reader/RemoteSimpleSeriesReaderTest.java | 91 +-
.../mult/AssignPathManagedMergeReaderTest.java | 100 +-
.../reader/mult/RemoteMultSeriesReaderTest.java | 169 +-
.../clusterinfo/ClusterInfoServiceImplTest.java | 18 +-
.../server/heartbeat/HeartbeatThreadTest.java | 7 +-
.../iotdb/cluster/server/member/BaseMember.java | 31 +-
.../cluster/server/member/DataGroupMemberTest.java | 48 +-
.../cluster/server/member/MetaGroupMemberTest.java | 115 +-
.../resources/node1conf/iotdb-engine.properties | 12 +-
.../resources/node2conf/iotdb-engine.properties | 12 +-
.../resources/node3conf/iotdb-engine.properties | 12 +-
compile-tools/thrift/pom.xml | 3 +-
docs/Development/ContributeGuide.md | 37 +-
docs/SystemDesign/SchemaManager/SchemaManager.md | 39 +-
docs/SystemDesign/TsFile/Format.md | 477 ++--
docs/UserGuide/Advanced-Features/Select-Into.md | 235 ++
.../Programming-MQTT.md | 79 +-
.../Data-Concept/Data-Model-and-Terminology.md | 195 +-
docs/UserGuide/Data-Concept/Data-Type.md | 125 +
.../UserGuide/Ecosystem Integration/Flink IoTDB.md | 3 +-
.../DDL-Data-Definition-Language.md | 6 +-
.../UserGuide/System-Tools/Load-External-Tsfile.md | 32 +-
docs/zh/Community/Community-Powered By.md | 41 +-
docs/zh/Community/Feedback.md | 18 +-
docs/zh/Development/Committer.md | 38 +-
docs/zh/Development/ContributeGuide.md | 59 +-
docs/zh/Development/HowToCommit.md | 40 +-
docs/zh/Development/VoteRelease.md | 7 +-
docs/zh/Download/README.md | 73 +-
docs/zh/SystemDesign/Architecture/Architecture.md | 1 -
docs/zh/SystemDesign/Client/RPC.md | 3 -
docs/zh/SystemDesign/Connector/Hive-TsFile.md | 11 +-
docs/zh/SystemDesign/Connector/Spark-IOTDB.md | 39 +-
docs/zh/SystemDesign/Connector/Spark-TsFile.md | 25 +-
docs/zh/SystemDesign/DataQuery/AggregationQuery.md | 31 +-
.../SystemDesign/DataQuery/AlignByDeviceQuery.md | 12 +-
docs/zh/SystemDesign/DataQuery/FillFunction.md | 30 +-
docs/zh/SystemDesign/DataQuery/GroupByFillQuery.md | 37 +-
docs/zh/SystemDesign/DataQuery/GroupByQuery.md | 48 +-
docs/zh/SystemDesign/DataQuery/LastQuery.md | 22 +-
docs/zh/SystemDesign/DataQuery/OrderByTimeQuery.md | 75 +-
.../zh/SystemDesign/DataQuery/QueryFundamentals.md | 58 +-
docs/zh/SystemDesign/DataQuery/RawDataQuery.md | 62 +-
docs/zh/SystemDesign/DataQuery/SeriesReader.md | 24 +-
docs/zh/SystemDesign/QueryEngine/Planner.md | 1 -
.../QueryEngine/ResultSetConstruction.md | 2 +-
.../zh/SystemDesign/SchemaManager/SchemaManager.md | 190 +-
docs/zh/SystemDesign/StorageEngine/Compaction.md | 40 +-
.../SystemDesign/StorageEngine/DataManipulation.md | 41 +-
.../zh/SystemDesign/StorageEngine/DataPartition.md | 24 +-
docs/zh/SystemDesign/StorageEngine/FileLists.md | 39 +-
docs/zh/SystemDesign/StorageEngine/FlushManager.md | 4 +-
docs/zh/SystemDesign/StorageEngine/MergeManager.md | 22 +-
docs/zh/SystemDesign/StorageEngine/Recover.md | 29 +-
.../zh/SystemDesign/StorageEngine/StorageEngine.md | 2 +-
docs/zh/SystemDesign/StorageEngine/WAL.md | 4 +-
docs/zh/SystemDesign/Tools/Sync.md | 105 +-
docs/zh/SystemDesign/TsFile/Format.md | 584 ++---
docs/zh/SystemDesign/TsFile/Read.md | 110 +-
docs/zh/SystemDesign/TsFile/TsFile.md | 1 -
docs/zh/SystemDesign/TsFile/Write.md | 3 +-
.../zh/UserGuide/API/Programming-Cpp-Native-API.md | 87 +-
docs/zh/UserGuide/API/Programming-Go-Native-API.md | 18 +-
docs/zh/UserGuide/API/Programming-JDBC.md | 14 +-
.../UserGuide/API/Programming-Java-Native-API.md | 59 +-
.../UserGuide/API/Programming-Python-Native-API.md | 70 +-
docs/zh/UserGuide/API/Programming-TsFile-API.md | 137 +-
docs/zh/UserGuide/API/Time-zone.md | 1 -
.../Administration-Management/Administration.md | 35 +-
docs/zh/UserGuide/Advanced-Features/Alerting.md | 15 +-
.../Advanced-Features/Continuous-Query.md | 17 +-
docs/zh/UserGuide/Advanced-Features/Select-Into.md | 234 ++
docs/zh/UserGuide/Advanced-Features/Triggers.md | 170 +-
.../Advanced-Features/UDF-User-Defined-Function.md | 225 +-
docs/zh/UserGuide/Appendix/Config-Manual.md | 139 +-
docs/zh/UserGuide/Appendix/SQL-Reference.md | 160 +-
docs/zh/UserGuide/Appendix/Status-Codes.md | 19 +-
docs/zh/UserGuide/CLI/Command-Line-Interface.md | 123 +-
docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 12 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 67 +-
.../Collaboration-of-Edge-and-Cloud/Sync-Tool.md | 40 +-
.../Programming-MQTT.md | 111 +-
.../Programming-Thrift.md | 30 +-
docs/zh/UserGuide/Comparison/TSDB-Comparison.md | 201 +-
docs/zh/UserGuide/Data-Concept/Compression.md | 12 +-
.../Data-Concept/Data-Model-and-Terminology.md | 230 +-
docs/zh/UserGuide/Data-Concept/Data-Type.md | 127 +-
docs/zh/UserGuide/Data-Concept/Encoding.md | 24 +-
docs/zh/UserGuide/Data-Concept/SDT.md | 30 +-
docs/zh/UserGuide/Ecosystem Integration/DBeaver.md | 20 +-
.../UserGuide/Ecosystem Integration/Flink IoTDB.md | 5 +-
.../Ecosystem Integration/Flink TsFile.md | 17 +-
docs/zh/UserGuide/Ecosystem Integration/Grafana.md | 72 +-
.../UserGuide/Ecosystem Integration/Hive TsFile.md | 55 +-
.../Ecosystem Integration/MapReduce TsFile.md | 39 +-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 17 +-
.../Ecosystem Integration/Spark TsFile.md | 88 +-
.../Ecosystem Integration/Writing Data on HDFS.md | 46 +-
.../Ecosystem Integration/Zeppelin-IoTDB.md | 51 +-
.../zh/UserGuide/FAQ/Frequently-asked-questions.md | 33 +-
.../UserGuide/IoTDB-Introduction/Architecture.md | 14 +-
docs/zh/UserGuide/IoTDB-Introduction/Features.md | 8 +-
.../zh/UserGuide/IoTDB-Introduction/Publication.md | 2 +-
docs/zh/UserGuide/IoTDB-Introduction/Scenario.md | 20 +-
.../UserGuide/IoTDB-Introduction/What-is-IoTDB.md | 4 +-
.../DDL-Data-Definition-Language.md | 72 +-
.../DML-Data-Manipulation-Language.md | 364 ++-
.../IoTDB-SQL-Language/Maintenance-Command.md | 10 +-
docs/zh/UserGuide/QuickStart/Files.md | 17 +-
docs/zh/UserGuide/QuickStart/QuickStart.md | 78 +-
docs/zh/UserGuide/QuickStart/ServerFileList.md | 64 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 43 +-
docs/zh/UserGuide/System-Tools/CSV-Tool.md | 24 +-
docs/zh/UserGuide/System-Tools/JMX-Tool.md | 24 +-
.../UserGuide/System-Tools/Load-External-Tsfile.md | 58 +-
docs/zh/UserGuide/System-Tools/MLogParser-Tool.md | 7 +-
.../System-Tools/Monitor-and-Log-Tools.md | 96 +-
docs/zh/UserGuide/System-Tools/NodeTool.md | 117 +-
.../Query-History-Visualization-Tool.md | 6 +-
docs/zh/UserGuide/System-Tools/Watermark-Tool.md | 34 +-
docs/zh/UserGuide/UserGuideReadme.md | 9 +-
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 26 +-
example/{mqtt => mqtt-customize}/README.md | 17 +-
example/{hadoop => mqtt-customize}/pom.xml | 10 +-
.../server/CustomizedJsonPayloadFormatter.java | 62 +
.../org.apache.iotdb.db.mqtt.PayloadFormatter | 1 +
example/pom.xml | 1 +
.../iotdb/HybridTimeseriesSessionExample.java | 129 +
.../org/apache/iotdb/SessionConcurrentExample.java | 199 ++
.../main/java/org/apache/iotdb/SessionExample.java | 47 +
...ablet.java => TsFileWriteVectorWithTablet.java} | 50 +-
.../java/org/apache/iotdb/flink/IoTDBSink.java | 26 +-
.../iotdb/flink/options/IoTDBSinkOptions.java | 11 -
...tITCase.java => RowTSRecordOutputFormatIT.java} | 2 +-
...rmatITCase.java => RowTsFileInputFormatIT.java} | 2 +-
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 68 +-
.../main/java/org/apache/iotdb/jdbc/Constant.java | 3 +
.../src/main/java/org/apache/iotdb/jdbc/Field.java | 52 +-
.../iotdb/jdbc}/GroupedLSBWatermarkEncoder.java | 21 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 16 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 2744 +++++++++++++++++---
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 58 +-
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 38 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 585 ++++-
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 173 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 38 +-
.../java/org/apache/iotdb/jdbc}/ListDataSet.java | 12 +-
.../java/org/apache/iotdb/jdbc/StringUtils.java | 78 +
.../org/apache/iotdb/jdbc}/WatermarkEncoder.java | 3 +-
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 3 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 162 ++
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 32 +-
.../apache/iotdb/jdbc/IoTDBResultMetadataTest.java | 21 +-
pom.xml | 2 +
.../resources/conf/iotdb-engine.properties | 30 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 1 +
.../db/concurrent/IoTDBThreadPoolFactory.java | 18 +
.../org/apache/iotdb/db/concurrent/ThreadName.java | 11 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 50 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 43 +-
.../apache/iotdb/db/cost/statistic/Operation.java | 3 +-
.../apache/iotdb/db/cq/ContinuousQueryTask.java | 6 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 183 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 71 +-
.../compaction/CompactionMergeTaskPoolManager.java | 13 +-
.../level/LevelCompactionTsFileManagement.java | 2 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 15 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 2 +
.../iotdb/db/engine/merge/task/MergeTask.java | 10 +-
.../selectinto/InsertTabletPlanGenerator.java | 254 ++
.../selectinto/InsertTabletPlansIterator.java | 139 +
.../engine/storagegroup/StorageGroupProcessor.java | 199 +-
.../db/engine/storagegroup/TsFileProcessor.java | 10 +-
.../db/engine/storagegroup/TsFileResource.java | 16 +-
.../storagegroup/timeindex/DeviceTimeIndex.java | 15 +-
.../storagegroup/timeindex/FileTimeIndex.java | 76 +-
.../engine/storagegroup/timeindex/ITimeIndex.java | 10 +-
.../storagegroup/timeindex/TimeIndexLevel.java | 10 -
.../virtualSg/VirtualStorageGroupManager.java | 110 +-
.../db/engine/trigger/executor/TriggerEngine.java | 16 +-
.../engine/trigger/executor/TriggerExecutor.java | 8 +-
.../service/TriggerRegistrationService.java | 10 +-
.../iotdb/db/engine/upgrade/UpgradeTask.java | 60 +-
.../exception/query/PathNumOverLimitException.java | 13 +-
.../org/apache/iotdb/db/metadata/MManager.java | 1046 +++-----
.../java/org/apache/iotdb/db/metadata/MTree.java | 708 +++--
.../org/apache/iotdb/db/metadata/MetaUtils.java | 18 +-
.../iotdb/db/metadata/MetadataOperationType.java | 4 +
.../db/metadata/{ => logfile}/MLogTxtWriter.java | 71 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 24 +-
.../db/metadata/{ => logfile}/TagLogFile.java | 2 +-
.../iotdb/db/metadata/mnode/EntityMNode.java | 117 +
.../iotdb/db/metadata/mnode/IEntityMNode.java | 55 +
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 82 +
.../iotdb/db/metadata/mnode/IMeasurementMNode.java | 58 +
.../db/metadata/mnode/IStorageGroupMNode.java | 10 +-
.../iotdb/db/metadata/mnode/InternalMNode.java | 271 ++
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 339 +--
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 207 +-
...roupMNode.java => StorageGroupEntityMNode.java} | 23 +-
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 11 +-
.../apache/iotdb/db/metadata/tag/TagManager.java | 556 ++++
.../iotdb/db/metadata/template/Template.java | 11 +-
.../db/metadata/template/TemplateManager.java | 96 +
.../org/apache/iotdb/db/monitor/StatMonitor.java | 2 +-
.../main/java/org/apache/iotdb/db/qp/Planner.java | 51 +-
.../apache/iotdb/db/qp/constant/SQLConstant.java | 4 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 76 +-
.../org/apache/iotdb/db/qp/logical/Operator.java | 6 +-
.../iotdb/db/qp/logical/crud/QueryOperator.java | 209 +-
.../db/qp/logical/crud/SelectIntoOperator.java | 110 +
.../iotdb/db/qp/logical/sys/LoadFilesOperator.java | 25 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 38 +-
.../db/qp/physical/crud/AlignByDevicePlan.java | 57 +-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 12 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 3 +-
.../iotdb/db/qp/physical/crud/MeasurementInfo.java | 75 +
.../iotdb/db/qp/physical/crud/SelectIntoPlan.java | 113 +
...emplatePlan.java => SetSchemaTemplatePlan.java} | 14 +-
.../iotdb/db/qp/physical/sys/OperateFilePlan.java | 23 +-
...tePlan.java => SetUsingSchemaTemplatePlan.java} | 16 +-
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 191 +-
.../iotdb/db/qp/strategy/LogicalChecker.java | 5 +
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 24 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 8 +-
.../qp/strategy/optimizer/ILogicalOptimizer.java | 3 +-
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 28 +-
.../db/query/control/QueryResourceManager.java | 100 +-
.../iotdb/db/query/control/QueryTimeManager.java | 14 +
.../iotdb/db/query/control/SessionManager.java | 27 +-
.../apache/iotdb/db/query/control/TracingInfo.java | 85 +
.../iotdb/db/query/control/TracingManager.java | 141 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 26 +-
.../iotdb/db/query/executor/LastQueryExecutor.java | 6 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 99 +-
.../reader/universal/DescPriorityMergeReader.java | 5 +-
.../reader/universal/PriorityMergeReader.java | 13 +-
.../apache/iotdb/db/rescon/MemTableManager.java | 4 +
.../apache/iotdb/db/rescon/TVListAllocator.java | 12 +-
.../java/org/apache/iotdb/db/service/IoTDB.java | 4 +-
.../org/apache/iotdb/db/service/RPCService.java | 1 +
.../org/apache/iotdb/db/service/ServiceType.java | 10 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 391 +--
.../org/apache/iotdb/db/service/UpgradeSevice.java | 33 +-
.../iotdb/db/service/thrift/ThriftService.java | 17 +-
.../db/service/thrift/ThriftServiceThread.java | 219 +-
.../iotdb/db/sync/receiver/SyncServerManager.java | 6 +
.../apache/iotdb/db/tools/TsFileRewriteTool.java | 174 +-
.../apache/iotdb/db/tools/TsFileSketchTool.java | 583 +++--
.../org/apache/iotdb/db/tools/mlog/MLogParser.java | 19 +-
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 155 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 21 +-
.../org/apache/iotdb/db/utils/UpgradeUtils.java | 10 -
.../iotdb/db/writelog/recover/LogReplayer.java | 6 +-
.../writelog/recover/TsFileRecoverPerformer.java | 26 +-
.../db/engine/memtable/MemTableFlushTaskTest.java | 22 +-
.../db/engine/memtable/MemTableTestUtils.java | 5 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 3 +-
.../storagegroup/StorageGroupProcessorTest.java | 84 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 9 +-
.../engine/storagegroup/TsFileProcessorTest.java | 14 +-
.../iotdb/db/integration/IoTDBAddSubDeviceIT.java | 11 +-
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 57 +-
.../org/apache/iotdb/db/integration/IoTDBAsIT.java | 2 +-
.../db/integration/IoTDBAutoCreateSchemaIT.java | 6 +-
.../db/integration/IoTDBContinuousQueryIT.java | 147 +-
.../db/integration/IoTDBCreateStorageGroupIT.java | 128 +
.../db/integration/IoTDBCreateTimeseriesIT.java | 34 +-
...ltiRowIT.java => IoTDBInsertWithoutTimeIT.java} | 52 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 22 +-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 121 +-
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 20 +-
.../db/integration/IoTDBQueryMemoryControlIT.java | 20 +-
.../iotdb/db/integration/IoTDBRestartIT.java | 48 +
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 617 +++++
.../db/integration/IoTDBSequenceDataQueryIT.java | 12 +-
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 11 +-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 14 +-
.../db/integration/IoTDBTriggerExecutionIT.java | 43 +-
.../iotdb/db/metadata/MManagerAdvancedTest.java | 20 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 315 ++-
.../iotdb/db/metadata/MManagerImproveTest.java | 8 +-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 103 +-
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 14 +-
.../apache/iotdb/db/metadata/mnode/MNodeTest.java | 41 +-
.../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 2 +-
.../iotdb/db/qp/physical/InsertRowPlanTest.java | 8 +-
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 14 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 83 +-
.../iotdb/db/query/control/TracingManagerTest.java | 7 +-
.../query/reader/series/SeriesReaderTestUtil.java | 2 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 71 +-
.../iotdb/db/tools/TsFileSketchToolTest.java | 4 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 11 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 4 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 3 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 2 +-
...{IoTDBRpcDataSet.java => IoTDBJDBCDataSet.java} | 113 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 6 +-
.../apache/iotdb/session/IoTDBSessionVectorIT.java | 213 ++
.../java/org/apache/iotdb/session/SessionTest.java | 2 +-
site/README-zh.md | 9 +-
site/README.md | 7 +-
site/pom.xml | 100 +-
.../src/main/.asf.yaml | 7 +-
site/src/main/.vuepress/config.js | 31 +-
site/src/main/.vuepress/theme/components/Page.vue | 15 +-
.../theme/global-components/Contributor.vue | 7 +
.../apache/iotdb/spark/db/EnvironmentUtils.java | 111 +-
.../test/java/org/apache/iotdb/db/sql/Cases.java | 235 +-
thrift/src/main/thrift/rpc.thrift | 13 +
.../file/metadata/MetadataIndexConstructor.java | 52 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 17 +-
.../org/apache/iotdb/tsfile/read/common/Path.java | 4 +
.../java/org/apache/iotdb/tsfile/utils/BitMap.java | 5 +
.../apache/iotdb/tsfile/write/TsFileWriter.java | 12 +-
.../tsfile/write/chunk/ChunkGroupWriterImpl.java | 77 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 28 +-
.../tsfile/write/chunk/VectorChunkWriterImpl.java | 5 +-
.../tsfile/write/schema/IMeasurementSchema.java | 5 +
.../tsfile/write/schema/MeasurementSchema.java | 12 +-
.../apache/iotdb/tsfile/write/schema/Schema.java | 28 +-
.../write/schema/VectorMeasurementSchema.java | 12 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 10 +
...ateTest.java => DefaultSchemaTemplateTest.java} | 8 +-
.../tsfile/write/MetadataIndexConstructorTest.java | 478 ++++
.../write/schema/converter/SchemaBuilderTest.java | 4 +-
.../write/writer/VectorChunkWriterImplTest.java | 34 +-
.../write/writer/VectorMeasurementSchemaStub.java | 12 +-
434 files changed, 19128 insertions(+), 11133 deletions(-)
copy
cluster/src/main/java/org/apache/iotdb/cluster/{exception/MemberReadOnlyException.java
=> ClusterIoTDBMBean.java} (67%)
copy
server/src/main/java/org/apache/iotdb/db/query/executor/UDTFQueryExecutor.java
=>
cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutor.java
(91%)
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/MetaClusterServer.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/RaftServer.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/DataHeartbeatServer.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/HeartbeatServer.java
delete mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/server/heartbeat/MetaHeartbeatServer.java
copy cluster/src/{test/java/org/apache/iotdb/cluster/utils/Constants.java =>
main/java/org/apache/iotdb/cluster/server/member/DataGroupMemberMBean.java}
(84%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/server/member/{package-info.java
=> MetaGroupMemberMBean.java} (76%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/{exception/PullFileException.java
=> server/member/RaftMemberMBean.java} (61%)
rename
cluster/src/main/java/org/apache/iotdb/cluster/server/{DataClusterServer.java
=> service/DataGroupServiceImpls.java} (91%)
copy
cluster/src/main/java/org/apache/iotdb/cluster/server/service/{package-info.java
=> DataGroupServiceImplsMBean.java} (82%)
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/ClusterUDTFQueryExecutorTest.java
create mode 100644 docs/UserGuide/Advanced-Features/Select-Into.md
create mode 100644 docs/zh/UserGuide/Advanced-Features/Select-Into.md
copy example/{mqtt => mqtt-customize}/README.md (59%)
copy example/{hadoop => mqtt-customize}/pom.xml (87%)
create mode 100644
example/mqtt-customize/src/main/java/org/apache/iotdb/mqtt/server/CustomizedJsonPayloadFormatter.java
create mode 100644
example/mqtt-customize/src/main/resources/META-INF/services/org.apache.iotdb.db.mqtt.PayloadFormatter
create mode 100644
example/session/src/main/java/org/apache/iotdb/HybridTimeseriesSessionExample.java
create mode 100644
example/session/src/main/java/org/apache/iotdb/SessionConcurrentExample.java
copy
example/tsfile/src/main/java/org/apache/iotdb/tsfile/{TsFileWriteWithTablet.java
=> TsFileWriteVectorWithTablet.java} (65%)
rename
flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/{RowTSRecordOutputFormatITCase.java
=> RowTSRecordOutputFormatIT.java} (95%)
rename
flink-tsfile-connector/src/test/java/org/apache/iotdb/flink/tsfile/{RowTsFileInputFormatITCase.java
=> RowTsFileInputFormatIT.java} (97%)
copy
server/src/main/java/org/apache/iotdb/db/exception/metadata/DeleteFailedException.java
=> jdbc/src/main/java/org/apache/iotdb/jdbc/Field.java (51%)
copy {server/src/main/java/org/apache/iotdb/db/tools/watermark =>
jdbc/src/main/java/org/apache/iotdb/jdbc}/GroupedLSBWatermarkEncoder.java (90%)
copy {server/src/main/java/org/apache/iotdb/db/query/dataset =>
jdbc/src/main/java/org/apache/iotdb/jdbc}/ListDataSet.java (83%)
create mode 100644 jdbc/src/main/java/org/apache/iotdb/jdbc/StringUtils.java
copy {server/src/main/java/org/apache/iotdb/db/tools/watermark =>
jdbc/src/main/java/org/apache/iotdb/jdbc}/WatermarkEncoder.java (96%)
create mode 100644
jdbc/src/test/java/org/apache/iotdb/jdbc/IoTDBDatabaseMetadataTest.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/selectinto/InsertTabletPlanGenerator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/engine/selectinto/InsertTabletPlansIterator.java
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
logfile}/MLogTxtWriter.java (80%)
rename server/src/main/java/org/apache/iotdb/db/metadata/{ =>
logfile}/TagLogFile.java (99%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/EntityMNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/IEntityMNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/IMNode.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/IMeasurementMNode.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/exception/LogExecutionException.java
=>
server/src/main/java/org/apache/iotdb/db/metadata/mnode/IStorageGroupMNode.java
(78%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/mnode/InternalMNode.java
copy
server/src/main/java/org/apache/iotdb/db/metadata/mnode/{StorageGroupMNode.java
=> StorageGroupEntityMNode.java} (72%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/tag/TagManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/metadata/template/TemplateManager.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/logical/crud/SelectIntoOperator.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/crud/MeasurementInfo.java
create mode 100644
server/src/main/java/org/apache/iotdb/db/qp/physical/crud/SelectIntoPlan.java
rename
server/src/main/java/org/apache/iotdb/db/qp/physical/crud/{SetDeviceTemplatePlan.java
=> SetSchemaTemplatePlan.java} (85%)
rename
server/src/main/java/org/apache/iotdb/db/qp/physical/sys/{SetUsingDeviceTemplatePlan.java
=> SetUsingSchemaTemplatePlan.java} (83%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/control/TracingInfo.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBCreateStorageGroupIT.java
copy
server/src/test/java/org/apache/iotdb/db/integration/{IoTDBInsertMultiRowIT.java
=> IoTDBInsertWithoutTimeIT.java} (69%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBSelectIntoIT.java
copy service-rpc/src/main/java/org/apache/iotdb/rpc/{IoTDBRpcDataSet.java =>
IoTDBJDBCDataSet.java} (82%)
create mode 100644
session/src/test/java/org/apache/iotdb/session/IoTDBSessionVectorIT.java
copy
server/src/main/resources/META-INF/services/org.apache.iotdb.db.mqtt.PayloadFormatter
=> site/src/main/.asf.yaml (91%)
rename
tsfile/src/test/java/org/apache/iotdb/tsfile/write/{DefaultDeviceTemplateTest.java
=> DefaultSchemaTemplateTest.java} (93%)
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/write/MetadataIndexConstructorTest.java
