You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ha...@apache.org on 2022/05/09 02:54:09 UTC
[iotdb] branch IOTDB-1239 created (now 1fb779fb06)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch IOTDB-1239
in repository https://gitbox.apache.org/repos/asf/iotdb.git
at 1fb779fb06 merge master
This branch includes the following new commits:
new 1fb779fb06 merge master
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.
[iotdb] 01/01: merge master
Posted by ha...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch IOTDB-1239
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 1fb779fb0621e76a285e8950d4b0ceb0a0470edb
Merge: b197c58d3b bc6c4af55e
Author: HTHou <hh...@outlook.com>
AuthorDate: Mon May 9 10:53:49 2022 +0800
merge master
.asf.yaml | 12 +-
.gitattributes | 1 +
.github/dependabot.yml | 97 +
.github/workflows/client-cpp.yml | 103 +
.github/workflows/client-go.yml | 9 +
.github/workflows/client-python.yml | 63 +
.github/workflows/client.yml | 100 -
.github/workflows/cluster.yml | 52 +
.github/workflows/e2e.yml | 19 +-
.github/workflows/grafana-plugin.yml | 59 +
.github/workflows/influxdb-protocol.yml | 70 +
.github/workflows/main-unix.yml | 14 +-
.github/workflows/main-win.yml | 40 +-
.github/workflows/sonar-coveralls.yml | 24 +-
.gitignore | 7 +-
.mvn/wrapper/MavenWrapperDownloader.java | 2 +-
CONTRIBUTING.md | 162 +
Code Summary.md | 59 +
Jenkinsfile | 46 +-
LICENSE | 10 +
LICENSE-binary | 40 +-
NOTICE | 2 +-
NOTICE-binary | 2 +-
README.md | 147 +-
README_ZH.md | 140 +-
RELEASE_NOTES.md | 438 +-
antlr/pom.xml | 2 +-
.../protocol/influxdb/input/InfluxLineProtocol.g4 | 93 +
.../apache/iotdb/db/qp/sql/InfluxDBSqlParser.g4 | 129 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 944 ++
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 1533 ---
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 1036 ++
checkstyle.xml | 7 +-
cli/pom.xml | 29 +-
cli/src/assembly/resources/sbin/start-cli.bat | 17 +-
cli/src/assembly/resources/sbin/start-cli.sh | 12 +-
cli/src/assembly/resources/tools/export-csv.bat | 15 +-
cli/src/assembly/resources/tools/export-csv.sh | 8 +-
cli/src/assembly/resources/tools/import-csv.bat | 15 +-
cli/src/assembly/resources/tools/import-csv.sh | 8 +-
.../java/org/apache/iotdb/cli/AbstractCli.java | 150 +-
cli/src/main/java/org/apache/iotdb/cli/Cli.java | 70 +-
.../apache/iotdb/cli/IoTDBSyntaxHighlighter.java | 76 +
cli/src/main/java/org/apache/iotdb/cli/WinCli.java | 178 -
.../org/apache/iotdb/cli/utils/JlineUtils.java | 111 +
.../org/apache/iotdb/tool/AbstractCsvTool.java | 116 +-
.../main/java/org/apache/iotdb/tool/ExportCsv.java | 279 +-
.../main/java/org/apache/iotdb/tool/ImportCsv.java | 956 +-
.../java/org/apache/iotdb/cli/AbstractScript.java | 27 +-
.../org/apache/iotdb/cli/StartClientScriptIT.java | 53 +-
.../org/apache/iotdb/tool/CsvLineSplitTest.java | 33 -
.../org/apache/iotdb/tool/ExportCsvTestIT.java | 102 -
.../org/apache/iotdb/tool/ImportCsvTestIT.java | 102 -
.../iotdb/tool/integration/ExportCsvTestIT.java | 105 +
.../iotdb/tool/integration/ImportCsvTestIT.java | 105 +
.../apache/iotdb/tool/unit/WriteCsvFileTestUT.java | 46 +
client-cpp/pom.xml | 33 +-
client-cpp/src/main/CMakeLists.txt | 9 +-
client-cpp/src/main/Session.cpp | 2927 ++--
client-cpp/src/main/Session.h | 1835 ++-
client-cpp/src/test/CMakeLists.txt | 4 +-
client-cpp/src/test/cpp/sessionIT.cpp | 469 +-
client-cpp/src/test/main.cpp | 6 +-
client-py/README.md | 295 +-
client-py/SessionAlignedTimeseriesExample.py | 225 +
client-py/SessionExample.py | 152 +-
client-py/SessionTest.py | 243 -
client-py/iotdb/Session.py | 431 +-
client-py/iotdb/utils/BitMap.py | 30 +
client-py/iotdb/utils/IoTDBConstants.py | 39 +-
client-py/iotdb/utils/IoTDBRpcDataSet.py | 140 +-
client-py/iotdb/utils/NumpyTablet.py | 131 +
client-py/iotdb/utils/SessionDataSet.py | 34 +-
client-py/iotdb/utils/Tablet.py | 97 +-
client-py/pom.xml | 10 +-
client-py/release.sh | 3 +
client-py/requirements.txt | 5 +-
client-py/requirements_dev.txt | 2 +-
client-py/setup.py | 3 +-
client-py/tests/tablet_performance_comparison.py | 300 +
client-py/tests/test_aligned_timeseries.py | 294 +
client-py/tests/test_dataframe.py | 35 +-
client-py/tests/test_numpy_tablet.py | 147 +
client-py/tests/test_one_device.py | 152 +
client-py/tests/test_session.py | 362 +
client-py/tests/test_tablet.py | 109 +
client-py/tests/test_todf.py | 216 +
cluster/pom.xml | 33 +-
cluster/src/assembly/cluster.xml | 4 +
.../resources/conf/iotdb-cluster.properties | 113 +-
cluster/src/assembly/resources/sbin/add-node.bat | 41 +-
cluster/src/assembly/resources/sbin/add-node.sh | 6 +-
.../src/assembly/resources/sbin/remove-node.bat | 110 +
cluster/src/assembly/resources/sbin/remove-node.sh | 72 +
cluster/src/assembly/resources/sbin/start-node.bat | 29 +-
cluster/src/assembly/resources/sbin/start-node.sh | 4 +-
cluster/src/assembly/resources/sbin/stop-node.bat | 2 +-
cluster/src/assembly/resources/sbin/stop-node.sh | 8 +-
.../java/org/apache/iotdb/cluster/ClientMain.java | 14 +-
.../iotdb/cluster/ClusterFileFlushPolicy.java | 9 +-
.../org/apache/iotdb/cluster/ClusterIoTDB.java | 672 +
.../apache/iotdb/cluster/ClusterIoTDBMBean.java | 36 +
.../cluster/ClusterIoTDBServerCommandLine.java | 94 +
.../java/org/apache/iotdb/cluster/ClusterMain.java | 302 -
.../apache/iotdb/cluster/RemoteTsFileResource.java | 7 +-
.../apache/iotdb/cluster/client/BaseFactory.java | 54 +
.../iotdb/cluster/client/ClientCategory.java | 38 +
.../apache/iotdb/cluster/client/ClientManager.java | 223 +
.../iotdb/cluster/client/ClientPoolFactory.java | 101 +
.../iotdb/cluster/client/DataClientProvider.java | 95 -
.../iotdb/cluster/client/IClientManager.java | 35 +
.../cluster/client/async/AsyncBaseFactory.java | 68 +
.../cluster/client/async/AsyncClientFactory.java | 65 -
.../cluster/client/async/AsyncClientPool.java | 216 -
.../cluster/client/async/AsyncDataClient.java | 203 +-
.../client/async/AsyncDataHeartbeatClient.java | 81 -
.../cluster/client/async/AsyncMetaClient.java | 151 +-
.../client/async/AsyncMetaHeartbeatClient.java | 81 -
.../cluster/client/sync/SyncClientAdaptor.java | 129 +-
.../cluster/client/sync/SyncClientFactory.java | 40 -
.../iotdb/cluster/client/sync/SyncClientPool.java | 169 -
.../iotdb/cluster/client/sync/SyncDataClient.java | 118 +-
.../client/sync/SyncDataHeartbeatClient.java | 77 -
.../iotdb/cluster/client/sync/SyncMetaClient.java | 123 +-
.../client/sync/SyncMetaHeartbeatClient.java | 77 -
.../apache/iotdb/cluster/config/ClusterConfig.java | 152 +-
.../iotdb/cluster/config/ClusterConstant.java | 110 +-
.../iotdb/cluster/config/ClusterDescriptor.java | 62 +-
.../iotdb/cluster/coordinator/Coordinator.java | 462 +-
.../exception/ChangeMembershipException.java | 28 +
.../exception/CheckConsistencyException.java | 4 +-
.../apache/iotdb/cluster/log/LogDispatcher.java | 22 +-
.../org/apache/iotdb/cluster/log/LogParser.java | 10 +
.../org/apache/iotdb/cluster/log/Snapshot.java | 5 +
.../iotdb/cluster/log/StableEntryManager.java | 6 +
.../cluster/log/applier/AsyncDataLogApplier.java | 24 +-
.../iotdb/cluster/log/applier/BaseApplier.java | 158 +-
.../iotdb/cluster/log/applier/DataLogApplier.java | 102 +-
.../iotdb/cluster/log/applier/MetaLogApplier.java | 41 +-
.../iotdb/cluster/log/catchup/CatchUpTask.java | 63 +-
.../iotdb/cluster/log/catchup/LogCatchUpTask.java | 20 +-
.../cluster/log/catchup/SnapshotCatchUpTask.java | 5 +-
.../iotdb/cluster/log/logtypes/AddNodeLog.java | 52 +-
.../iotdb/cluster/log/logtypes/CloseFileLog.java | 2 +-
.../cluster/log/logtypes/PhysicalPlanLog.java | 2 +-
.../iotdb/cluster/log/logtypes/RemoveNodeLog.java | 48 +-
.../cluster/log/manage/CommittedEntryManager.java | 26 +-
.../manage/FilePartitionedSnapshotLogManager.java | 71 +-
.../log/manage/MetaSingleSnapshotLogManager.java | 24 +-
.../log/manage/PartitionedSnapshotLogManager.java | 63 +-
.../iotdb/cluster/log/manage/RaftLogManager.java | 186 +-
.../log/manage/UnCommittedEntryManager.java | 2 +-
.../serializable/SyncLogDequeSerializer.java | 44 +-
.../iotdb/cluster/log/snapshot/FileSnapshot.java | 136 +-
.../cluster/log/snapshot/MetaSimpleSnapshot.java | 143 +-
.../cluster/log/snapshot/PartitionedSnapshot.java | 45 +-
.../cluster/log/snapshot/PullSnapshotTask.java | 47 +-
.../log/snapshot/PullSnapshotTaskDescriptor.java | 3 +-
.../cluster/log/snapshot/SnapshotInstaller.java | 5 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 1800 ---
.../iotdb/cluster/metadata/CSchemaProcessor.java | 1743 +++
.../apache/iotdb/cluster/metadata/MetaPuller.java | 252 +-
.../cluster/partition/NodeAdditionResult.java | 15 +-
.../iotdb/cluster/partition/NodeRemovalResult.java | 41 +-
.../iotdb/cluster/partition/PartitionGroup.java | 69 +-
.../iotdb/cluster/partition/PartitionTable.java | 51 +-
.../partition/balancer/DefaultSlotBalancer.java | 121 +
.../cluster/partition/balancer/SlotBalancer.java | 43 +
.../iotdb/cluster/partition/slot/SlotManager.java | 114 +-
.../partition/slot/SlotNodeAdditionResult.java | 10 +-
.../partition/slot/SlotNodeRemovalResult.java | 45 +-
.../cluster/partition/slot/SlotPartitionTable.java | 383 +-
.../iotdb/cluster/partition/slot/SlotStrategy.java | 19 +-
.../partition/slot/SlotTimePartitionFilter.java | 56 +
.../cluster/query/ClusterConcatPathOptimizer.java | 37 -
.../cluster/query/ClusterDataQueryExecutor.java | 31 +-
.../cluster/query/ClusterPhysicalGenerator.java | 47 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 552 +-
.../iotdb/cluster/query/ClusterPlanRouter.java | 220 +-
.../apache/iotdb/cluster/query/ClusterPlanner.java | 29 +-
.../iotdb/cluster/query/ClusterQueryRouter.java | 49 +-
.../cluster/query/ClusterUDTFQueryExecutor.java | 103 +
.../iotdb/cluster/query/LocalQueryExecutor.java | 377 +-
.../iotdb/cluster/query/RemoteQueryContext.java | 12 +-
.../query/aggregate/ClusterAggregateExecutor.java | 37 +-
.../cluster/query/aggregate/ClusterAggregator.java | 55 +-
.../query/dataset/ClusterAlignByDeviceDataSet.java | 61 -
.../cluster/query/fill/ClusterFillExecutor.java | 58 +-
.../cluster/query/fill/ClusterLinearFill.java | 12 +-
.../cluster/query/fill/ClusterPreviousFill.java | 88 +-
.../cluster/query/fill/PreviousFillArguments.java | 2 +-
.../iotdb/cluster/query/filter/SlotSgFilter.java | 2 +-
.../cluster/query/filter/SlotTsFileFilter.java | 17 +-
.../groupby/ClusterGroupByNoVFilterDataSet.java | 16 +-
.../groupby/ClusterGroupByVFilterDataSet.java | 23 +-
.../query/groupby/MergeGroupByExecutor.java | 7 +-
.../query/groupby/RemoteGroupByExecutor.java | 76 +-
.../query/last/ClusterLastQueryExecutor.java | 110 +-
.../cluster/query/manage/ClusterQueryManager.java | 10 +-
.../query/manage/ClusterSessionManager.java | 138 +
.../cluster/query/reader/ClusterReaderFactory.java | 462 +-
.../cluster/query/reader/ClusterTimeGenerator.java | 72 +-
.../iotdb/cluster/query/reader/DataSourceInfo.java | 60 +-
.../iotdb/cluster/query/reader/EmptyReader.java | 2 +-
.../reader/ManagedDescPriorityMergeReader.java | 96 +
.../cluster/query/reader/ManagedMergeReader.java | 94 -
.../query/reader/ManagedPriorityMergeReader.java | 94 +
.../reader/RemoteSeriesReaderByTimestamp.java | 14 +-
.../query/reader/RemoteSimpleSeriesReader.java | 14 +-
.../mult/AssignPathAscPriorityMergeReader.java | 49 +
.../mult/AssignPathDescPriorityMergeReader.java | 49 +
.../reader/mult/AssignPathManagedMergeReader.java | 43 +-
.../reader/mult/AssignPathPriorityMergeReader.java | 66 -
.../mult/IAssignPathPriorityMergeReader.java | 47 +
.../cluster/query/reader/mult/MultBatchReader.java | 5 +-
.../query/reader/mult/MultDataSourceInfo.java | 60 +-
.../cluster/query/reader/mult/MultElement.java | 49 +
.../query/reader/mult/RemoteMultSeriesReader.java | 39 +-
.../apache/iotdb/cluster/server/ClientServer.java | 330 -
.../iotdb/cluster/server/ClusterRPCService.java | 110 +
.../cluster/server/ClusterRPCServiceMBean.java | 35 +
.../iotdb/cluster/server/ClusterTSServiceImpl.java | 47 +
.../iotdb/cluster/server/DataClusterServer.java | 966 --
.../iotdb/cluster/server/MetaClusterServer.java | 369 -
.../cluster/server/PullSnapshotHintService.java | 83 +-
.../apache/iotdb/cluster/server/RaftServer.java | 263 -
.../org/apache/iotdb/cluster/server/Response.java | 17 +-
.../iotdb/cluster/server/StoppedMemberManager.java | 42 +-
.../server/basic/ClusterServiceProvider.java | 95 +
.../server/clusterinfo/ClusterInfoServer.java | 90 +
.../server/clusterinfo/ClusterInfoServerMBean.java | 22 +
.../server/clusterinfo/ClusterInfoServiceImpl.java | 71 +
.../ClusterInfoServiceThriftHandler.java | 55 +
.../handlers/caller/AppendNodeEntryHandler.java | 8 +-
.../server/handlers/caller/ElectionHandler.java | 23 +
.../server/handlers/caller/HeartbeatHandler.java | 30 +-
.../server/handlers/caller/LogCatchUpHandler.java | 9 +
.../server/handlers/caller/NodeStatusHandler.java | 10 +-
.../handlers/caller/PreviousFillHandler.java | 28 +-
.../caller/PullMeasurementSchemaHandler.java | 13 +-
.../handlers/caller/ShowTimeSeriesHandler.java | 121 +
.../handlers/forwarder/ForwardPlanHandler.java | 2 +-
.../server/heartbeat/DataHeartbeatServer.java | 83 -
.../server/heartbeat/DataHeartbeatThread.java | 8 +-
.../cluster/server/heartbeat/HeartbeatServer.java | 212 -
.../cluster/server/heartbeat/HeartbeatThread.java | 119 +-
.../server/heartbeat/MetaHeartbeatServer.java | 91 -
.../server/heartbeat/MetaHeartbeatThread.java | 23 +
.../cluster/server/member/DataGroupMember.java | 752 +-
.../server/member/DataGroupMemberMBean.java | 25 +
.../cluster/server/member/MetaGroupMember.java | 1200 +-
.../server/member/MetaGroupMemberMBean.java | 35 +
.../iotdb/cluster/server/member/RaftMember.java | 676 +-
.../cluster/server/member/RaftMemberMBean.java | 53 +
.../iotdb/cluster/server/monitor/NodeReport.java | 9 +-
.../cluster/server/monitor/NodeStatusManager.java | 2 +-
.../server/raft/AbstractDataRaftService.java | 54 +
.../server/raft/AbstractMetaRaftService.java | 52 +
.../cluster/server/raft/AbstractRaftService.java | 76 +
.../server/raft/DataRaftHeartBeatService.java | 62 +
.../server/raft/DataRaftHeartBeatServiceMBean.java | 22 +
.../iotdb/cluster/server/raft/DataRaftService.java | 59 +
.../cluster/server/raft/DataRaftServiceMBean.java | 22 +
.../server/raft/MetaRaftHeartBeatService.java | 62 +
.../server/raft/MetaRaftHeartBeatServiceMBean.java | 22 +
.../iotdb/cluster/server/raft/MetaRaftService.java | 59 +
.../cluster/server/raft/MetaRaftServiceMBean.java | 22 +
.../cluster/server/raft/RaftServiceHandler.java | 43 +
.../cluster/server/service/BaseAsyncService.java | 12 +-
.../cluster/server/service/BaseSyncService.java | 8 +-
.../cluster/server/service/DataAsyncService.java | 105 +-
.../cluster/server/service/DataGroupEngine.java | 510 +
.../server/service/DataGroupEngineMBean.java | 31 +
.../server/service/DataGroupServiceImpls.java | 749 ++
.../cluster/server/service/DataSyncService.java | 103 +-
.../cluster/server/service/MetaAsyncService.java | 62 +-
.../cluster/server/service/MetaSyncService.java | 70 +-
.../apache/iotdb/cluster/utils/ClientUtils.java | 64 +-
.../iotdb/cluster/utils/ClusterQueryUtils.java | 66 +-
.../apache/iotdb/cluster/utils/ClusterUtils.java | 136 +-
.../iotdb/cluster/utils/NodeSerializeUtils.java | 2 +
.../apache/iotdb/cluster/utils/PartitionUtils.java | 272 +-
.../apache/iotdb/cluster/utils/PlanSerializer.java | 12 +-
.../apache/iotdb/cluster/utils/StatusUtils.java | 29 +-
.../cluster/utils/nodetool/ClusterMonitor.java | 227 +-
.../utils/nodetool/ClusterMonitorMBean.java | 29 +-
.../iotdb/cluster/utils/nodetool/NodeTool.java | 13 +-
.../cluster/utils/nodetool/function/Header.java | 60 +
.../cluster/utils/nodetool/function/Host.java | 77 -
.../cluster/utils/nodetool/function/Migration.java | 59 +
.../utils/nodetool/function/NodeToolCmd.java | 23 +-
.../cluster/utils/nodetool/function/Partition.java | 6 +-
.../cluster/utils/nodetool/function/Ring.java | 15 +-
.../cluster/utils/nodetool/function/Slot.java | 63 +
.../cluster/utils/nodetool/function/Status.java | 29 +-
.../iotdb/cluster/client/BaseClientTest.java | 156 +
.../iotdb/cluster/client/ClientManagerTest.java | 212 +
.../cluster/client/ClientPoolFactoryTest.java | 293 +
.../cluster/client/DataClientProviderTest.java | 242 -
.../iotdb/cluster/client/MockClientManager.java | 47 +
.../cluster/client/async/AsyncClientPoolTest.java | 198 -
.../cluster/client/async/AsyncDataClientTest.java | 115 +-
.../client/async/AsyncDataHeartbeatClientTest.java | 42 -
.../cluster/client/async/AsyncMetaClientTest.java | 114 +-
.../client/async/AsyncMetaHeartbeatClientTest.java | 43 -
.../cluster/client/sync/SyncClientAdaptorTest.java | 103 +-
.../cluster/client/sync/SyncClientPoolTest.java | 167 -
.../cluster/client/sync/SyncDataClientTest.java | 172 +-
.../client/sync/SyncDataHeartbeatClientTest.java | 66 -
.../cluster/client/sync/SyncMetaClientTest.java | 170 +-
.../client/sync/SyncMetaHeartbeatClientTest.java | 66 -
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 37 +-
.../cluster/common/TestAsyncClientFactory.java | 55 -
.../iotdb/cluster/common/TestAsyncDataClient.java | 50 +-
.../iotdb/cluster/common/TestAsyncMetaClient.java | 9 +-
.../iotdb/cluster/common/TestDataGroupMember.java | 14 +-
.../iotdb/cluster/common/TestLogApplier.java | 4 +-
.../iotdb/cluster/common/TestMetaGroupMember.java | 5 +-
.../apache/iotdb/cluster/common/TestSnapshot.java | 10 +-
.../cluster/common/TestSyncClientFactory.java | 75 -
.../org/apache/iotdb/cluster/common/TestUtils.java | 50 +-
.../cluster/integration/BaseSingleNodeTest.java | 16 +-
.../iotdb/cluster/integration/SingleNodeTest.java | 39 +-
.../iotdb/cluster/log/CommitLogCallbackTest.java | 2 +-
.../iotdb/cluster/log/CommitLogTaskTest.java | 5 +-
.../iotdb/cluster/log/LogDispatcherTest.java | 15 +-
.../apache/iotdb/cluster/log/LogParserTest.java | 25 +-
.../log/applier/AsyncDataLogApplierTest.java | 10 +-
.../cluster/log/applier/DataLogApplierTest.java | 344 +-
.../cluster/log/applier/MetaLogApplierTest.java | 24 +-
.../iotdb/cluster/log/catchup/CatchUpTaskTest.java | 33 +-
.../cluster/log/catchup/LogCatchUpTaskTest.java | 26 +-
.../log/catchup/SnapshotCatchUpTaskTest.java | 24 +-
.../cluster/log/logtypes/SerializeLogTest.java | 13 +-
.../FilePartitionedSnapshotLogManagerTest.java | 12 +-
.../manage/MetaSingleSnapshotLogManagerTest.java | 6 +-
.../serializable/SyncLogDequeSerializerTest.java | 4 +-
.../cluster/log/snapshot/DataSnapshotTest.java | 38 +-
.../cluster/log/snapshot/FileSnapshotTest.java | 74 +-
.../log/snapshot/MetaSimpleSnapshotTest.java | 183 +-
.../log/snapshot/PartitionedSnapshotTest.java | 101 +-
.../cluster/log/snapshot/PullSnapshotTaskTest.java | 54 +-
.../iotdb/cluster/log/snapshot/SimpleSnapshot.java | 4 +-
.../iotdb/cluster/partition/MManagerWhiteBox.java | 54 -
.../cluster/partition/SchemaProcessorWhiteBox.java | 54 +
.../iotdb/cluster/partition/SlotManagerTest.java | 6 +-
.../cluster/partition/SlotPartitionTableTest.java | 130 +-
.../apache/iotdb/cluster/query/BaseQueryTest.java | 20 +-
.../query/ClusterAggregateExecutorTest.java | 67 +-
.../query/ClusterDataQueryExecutorTest.java | 122 +-
.../cluster/query/ClusterFillExecutorTest.java | 140 -
.../query/ClusterPhysicalGeneratorTest.java | 36 +-
.../cluster/query/ClusterPlanExecutorTest.java | 41 +-
.../iotdb/cluster/query/ClusterPlannerTest.java | 1 -
.../cluster/query/ClusterQueryRouterTest.java | 114 +-
.../query/ClusterUDTFQueryExecutorTest.java | 121 +
.../iotdb/cluster/query/LoadConfigurationTest.java | 2 +-
.../query/fill/ClusterFillExecutorTest.java | 170 +
.../ClusterGroupByNoVFilterDataSetTest.java | 17 +-
.../groupby/ClusterGroupByVFilterDataSetTest.java | 23 +-
.../query/groupby/MergeGroupByExecutorTest.java | 46 +-
.../query/groupby/RemoteGroupByExecutorTest.java | 49 +-
.../query/last/ClusterLastQueryExecutorTest.java | 95 +
.../query/manage/ClusterQueryManagerTest.java | 12 +-
.../cluster/query/manage/QueryCoordinatorTest.java | 8 +-
.../query/reader/ClusterReaderFactoryTest.java | 85 +
.../query/reader/ClusterTimeGeneratorTest.java | 69 +-
.../cluster/query/reader/DatasourceInfoTest.java | 55 +-
.../reader/RemoteSeriesReaderByTimestampTest.java | 135 +-
.../query/reader/RemoteSimpleSeriesReaderTest.java | 107 +-
.../mult/AssignPathManagedMergeReaderTest.java | 124 +-
.../mult/MultSeriesRawDataPointReaderTest.java | 2 +-
.../reader/mult/RemoteMultSeriesReaderTest.java | 226 +-
.../server/clusterinfo/ClusterInfoServerTest.java | 99 +
.../clusterinfo/ClusterInfoServiceImplTest.java | 100 +
.../caller/AppendGroupEntryHandlerTest.java | 3 +-
.../caller/AppendNodeEntryHandlerTest.java | 3 +-
.../handlers/caller/ElectionHandlerTest.java | 3 +-
.../handlers/caller/HeartbeatHandlerTest.java | 20 +-
.../handlers/caller/LogCatchUpHandlerTest.java | 3 +-
.../caller/PullMeasurementSchemaHandlerTest.java | 12 +-
.../handlers/forwarder/ForwardPlanHandlerTest.java | 6 +-
.../server/heartbeat/DataHeartbeatThreadTest.java | 13 +-
.../server/heartbeat/HeartbeatThreadTest.java | 25 +-
.../server/heartbeat/MetaHeartbeatThreadTest.java | 41 +-
.../iotdb/cluster/server/member/BaseMember.java | 113 +-
.../cluster/server/member/DataGroupMemberTest.java | 275 +-
.../cluster/server/member/MetaGroupMemberTest.java | 377 +-
.../cluster/server/member/RaftMemberTest.java | 5 +-
.../cluster/utils/CreateTemplatePlanUtil.java | 74 +
.../iotdb/cluster/utils/SerializeUtilTest.java | 24 +-
cluster/src/test/resources/logback-test.xml | 41 +
cluster/src/test/resources/logback.xml | 45 -
.../resources/node1conf/iotdb-cluster.properties | 3 +-
.../resources/node1conf/iotdb-engine.properties | 13 +-
.../src/test/resources/node1conf/iotdb-metric.yml | 21 +
cluster/src/test/resources/node1conf/logback.xml | 282 +
.../resources/node2conf/iotdb-cluster.properties | 3 +-
.../resources/node2conf/iotdb-engine.properties | 13 +-
.../src/test/resources/node2conf/iotdb-metric.yml | 21 +
cluster/src/test/resources/node2conf/logback.xml | 282 +
.../resources/node3conf/iotdb-cluster.properties | 3 +-
.../resources/node3conf/iotdb-engine.properties | 13 +-
.../src/test/resources/node3conf/iotdb-metric.yml | 21 +
cluster/src/test/resources/node3conf/logback.xml | 282 +
code-coverage/pom.xml | 5 +-
compile-tools/pom.xml | 34 +-
compile-tools/thrift/pom.xml | 46 +-
confignode/pom.xml | 107 +
confignode/src/assembly/confignode.xml | 45 +
.../src/assembly/resources/conf/confignode-env.bat | 146 +
.../src/assembly/resources/conf/confignode-env.sh | 264 +
.../resources/conf/iotdb-confignode.properties | 212 +
confignode/src/assembly/resources/conf/jmx.access | 22 +
.../src/assembly/resources/conf/jmx.password | 22 +
.../src/assembly/resources/conf/logback-tool.xml | 22 +
confignode/src/assembly/resources/conf/logback.xml | 140 +
.../assembly/resources/sbin/start-confignode.bat | 123 +
.../assembly/resources/sbin/start-confignode.sh | 79 +
.../assembly/resources/sbin/stop-confignode.bat | 38 +
.../src/assembly/resources/sbin/stop-confignode.sh | 42 +
.../confignode/client/AsyncDataNodeClientPool.java | 106 +
.../client/ConfigNodeClientPoolFactory.java | 74 +
.../client/SyncConfigNodeClientPool.java | 107 +
.../client/handlers/InitRegionHandler.java | 56 +
.../iotdb/confignode/conf/ConfigNodeConf.java | 377 +
.../iotdb/confignode/conf/ConfigNodeConstant.java | 51 +
.../confignode/conf/ConfigNodeDescriptor.java | 238 +
.../confignode/conf/ConfigNodeStartupCheck.java | 356 +
.../consensus/request/ConfigRequest.java | 188 +
.../consensus/request/ConfigRequestType.java | 59 +
.../consensus/request/auth/AuthorReq.java | 248 +
.../request/read/CountStorageGroupReq.java | 86 +
.../consensus/request/read/GetDataNodeInfoReq.java | 68 +
.../request/read/GetDataPartitionReq.java | 146 +
.../request/read/GetOrCreateDataPartitionReq.java | 28 +
.../read/GetOrCreateSchemaPartitionReq.java | 28 +
.../request/read/GetSchemaPartitionReq.java | 103 +
.../consensus/request/read/GetStorageGroupReq.java | 34 +
.../request/write/ApplyConfigNodeReq.java | 71 +
.../request/write/CreateDataPartitionReq.java | 130 +
.../consensus/request/write/CreateRegionsReq.java | 80 +
.../request/write/CreateSchemaPartitionReq.java | 100 +
.../consensus/request/write/DeleteRegionsReq.java | 79 +
.../request/write/DeleteStorageGroupReq.java | 69 +
.../request/write/RegisterDataNodeReq.java | 69 +
.../request/write/SetDataReplicationFactorReq.java | 80 +
.../write/SetSchemaReplicationFactorReq.java | 80 +
.../request/write/SetStorageGroupReq.java | 71 +
.../consensus/request/write/SetTTLReq.java | 79 +
.../request/write/SetTimePartitionIntervalReq.java | 80 +
.../consensus/response/CountStorageGroupResp.java | 54 +
.../response/DataNodeConfigurationResp.java | 71 +
.../consensus/response/DataNodeLocationsResp.java | 56 +
.../consensus/response/DataPartitionResp.java | 62 +
.../consensus/response/PermissionInfoResp.java | 56 +
.../consensus/response/SchemaPartitionResp.java | 57 +
.../consensus/response/StorageGroupSchemaResp.java | 55 +
.../statemachine/PartitionRegionStateMachine.java | 128 +
.../confignode/exception/ConfigNodeException.java | 26 +
.../physical/UnknownPhysicalPlanTypeException.java | 29 +
.../confignode/manager/ClusterSchemaManager.java | 297 +
.../iotdb/confignode/manager/ConfigManager.java | 448 +
.../iotdb/confignode/manager/ConsensusManager.java | 144 +
.../iotdb/confignode/manager/LoadManager.java | 34 +
.../apache/iotdb/confignode/manager/Manager.java | 189 +
.../iotdb/confignode/manager/NodeManager.java | 220 +
.../iotdb/confignode/manager/PartitionManager.java | 237 +
.../confignode/manager/PermissionManager.java | 69 +
.../confignode/partition/DataPartitionRule.java | 50 +
.../iotdb/confignode/persistence/AuthorInfo.java | 346 +
.../confignode/persistence/ClusterSchemaInfo.java | 360 +
.../iotdb/confignode/persistence/NodeInfo.java | 299 +
.../confignode/persistence/PartitionInfo.java | 335 +
.../executor/ConfigRequestExecutor.java | 141 +
.../iotdb/confignode/service/ConfigNode.java | 124 +
.../confignode/service/ConfigNodeCommandLine.java | 81 +
.../iotdb/confignode/service/ConfigNodeMBean.java | 21 +
.../service/thrift/ConfigNodeRPCService.java | 89 +
.../thrift/ConfigNodeRPCServiceHandler.java | 52 +
.../service/thrift/ConfigNodeRPCServiceMBean.java | 22 +
.../thrift/ConfigNodeRPCServiceProcessor.java | 346 +
.../iotdb/confignode/cli/TemporaryClientDemo.java | 76 +
.../consensus/request/ConfigRequestSerDeTest.java | 564 +
.../hash/DeviceGroupHashExecutorManualTest.java | 95 +
.../thrift/ConfigNodeRPCServiceProcessorTest.java | 941 ++
.../confignode1conf/iotdb-confignode.properties | 29 +
.../src/test/resources/confignode1conf/logback.xml | 140 +
.../confignode2conf/iotdb-confignode.properties | 29 +
.../src/test/resources/confignode2conf/logback.xml | 140 +
.../confignode3conf/iotdb-confignode.properties | 29 +
.../src/test/resources/confignode3conf/logback.xml | 140 +
consensus/README.md | 163 +
consensus/pom.xml | 60 +
.../apache/iotdb/consensus/ConsensusFactory.java | 57 +
.../org/apache/iotdb/consensus/IConsensus.java | 66 +
.../org/apache/iotdb/consensus/IStateMachine.java | 108 +
.../iotdb/consensus/common/ConsensusGroup.java | 62 +
.../org/apache/iotdb/consensus/common/DataSet.java | 22 +
.../org/apache/iotdb/consensus/common/Peer.java | 67 +
.../common/request/ByteBufferConsensusRequest.java | 44 +
.../common/request/IConsensusRequest.java | 27 +
.../common/response/ConsensusGenericResponse.java | 64 +
.../common/response/ConsensusReadResponse.java | 65 +
.../common/response/ConsensusResponse.java | 39 +
.../common/response/ConsensusWriteResponse.java | 65 +
.../consensus/exception/ConsensusException.java | 31 +
.../ConsensusGroupAlreadyExistException.java | 36 +
.../exception/ConsensusGroupNotExistException.java | 36 +
.../exception/IllegalPeerEndpointException.java | 32 +
.../exception/IllegalPeerNumException.java | 29 +
.../PeerAlreadyInConsensusGroupException.java | 31 +
.../PeerNotInConsensusGroupException.java | 29 +
.../exception/RatisRequestFailedException.java | 26 +
.../ratis/ApplicationStateMachineProxy.java | 192 +
.../apache/iotdb/consensus/ratis/RatisClient.java | 107 +
.../iotdb/consensus/ratis/RatisConsensus.java | 595 +
.../iotdb/consensus/ratis/RequestMessage.java | 66 +
.../iotdb/consensus/ratis/ResponseMessage.java | 66 +
.../iotdb/consensus/ratis/SnapshotStorage.java | 144 +
.../org/apache/iotdb/consensus/ratis/Utils.java | 148 +
.../consensus/standalone/StandAloneConsensus.java | 234 +
.../consensus/standalone/StandAloneServerImpl.java | 77 +
consensus/src/main/resources/logback-test.xml | 31 +
.../apache/iotdb/consensus/EmptyStateMachine.java | 53 +
.../iotdb/consensus/ratis/RatisConsensusTest.java | 236 +
.../apache/iotdb/consensus/ratis/SnapshotTest.java | 120 +
.../apache/iotdb/consensus/ratis/TestUtils.java | 160 +
.../apache/iotdb/consensus/ratis/UtilsTest.java | 37 +
.../iotdb/consensus/standalone/RecoveryTest.java | 94 +
.../standalone/StandAloneConsensusTest.java | 296 +
cross-tests/pom.xml | 13 +-
.../tests/tools/importCsv/AbstractScript.java | 50 +-
.../tests/tools/importCsv/ExportCsvTestIT.java | 237 +-
.../tests/tools/importCsv/ImportCsvTestIT.java | 415 +-
distribution/pom.xml | 37 +-
distribution/src/assembly/all.xml | 12 +-
distribution/src/assembly/grafana-connector.xml | 48 +
distribution/src/assembly/grafana-plugin.xml | 38 +
distribution/src/assembly/grafana.xml | 48 -
distribution/src/assembly/server.xml | 8 +
docker/ReadMe.md | 95 +-
.../main/DockerCompose/docker-compose-grafana.yml | 50 +
docker/src/main/Dockerfile | 43 -
docker/src/main/Dockerfile-0.11.3 | 41 +
docker/src/main/Dockerfile-0.11.4 | 41 +
docker/src/main/Dockerfile-0.12.0-cluster | 53 +
docker/src/main/Dockerfile-0.12.0-node | 45 +
docker/src/main/Dockerfile-0.12.1-cluster | 53 +
docker/src/main/Dockerfile-0.12.1-node | 45 +
docker/src/main/Dockerfile-0.12.2-cluster | 53 +
docker/src/main/Dockerfile-0.12.2-grafana | 41 +
docker/src/main/Dockerfile-0.12.2-node | 45 +
docker/src/main/Dockerfile-cluster | 44 +
docker/src/main/Dockerfile-single | 45 +
docker/src/main/Dockerfile-single-influxdb | 46 +
docs/Community/About.md | 99 +
docs/Community/Community-Powered By.md | 2 +-
docs/Community/Materials.md | 24 +-
docs/Development/ContributeGuide.md | 140 +-
docs/Development/HowToCommit.md | 18 +
docs/Development/VoteRelease.md | 8 +-
docs/Download/README.md | 101 +-
docs/SystemDesign/Architecture/Architecture.md | 54 -
docs/SystemDesign/Client/RPC.md | 56 -
docs/SystemDesign/Connector/Hive-TsFile.md | 114 -
docs/SystemDesign/Connector/Spark-IOTDB.md | 87 -
docs/SystemDesign/Connector/Spark-TsFile.md | 114 -
docs/SystemDesign/DataQuery/AggregationQuery.md | 136 -
docs/SystemDesign/DataQuery/AlignByDeviceQuery.md | 272 -
docs/SystemDesign/DataQuery/DataQuery.md | 46 -
docs/SystemDesign/DataQuery/FillFunction.md | 159 -
docs/SystemDesign/DataQuery/GroupByFillQuery.md | 177 -
docs/SystemDesign/DataQuery/GroupByQuery.md | 283 -
docs/SystemDesign/DataQuery/LastQuery.md | 137 -
docs/SystemDesign/DataQuery/QueryFundamentals.md | 161 -
docs/SystemDesign/DataQuery/RawDataQuery.md | 303 -
docs/SystemDesign/DataQuery/SeriesReader.md | 384 -
docs/SystemDesign/QueryEngine/PlanExecutor.md | 26 -
docs/SystemDesign/QueryEngine/Planner.md | 65 -
docs/SystemDesign/QueryEngine/QueryEngine.md | 64 -
.../QueryEngine/ResultSetConstruction.md | 177 -
docs/SystemDesign/SchemaManager/SchemaManager.md | 329 -
.../SystemDesign/StorageEngine/DataManipulation.md | 104 -
docs/SystemDesign/StorageEngine/DataPartition.md | 86 -
docs/SystemDesign/StorageEngine/FlushManager.md | 84 -
docs/SystemDesign/StorageEngine/MergeManager.md | 107 -
docs/SystemDesign/StorageEngine/Recover.md | 106 -
docs/SystemDesign/StorageEngine/StorageEngine.md | 68 -
docs/SystemDesign/StorageEngine/WAL.md | 48 -
docs/SystemDesign/Tools/Sync.md | 249 -
docs/SystemDesign/TsFile/Format.md | 587 -
docs/SystemDesign/TsFile/Read.md | 559 -
docs/SystemDesign/TsFile/TsFile.md | 30 -
docs/SystemDesign/TsFile/Write.md | 126 -
docs/UserGuide/API/InfluxDB-Protocol.md | 344 +
docs/UserGuide/API/Programming-Cpp-Native-API.md | 409 +
docs/UserGuide/API/Programming-Go-Native-API.md | 65 +
docs/UserGuide/API/Programming-JDBC.md | 23 +-
docs/UserGuide/API/Programming-Java-Native-API.md | 629 +
docs/UserGuide/API/Programming-MQTT.md | 182 +
docs/UserGuide/API/Programming-Native-API.md | 335 -
docs/UserGuide/API/Programming-Other-Languages.md | 271 -
.../UserGuide/API/Programming-Python-Native-API.md | 405 +
.../Programming-Thrift.md | 0
docs/UserGuide/API/Programming-TsFile-API.md | 163 +-
docs/UserGuide/API/RestService.md | 928 ++
docs/UserGuide/API/Status-Codes.md | 108 +
.../Administration-Management/Administration.md | 198 +-
docs/UserGuide/Appendix/Config-Manual.md | 686 -
docs/UserGuide/Appendix/SQL-Reference.md | 1145 --
docs/UserGuide/Appendix/Status-Codes.md | 107 -
docs/UserGuide/CLI/Command-Line-Interface.md | 194 -
docs/UserGuide/Cluster/Cluster-Setup-Example.md | 278 +-
docs/UserGuide/Cluster/Cluster-Setup.md | 524 +-
.../Collaboration-of-Edge-and-Cloud/Sync-Tool.md | 186 -
.../Programming-MQTT.md | 104 -
docs/UserGuide/Comparison/TSDB-Comparison.md | 374 -
docs/UserGuide/Data-Concept/Compression.md | 106 +-
.../Data-Concept/Data-Model-and-Terminology.md | 235 +-
docs/UserGuide/Data-Concept/Data-Type.md | 123 +-
docs/UserGuide/Data-Concept/Encoding.md | 41 +-
docs/UserGuide/Data-Concept/SDT.md | 111 -
docs/UserGuide/Data-Concept/Schema-Template.md | 52 +
docs/UserGuide/Data-Concept/Time-Partition.md | 62 +
docs/UserGuide/Data-Concept/Time-zone.md | 90 +
docs/UserGuide/Data-Modeling/DataRegion.md | 55 +
.../Data-Modeling/SchemaRegion-rocksdb.md | 108 +
docs/UserGuide/Ecosystem Integration/DBeaver.md | 86 +
.../UserGuide/Ecosystem Integration/Flink IoTDB.md | 3 +-
.../Ecosystem Integration/Grafana Connector.md | 181 +
.../Ecosystem Integration/Grafana Plugin.md | 348 +
docs/UserGuide/Ecosystem Integration/Grafana.md | 164 -
.../UserGuide/Ecosystem Integration/Hive TsFile.md | 8 +-
.../Ecosystem Integration/MapReduce TsFile.md | 2 +-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 79 +-
.../Ecosystem Integration/Spark TsFile.md | 2 +-
.../Ecosystem Integration/Zeppelin-IoTDB.md | 6 +-
.../Integration-Test-refactoring-tutorial.md | 161 +
.../DDL-Data-Definition-Language.md | 544 -
.../DML-Data-Manipulation-Language.md | 1521 ---
.../IoTDB-SQL-Language/Maintenance-Command.md | 102 -
.../JMX-Tool.md | 0
.../MLogParser-Tool.md | 0
.../Maintenance-Tools/Maintenance-Command.md | 116 +
docs/UserGuide/Maintenance-Tools/Metric-Tool.md | 341 +
.../Maintenance-Tools/Monitor-and-Log-Tools.md | 115 +
.../NodeTool.md | 0
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 38 +
docs/UserGuide/Maintenance-Tools/Sync-Tool.md | 447 +
.../Maintenance-Tools/TsFile-Split-Tool.md | 53 +
.../Maintenance-Tools/TsFileSelfCheck-Tool.md | 42 +
docs/UserGuide/Maintenance-Tools/Watermark-Tool.md | 196 +
.../Operate-Metadata/Auto-Create-MetaData.md | 112 +
docs/UserGuide/Operate-Metadata/Node.md | 254 +
docs/UserGuide/Operate-Metadata/Storage-Group.md | 137 +
docs/UserGuide/Operate-Metadata/TTL.md | 59 +
docs/UserGuide/Operate-Metadata/Template.md | 192 +
docs/UserGuide/Operate-Metadata/Timeseries.md | 339 +
docs/UserGuide/Process-Data/Alerting.md | 385 +
docs/UserGuide/Process-Data/Continuous-Query.md | 287 +
docs/UserGuide/Process-Data/Select-Into.md | 261 +
docs/UserGuide/Process-Data/Triggers.md | 894 ++
.../Process-Data/UDF-User-Defined-Function.md | 594 +
docs/UserGuide/Query-Data/Aggregate-Query.md | 455 +
docs/UserGuide/Query-Data/Fill-Null-Value.md | 390 +
docs/UserGuide/Query-Data/Last-Query.md | 71 +
docs/UserGuide/Query-Data/Overview.md | 216 +
docs/UserGuide/Query-Data/Pagination.md | 376 +
.../Query-Data/Performance-Tracing-Tool.md | 53 +
docs/UserGuide/Query-Data/Query-Filter.md | 175 +
docs/UserGuide/Query-Data/Result-Format.md | 76 +
docs/UserGuide/Query-Data/Select-Expression.md | 1073 ++
docs/UserGuide/Query-Data/Tracing-Tool.md | 48 +
docs/UserGuide/Query-Data/Without-Null.md | 191 +
.../UserGuide/QuickStart/Command-Line-Interface.md | 266 +
docs/UserGuide/QuickStart/Files.md | 8 +-
docs/UserGuide/QuickStart/QuickStart.md | 4 +-
docs/UserGuide/QuickStart/WayToGetIoTDB.md | 66 +-
docs/UserGuide/Reference/Config-Manual.md | 1145 ++
.../Frequently-asked-questions.md | 0
docs/UserGuide/Reference/Keywords.md | 212 +
docs/UserGuide/Reference/SQL-Reference.md | 1260 ++
docs/UserGuide/Reference/Syntax-Conventions.md | 503 +
docs/UserGuide/Reference/TSDB-Comparison.md | 389 +
docs/UserGuide/System-Tools/CSV-Tool.md | 144 -
.../UserGuide/System-Tools/Load-External-Tsfile.md | 82 -
.../System-Tools/Monitor-and-Log-Tools.md | 252 -
.../System-Tools/Performance-Tracing-Tool.md | 63 -
.../Query-History-Visualization-Tool.md | 31 -
docs/UserGuide/System-Tools/Watermark-Tool.md | 196 -
docs/UserGuide/UDF-Library/Anomaly-Detection.md | 525 +
docs/UserGuide/UDF-Library/Data-Matching.md | 335 +
docs/UserGuide/UDF-Library/Data-Profiling.md | 1812 +++
docs/UserGuide/UDF-Library/Data-Quality.md | 519 +
docs/UserGuide/UDF-Library/Data-Repairing.md | 355 +
docs/UserGuide/UDF-Library/Frequency-Domain.md | 605 +
docs/UserGuide/UDF-Library/M4.md | 92 +
docs/UserGuide/UDF-Library/Quick-Start.md | 41 +
docs/UserGuide/UDF-Library/Series-Discovery.md | 173 +
docs/UserGuide/UDF-Library/String-Processing.md | 299 +
docs/UserGuide/UDF/Triggers.md | 100 -
docs/UserGuide/UDF/UDF-User-Defined-Function.md | 587 -
docs/UserGuide/UserGuideReadme.md | 2 +-
docs/UserGuide/Write-And-Delete-Data/CSV-Tool.md | 217 +
.../UserGuide/Write-And-Delete-Data/Delete-Data.md | 98 +
.../Write-And-Delete-Data/Load-External-Tsfile.md | 92 +
docs/UserGuide/Write-And-Delete-Data/Write-Data.md | 108 +
docs/zh/Community/About.md | 127 +
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 | 105 +-
docs/zh/Development/HowToCommit.md | 58 +-
docs/zh/Development/VoteRelease.md | 15 +-
docs/zh/Download/README.md | 157 +-
docs/zh/SystemDesign/Architecture/Architecture.md | 55 -
docs/zh/SystemDesign/Client/RPC.md | 57 -
docs/zh/SystemDesign/Connector/Hive-TsFile.md | 121 -
docs/zh/SystemDesign/Connector/Spark-IOTDB.md | 89 -
docs/zh/SystemDesign/Connector/Spark-TsFile.md | 125 -
docs/zh/SystemDesign/DataQuery/AggregationQuery.md | 134 -
.../SystemDesign/DataQuery/AlignByDeviceQuery.md | 270 -
docs/zh/SystemDesign/DataQuery/DataQuery.md | 48 -
docs/zh/SystemDesign/DataQuery/FillFunction.md | 159 -
docs/zh/SystemDesign/DataQuery/GroupByFillQuery.md | 176 -
docs/zh/SystemDesign/DataQuery/GroupByQuery.md | 288 -
docs/zh/SystemDesign/DataQuery/LastQuery.md | 133 -
docs/zh/SystemDesign/DataQuery/OrderByTimeQuery.md | 190 -
.../zh/SystemDesign/DataQuery/QueryFundamentals.md | 144 -
docs/zh/SystemDesign/DataQuery/RawDataQuery.md | 323 -
docs/zh/SystemDesign/DataQuery/SeriesReader.md | 384 -
docs/zh/SystemDesign/QueryEngine/PlanExecutor.md | 26 -
docs/zh/SystemDesign/QueryEngine/Planner.md | 63 -
docs/zh/SystemDesign/QueryEngine/QueryEngine.md | 64 -
.../QueryEngine/ResultSetConstruction.md | 175 -
.../zh/SystemDesign/SchemaManager/SchemaManager.md | 323 -
docs/zh/SystemDesign/StorageEngine/Compaction.md | 258 -
.../SystemDesign/StorageEngine/DataManipulation.md | 105 -
.../zh/SystemDesign/StorageEngine/DataPartition.md | 86 -
docs/zh/SystemDesign/StorageEngine/FileLists.md | 156 -
docs/zh/SystemDesign/StorageEngine/FlushManager.md | 84 -
docs/zh/SystemDesign/StorageEngine/MergeManager.md | 112 -
docs/zh/SystemDesign/StorageEngine/Recover.md | 107 -
.../zh/SystemDesign/StorageEngine/StorageEngine.md | 67 -
docs/zh/SystemDesign/StorageEngine/WAL.md | 48 -
docs/zh/SystemDesign/Tools/Sync.md | 299 -
docs/zh/SystemDesign/TsFile/Format.md | 584 -
docs/zh/SystemDesign/TsFile/Read.md | 566 -
docs/zh/SystemDesign/TsFile/TsFile.md | 31 -
docs/zh/SystemDesign/TsFile/Write.md | 126 -
docs/zh/UserGuide/API/InfluxDB-Protocol.md | 347 +
.../zh/UserGuide/API/Programming-Cpp-Native-API.md | 400 +
docs/zh/UserGuide/API/Programming-Go-Native-API.md | 83 +
docs/zh/UserGuide/API/Programming-JDBC.md | 29 +-
.../UserGuide/API/Programming-Java-Native-API.md | 607 +
docs/zh/UserGuide/API/Programming-MQTT.md | 178 +
docs/zh/UserGuide/API/Programming-Native-API.md | 238 -
.../UserGuide/API/Programming-Other-Languages.md | 320 -
.../UserGuide/API/Programming-Python-Native-API.md | 393 +
docs/zh/UserGuide/API/Programming-Thrift.md | 155 +
docs/zh/UserGuide/API/Programming-TsFile-API.md | 308 +-
docs/zh/UserGuide/API/RestService.md | 941 ++
docs/zh/UserGuide/API/Status-Codes.md | 107 +
.../Administration-Management/Administration.md | 219 +-
docs/zh/UserGuide/Appendix/Config-Manual.md | 715 -
docs/zh/UserGuide/Appendix/SQL-Reference.md | 1113 --
docs/zh/UserGuide/Appendix/Status-Codes.md | 106 -
docs/zh/UserGuide/CLI/Command-Line-Interface.md | 192 -
docs/zh/UserGuide/Cluster/Cluster-Setup-Example.md | 314 +-
docs/zh/UserGuide/Cluster/Cluster-Setup.md | 514 +-
.../Collaboration-of-Edge-and-Cloud/Sync-Tool.md | 187 -
.../Programming-MQTT.md | 106 -
.../Programming-Thrift.md | 157 -
docs/zh/UserGuide/Data-Concept/Compression.md | 111 +-
.../Data-Concept/Data-Model-and-Terminology.md | 234 +-
docs/zh/UserGuide/Data-Concept/Data-Type.md | 125 +-
docs/zh/UserGuide/Data-Concept/Encoding.md | 56 +-
docs/zh/UserGuide/Data-Concept/SDT.md | 106 -
docs/zh/UserGuide/Data-Concept/Schema-Template.md | 110 +
docs/zh/UserGuide/Data-Concept/Time-Partition.md | 64 +
docs/zh/UserGuide/Data-Concept/Time-zone.md | 90 +
docs/zh/UserGuide/Data-Modeling/DataRegion.md | 53 +
.../Data-Modeling/SchemaRegion-rocksdb.md | 103 +
docs/zh/UserGuide/Ecosystem Integration/DBeaver.md | 86 +
.../UserGuide/Ecosystem Integration/Flink IoTDB.md | 5 +-
.../Ecosystem Integration/Flink TsFile.md | 17 +-
.../Ecosystem Integration/Grafana Connector.md | 184 +
.../Ecosystem Integration/Grafana Plugin.md | 351 +
docs/zh/UserGuide/Ecosystem Integration/Grafana.md | 164 -
.../UserGuide/Ecosystem Integration/Hive TsFile.md | 63 +-
.../Ecosystem Integration/MapReduce TsFile.md | 41 +-
.../UserGuide/Ecosystem Integration/Spark IoTDB.md | 94 +-
.../Ecosystem Integration/Spark TsFile.md | 89 +-
.../Ecosystem Integration/Writing Data on HDFS.md | 46 +-
.../Ecosystem Integration/Zeppelin-IoTDB.md | 59 +-
.../zh/UserGuide/FAQ/Frequently-asked-questions.md | 154 -
.../Integration-Test-refactoring-tutorial.md | 163 +
.../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 | 550 -
.../DML-Data-Manipulation-Language.md | 1507 ---
.../IoTDB-SQL-Language/Maintenance-Command.md | 101 -
docs/zh/UserGuide/Maintenance-Tools/JMX-Tool.md | 59 +
.../UserGuide/Maintenance-Tools/MLogParser-Tool.md | 37 +
.../Maintenance-Tools/Maintenance-Command.md | 113 +
docs/zh/UserGuide/Maintenance-Tools/Metric-Tool.md | 342 +
.../Maintenance-Tools/Monitor-and-Log-Tools.md | 117 +
docs/zh/UserGuide/Maintenance-Tools/NodeTool.md | 293 +
.../Maintenance-Tools/SchemaFileSketch-Tool.md | 35 +
docs/zh/UserGuide/Maintenance-Tools/Sync-Tool.md | 453 +
.../Maintenance-Tools/TsFile-Split-Tool.md | 52 +
.../Maintenance-Tools/TsFileSelfCheck-Tool.md | 42 +
.../UserGuide/Maintenance-Tools/Watermark-Tool.md | 196 +
.../Operate-Metadata/Auto-Create-MetaData.md | 111 +
docs/zh/UserGuide/Operate-Metadata/Node.md | 258 +
.../zh/UserGuide/Operate-Metadata/Storage-Group.md | 139 +
docs/zh/UserGuide/Operate-Metadata/TTL.md | 57 +
docs/zh/UserGuide/Operate-Metadata/Template.md | 192 +
docs/zh/UserGuide/Operate-Metadata/Timeseries.md | 338 +
docs/zh/UserGuide/Process-Data/Alerting.md | 374 +
docs/zh/UserGuide/Process-Data/Continuous-Query.md | 289 +
docs/zh/UserGuide/Process-Data/Select-Into.md | 261 +
docs/zh/UserGuide/Process-Data/Triggers.md | 826 ++
.../Process-Data/UDF-User-Defined-Function.md | 521 +
docs/zh/UserGuide/Query-Data/Aggregate-Query.md | 449 +
docs/zh/UserGuide/Query-Data/Fill-Null-Value.md | 396 +
docs/zh/UserGuide/Query-Data/Last-Query.md | 69 +
docs/zh/UserGuide/Query-Data/Overview.md | 223 +
docs/zh/UserGuide/Query-Data/Pagination.md | 367 +
.../Query-Data/Performance-Tracing-Tool.md | 51 +
docs/zh/UserGuide/Query-Data/Query-Filter.md | 170 +
docs/zh/UserGuide/Query-Data/Result-Format.md | 83 +
docs/zh/UserGuide/Query-Data/Select-Expression.md | 1075 ++
docs/zh/UserGuide/Query-Data/Tracing-Tool.md | 48 +
docs/zh/UserGuide/Query-Data/Without-Null.md | 191 +
.../UserGuide/QuickStart/Command-Line-Interface.md | 258 +
docs/zh/UserGuide/QuickStart/Files.md | 21 +-
docs/zh/UserGuide/QuickStart/QuickStart.md | 78 +-
docs/zh/UserGuide/QuickStart/ServerFileList.md | 64 +-
docs/zh/UserGuide/QuickStart/WayToGetIoTDB.md | 101 +-
docs/zh/UserGuide/Reference/Config-Manual.md | 1724 +++
.../Reference/Frequently-asked-questions.md | 153 +
docs/zh/UserGuide/Reference/Keywords.md | 212 +
docs/zh/UserGuide/Reference/SQL-Reference.md | 1220 ++
docs/zh/UserGuide/Reference/Syntax-Conventions.md | 507 +
docs/zh/UserGuide/Reference/TSDB-Comparison.md | 362 +
docs/zh/UserGuide/System-Tools/CSV-Tool.md | 144 -
docs/zh/UserGuide/System-Tools/JMX-Tool.md | 59 -
.../UserGuide/System-Tools/Load-External-Tsfile.md | 79 -
docs/zh/UserGuide/System-Tools/MLogParser-Tool.md | 38 -
.../System-Tools/Monitor-and-Log-Tools.md | 286 -
docs/zh/UserGuide/System-Tools/NodeTool.md | 294 -
.../System-Tools/Performance-Tracing-Tool.md | 63 -
.../Query-History-Visualization-Tool.md | 30 -
docs/zh/UserGuide/System-Tools/Watermark-Tool.md | 196 -
docs/zh/UserGuide/UDF-Library/Anomaly-Detection.md | 531 +
docs/zh/UserGuide/UDF-Library/Data-Matching.md | 333 +
docs/zh/UserGuide/UDF-Library/Data-Profiling.md | 1805 +++
docs/zh/UserGuide/UDF-Library/Data-Quality.md | 524 +
docs/zh/UserGuide/UDF-Library/Data-Repairing.md | 346 +
docs/zh/UserGuide/UDF-Library/Frequency-Domain.md | 598 +
docs/zh/UserGuide/UDF-Library/M4.md | 93 +
docs/zh/UserGuide/UDF-Library/Quick-Start.md | 40 +
docs/zh/UserGuide/UDF-Library/Series-Discovery.md | 173 +
docs/zh/UserGuide/UDF-Library/String-Processing.md | 290 +
docs/zh/UserGuide/UDF/Triggers.md | 100 -
docs/zh/UserGuide/UDF/UDF-User-Defined-Function.md | 591 -
docs/zh/UserGuide/UserGuideReadme.md | 9 +-
.../zh/UserGuide/Write-And-Delete-Data/CSV-Tool.md | 217 +
.../UserGuide/Write-And-Delete-Data/Delete-Data.md | 92 +
.../Write-And-Delete-Data/Load-External-Tsfile.md | 91 +
.../UserGuide/Write-And-Delete-Data/Write-Data.md | 110 +
example/client-cpp-example/pom.xml | 27 +-
.../src/AlignedTimeseriesSessionExample.cpp | 372 +
example/client-cpp-example/src/CMakeLists.txt | 8 +-
example/client-cpp-example/src/SessionExample.cpp | 283 +-
example/flink/pom.xml | 2 +-
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 26 +-
.../java/org/apache/iotdb/flink/TsFileUtils.java | 4 +-
example/hadoop/pom.xml | 5 +-
.../iotdb/hadoop/tsfile/TSFMRReadExample.java | 5 +-
.../iotdb/hadoop/tsfile/TSMRWriteExample.java | 6 +-
.../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 6 +-
.../iotdb/hadoop/tsfile/TsFileWriteToHDFS.java | 6 +-
example/jdbc/pom.xml | 2 +-
.../main/java/org/apache/iotdb/JDBCExample.java | 9 +-
.../org/apache/iotdb/PrepareStatementDemo.java | 2 +-
example/kafka/pom.xml | 12 +-
example/kafka/readme.md | 32 +-
.../main/java/org/apache/iotdb/kafka/Constant.java | 68 +-
.../main/java/org/apache/iotdb/kafka/Consumer.java | 129 +
.../org/apache/iotdb/kafka/ConsumerThread.java | 159 +
.../java/org/apache/iotdb/kafka/KafkaConsumer.java | 90 -
.../apache/iotdb/kafka/KafkaConsumerThread.java | 104 -
.../java/org/apache/iotdb/kafka/KafkaProducer.java | 64 -
.../main/java/org/apache/iotdb/kafka/Producer.java | 62 +
example/mqtt-customize/README.md | 42 +
example/mqtt-customize/pom.xml | 41 +
.../server/CustomizedJsonPayloadFormatter.java | 62 +
....apache.iotdb.db.protocol.mqtt.PayloadFormatter | 1 +
example/mqtt/pom.xml | 2 +-
.../java/org/apache/iotdb/mqtt/MQTTClient.java | 3 +
example/pom.xml | 10 +-
example/pulsar/pom.xml | 7 +-
.../java/org/apache/iotdb/pulsar/Constant.java | 38 +-
.../org/apache/iotdb/pulsar/PulsarConsumer.java | 65 +-
.../apache/iotdb/pulsar/PulsarConsumerThread.java | 130 +-
.../org/apache/iotdb/pulsar/PulsarProducer.java | 38 +-
example/rabbitmq/pom.xml | 49 +
example/rabbitmq/readme.md | 63 +
.../java/org/apache/iotdb/rabbitmq/Constant.java | 68 +
.../iotdb/rabbitmq/RabbitMQChannelUtils.java | 50 +
.../apache/iotdb/rabbitmq/RabbitMQConsumer.java | 132 +
.../apache/iotdb/rabbitmq/RabbitMQProducer.java | 49 +
example/rest-client-c-example/CMakeLists.txt | 25 +
example/rest-client-c-example/README.md | 111 +
example/rest-client-c-example/base64.c | 100 +
example/rest-client-c-example/base64.h | 30 +
example/rest-client-c-example/main.c | 128 +
example/rocketmq/pom.xml | 2 +-
example/rocketmq/readme.md | 4 +-
example/session/pom.xml | 2 +-
.../iotdb/AlignedTimeseriesSessionExample.java | 642 +
.../org/apache/iotdb/DataMigrationExample.java | 10 +-
.../iotdb/HybridTimeseriesSessionExample.java | 122 +
.../org/apache/iotdb/SessionConcurrentExample.java | 188 +
.../main/java/org/apache/iotdb/SessionExample.java | 372 +-
.../java/org/apache/iotdb/SessionPoolExample.java | 45 +-
.../main/java/org/apache/iotdb/TabletExample.java | 194 +
example/trigger/pom.xml | 138 +
.../org/apache/iotdb/trigger/AlertingExample.java | 107 +
.../org/apache/iotdb/trigger/TriggerExample.java | 147 +
example/tsfile/pom.xml | 2 +-
example/tsfile/readme.md | 2 +-
.../java/org/apache/iotdb/tsfile/Constant.java | 2 +
.../iotdb/tsfile/TsFileForceAppendWrite.java | 13 +-
.../java/org/apache/iotdb/tsfile/TsFileRead.java | 26 +-
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 99 +-
.../tsfile/TsFileWriteAlignedWithTSRecord.java | 95 +
.../iotdb/tsfile/TsFileWriteAlignedWithTablet.java | 146 +
.../iotdb/tsfile/TsFileWriteWithTSRecord.java | 70 +-
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 108 +-
example/udf/pom.xml | 72 +-
.../java/org/apache/iotdb/udf/UDTFExample.java | 19 +-
flink-iotdb-connector/pom.xml | 7 +-
.../java/org/apache/iotdb/flink/IoTDBSink.java | 19 +-
.../iotdb/flink/options/IoTDBSinkOptions.java | 11 -
flink-tsfile-connector/pom.xml | 2 +-
.../iotdb/flink/tsfile/TsFileInputFormat.java | 6 +-
.../tsfile/RowTSRecordOutputFormatITCase.java | 54 -
.../RowTSRecordOutputFormatIntegrationTest.java | 54 +
.../flink/tsfile/RowTsFileInputFormatITCase.java | 108 -
.../RowTsFileInputFormatIntegrationTest.java | 108 +
.../flink/tsfile/RowTsFileInputFormatTest.java | 14 +-
.../tsfile/RowTsFileOutputFormatTestBase.java | 4 +-
.../util/TSFileConfigUtilCompletenessTest.java | 4 +-
.../img/add_data_source.png | Bin
{grafana => grafana-connector}/img/add_graph.png | Bin
.../img/edit_data_source.png | Bin
grafana-connector/pom.xml | 258 +
grafana-connector/readme.md | 192 +
grafana-connector/readme_zh.md | 195 +
.../web/grafana/TsfileWebDemoApplication.java | 0
.../apache/iotdb/web/grafana/bean/TimeValues.java | 0
.../iotdb/web/grafana/conf/MyConfiguration.java | 0
.../controller/DatabaseConnectController.java | 193 +
.../org/apache/iotdb/web/grafana/dao/BasicDao.java | 0
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 207 +
.../grafana/service/DatabaseConnectService.java | 32 +
.../service/impl/DatabaseConnectServiceImpl.java | 46 +
.../src/main/resources/application.properties | 0
.../web/grafana/dao/impl/BasicDaoImplTest.java | 0
.../Apache IoTDB Dashboard v0.13.1.json | 1527 +++
.../Apache IoTDB Dashboard v0.14.0.json | 1527 +++
grafana-plugin/.gitignore | 33 +
grafana-plugin/.prettierrc.js | 20 +
grafana-plugin/CHANGELOG.md | 24 +
grafana-plugin/LICENSE | 201 +
grafana-plugin/Magefile.go | 32 +
grafana-plugin/README.md | 91 +
grafana-plugin/backend-compile.sh | 36 +
grafana-plugin/go.mod | 23 +
grafana-plugin/go.sum | 659 +
grafana-plugin/jest.config.js | 24 +
grafana-plugin/package.json | 31 +
grafana-plugin/pkg/main.go | 40 +
grafana-plugin/pkg/plugin/plugin.go | 350 +
grafana-plugin/pom.xml | 142 +
grafana-plugin/src/ConfigEditor.tsx | 101 +
grafana-plugin/src/QueryEditor.tsx | 345 +
grafana-plugin/src/componments/AggregateFun.tsx | 44 +
grafana-plugin/src/componments/ControlValue.tsx | 38 +
grafana-plugin/src/componments/FillValue.tsx | 38 +
grafana-plugin/src/componments/Form.tsx | 42 +
grafana-plugin/src/componments/FromValue.tsx | 110 +
grafana-plugin/src/componments/GroupBy.tsx | 58 +
grafana-plugin/src/componments/SelectValue.tsx | 110 +
grafana-plugin/src/componments/TimeSeries.tsx | 82 +
grafana-plugin/src/componments/WhereValue.tsx | 39 +
grafana-plugin/src/datasource.ts | 128 +
grafana-plugin/src/functions.ts | 20 +
grafana-plugin/src/img/logo.svg | 271 +
grafana-plugin/src/module.ts | 25 +
grafana-plugin/src/plugin.json | 50 +
grafana-plugin/src/types.ts | 68 +
grafana-plugin/tsconfig.json | 9 +
grafana-plugin/yarn.lock | 13256 +++++++++++++++++++
grafana/pom.xml | 258 -
grafana/readme.md | 175 -
grafana/readme_zh.md | 172 -
.../controller/DatabaseConnectController.java | 227 -
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 212 -
.../grafana/service/DatabaseConnectService.java | 34 -
.../service/impl/DatabaseConnectServiceImpl.java | 51 -
hadoop/README.md | 2 +-
hadoop/pom.xml | 22 +-
.../apache/iotdb/hadoop/fileSystem/HDFSInput.java | 5 +
.../apache/iotdb/hadoop/tsfile/TSFInputFormat.java | 11 +-
.../iotdb/hadoop/tsfile/TSFRecordReader.java | 4 +-
.../iotdb/hadoop/tsfile/record/HDFSTSRecord.java | 8 +-
.../apache/iotdb/hadoop/tsfile/TSFHadoopTest.java | 49 +-
.../iotdb/hadoop/tsfile/TSFInputSplitTest.java | 3 +-
.../iotdb/hadoop/tsfile/TsFileTestHelper.java | 2 +-
hive-connector/pom.xml | 33 +-
.../org/apache/iotdb/hive/TSFHiveInputFormat.java | 6 +-
.../org/apache/iotdb/hive/TSFHiveRecordWriter.java | 3 +-
.../org/apache/iotdb/hive/TsFileDeserializer.java | 10 +-
.../apache/iotdb/hive/TSFHiveInputFormatTest.java | 27 +-
.../apache/iotdb/hive/TSFHiveRecordReaderTest.java | 28 +-
.../apache/iotdb/hive/TsFileDeserializerTest.java | 11 +-
.../org/apache/iotdb/hive/TsFileSerDeTest.java | 11 +-
.../org/apache/iotdb/hive/TsFileTestHelper.java | 2 +-
influxdb-protocol/pom.xml | 137 +
.../org/apache/iotdb/influxdb/IoTDBInfluxDB.java | 411 +
.../iotdb/influxdb/IoTDBInfluxDBFactory.java | 70 +
.../iotdb/influxdb/example/InfluxDBExample.java | 108 +
.../protocol/constant/InfluxDBConstant.java | 25 +
.../iotdb/influxdb/protocol/dto/SessionPoint.java | 85 +
.../protocol/impl/IoTDBInfluxDBService.java | 99 +
.../influxdb/protocol/util/ParameterUtils.java | 36 +
.../iotdb/influxdb/session/InfluxDBSession.java | 277 +
.../influxdb/integration/IoTDBInfluxDBIT.java | 202 +
integration/README.md | 120 +
integration/pic/Add_New_Configuration.png | Bin 0 -> 129654 bytes
integration/pic/Cluster_Category.png | Bin 0 -> 175311 bytes
integration/pic/Fork_mode.png | Bin 0 -> 188976 bytes
integration/pic/Run(Menu).png | Bin 0 -> 99077 bytes
integration/pic/Standalone_Category.png | Bin 0 -> 183256 bytes
integration/pom.xml | 290 +
integration/src/assembly/cluster.xml | 47 +
.../iotdb/db/query/udf/example/Accumulator.java | 102 +
.../apache/iotdb/db/query/udf/example/Adder.java | 96 +
.../apache/iotdb/db/query/udf/example/Counter.java | 88 +
.../db/query/udf/example/ExampleUDFConstant.java | 31 +
.../org/apache/iotdb/db/query/udf/example/Max.java | 76 +
.../iotdb/db/query/udf/example/Multiplier.java | 0
.../SlidingSizeWindowConstructorTester0.java | 0
.../SlidingSizeWindowConstructorTester1.java | 0
.../SlidingTimeWindowConstructionTester.java | 72 +
.../db/query/udf/example/TerminateTester.java | 0
.../iotdb/db/query/udf/example/ValidateTester.java | 0
.../iotdb/db/query/udf/example/WindowStartEnd.java | 66 +
.../iotdb/integration/env/ClusterEnvBase.java | 279 +
.../iotdb/integration/env/ClusterEnvConfig.java | 159 +
.../apache/iotdb/integration/env/ClusterNode.java | 177 +
.../iotdb/integration/env/ConfigFactory.java | 52 +
.../apache/iotdb/integration/env/EnvFactory.java | 57 +
.../iotdb/integration/env/FiveNodeCluster1Env.java | 64 +
.../iotdb/integration/env/RemoteEnvConfig.java | 23 +
.../iotdb/integration/env/RemoteServerEnv.java | 107 +
.../apache/iotdb/itbase/category/ClusterTest.java | 21 +
.../iotdb/itbase/category/LocalStandaloneTest.java | 21 +
.../apache/iotdb/itbase/category/RemoteTest.java | 21 +
.../org/apache/iotdb/itbase/env/BaseConfig.java | 116 +
.../java/org/apache/iotdb/itbase/env/BaseEnv.java | 39 +
.../db/engine/trigger/example/Accumulator.java | 95 +
.../iotdb/db/engine/trigger/example/Counter.java | 96 +
.../apache/iotdb/db/integration/IOTDBInsertIT.java | 194 +
.../apache/iotdb/db/integration/IoTDBAliasIT.java | 396 +
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 1099 ++
.../IoTDBAlignedTimeSeriesCompactionIT.java | 564 +
.../iotdb/db/integration/IoTDBArithmeticIT.java | 287 +
.../org/apache/iotdb/db/integration/IoTDBAsIT.java | 564 +
.../iotdb/db/integration/IoTDBAuthorizationIT.java | 1363 ++
.../db/integration/IoTDBAutoCreateSchemaIT.java | 208 +
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 144 +
.../iotdb/db/integration/IoTDBClearCacheIT.java | 171 +
.../apache/iotdb/db/integration/IoTDBCloseIT.java | 191 +
.../iotdb/db/integration/IoTDBCompactionIT.java | 338 +
.../integration/IoTDBCompactionWithIDTableIT.java | 352 +
.../iotdb/db/integration/IoTDBCompleteIT.java | 491 +
.../iotdb/db/integration/IoTDBCompressTypeIT.java | 101 +
.../db/integration/IoTDBContinuousQueryIT.java | 502 +
.../IoTDBCreateAlignedTimeseriesIT.java | 142 +
.../db/integration/IoTDBCreateStorageGroupIT.java | 131 +
.../db/integration/IoTDBCreateTimeseriesIT.java | 260 +
.../apache/iotdb/db/integration/IoTDBDaemonIT.java | 456 +
.../db/integration/IoTDBDatetimeFormatIT.java | 133 +
.../db/integration/IoTDBDeleteStorageGroupIT.java | 183 +
.../db/integration/IoTDBDeleteTimeseriesIT.java | 215 +
.../iotdb/db/integration/IoTDBDeletionIT.java | 529 +
.../iotdb/db/integration/IoTDBDisableAlignIT.java | 392 +
.../iotdb/db/integration/IoTDBEncodingIT.java | 492 +
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 291 +
.../iotdb/db/integration/IoTDBExecuteBatchIT.java | 196 +
.../iotdb/db/integration/IoTDBFilePathUtilsIT.java | 99 +
.../apache/iotdb/db/integration/IoTDBFillIT.java | 1227 ++
.../db/integration/IoTDBFloatPrecisionIT.java | 170 +
.../db/integration/IoTDBFlushQueryMergeIT.java | 197 +
.../iotdb/db/integration/IoTDBFuzzyQueryIT.java | 294 +
.../org/apache/iotdb/db/integration/IoTDBInIT.java | 252 +
.../db/integration/IoTDBInsertMultiRowIT.java | 144 +
.../iotdb/db/integration/IoTDBInsertNaNIT.java | 197 +
.../iotdb/db/integration/IoTDBInsertNullIT.java | 207 +
.../db/integration/IoTDBInsertWithQueryIT.java | 465 +
.../db/integration/IoTDBInsertWithoutTimeIT.java | 131 +
.../iotdb/db/integration/IoTDBKillQueryIT.java | 80 +
.../iotdb/db/integration/IoTDBLargeDataIT.java | 373 +
.../apache/iotdb/db/integration/IoTDBLastIT.java | 731 +
.../iotdb/db/integration/IoTDBLimitSlimitIT.java | 204 +
...IoTDBLoadExternalTsFileWithTimePartitionIT.java | 329 +
.../db/integration/IoTDBLoadExternalTsfileIT.java | 1034 ++
.../integration/IoTDBManageTsFileResourceIT.java | 294 +
.../iotdb/db/integration/IoTDBMaxTimeQueryIT.java | 139 +
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 660 +
.../iotdb/db/integration/IoTDBMultiDeviceIT.java | 297 +
.../IoTDBMultiOverlappedChunkInUnseqIT.java | 110 +
.../db/integration/IoTDBMultiOverlappedPageIT.java | 166 +
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 471 +
.../db/integration/IoTDBMultiStatementsIT.java | 187 +
.../iotdb/db/integration/IoTDBNestedQueryIT.java | 639 +
.../db/integration/IoTDBNewTsFileCompactionIT.java | 1080 ++
.../iotdb/db/integration/IoTDBNumberPathIT.java | 483 +
.../db/integration/IoTDBOverlappedPageIT.java | 194 +
.../db/integration/IoTDBPartialInsertionIT.java | 131 +
.../db/integration/IoTDBPathNumOverLimitIT.java | 74 +
.../iotdb/db/integration/IoTDBQueryDemoIT.java | 685 +
.../db/integration/IoTDBQueryMemoryControlIT.java | 277 +
.../iotdb/db/integration/IoTDBQueryTimeoutIT.java | 156 +
.../IoTDBQueryWithComplexValueFilterIT.java | 113 +
.../db/integration/IoTDBQueryWithIDTableIT.java | 290 +
.../IoTDBQueryWithRecreatedTimeseriesIT.java | 79 +
.../iotdb/db/integration/IoTDBQuotedPathIT.java | 125 +
.../iotdb/db/integration/IoTDBRecoverIT.java | 436 +
.../db/integration/IoTDBRecoverUnclosedIT.java | 302 +
.../db/integration/IoTDBRemovePartitionIT.java | 333 +
.../iotdb/db/integration/IoTDBRestartIT.java | 407 +
.../db/integration/IoTDBResultMetadataIT.java | 89 +
.../iotdb/db/integration/IoTDBResultSetIT.java | 134 +
.../db/integration/IoTDBRpcCompressionIT.java | 140 +
.../IoTDBSameMeasurementsDifferentTypesIT.java | 182 +
.../db/integration/IoTDBSchemaTemplateIT.java | 336 +
.../IoTDBSelectCompareExpressionIT.java | 482 +
.../iotdb/db/integration/IoTDBSelectIntoIT.java | 786 ++
.../iotdb/db/integration/IoTDBSelectSchemaIT.java | 133 +
.../iotdb/db/integration/IoTDBSensorUpdateIT.java | 87 +
.../db/integration/IoTDBSequenceDataQueryIT.java | 329 +
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 444 +
.../db/integration/IoTDBSessionTimeoutIT.java | 84 +
.../IoTDBSetSystemReadOnlyWritableIT.java | 258 +
.../apache/iotdb/db/integration/IoTDBSettleIT.java | 96 +
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 1259 ++
.../integration/IoTDBSizeTieredCompactionIT.java | 1370 ++
.../integration/IoTDBSortedShowTimeseriesIT.java | 338 +
.../IoTDBSyntaxConventionIdentifierIT.java | 838 ++
.../IoTDBSyntaxConventionStringLiteralIT.java | 764 ++
.../iotdb/db/integration/IoTDBTagAlterIT.java | 625 +
.../apache/iotdb/db/integration/IoTDBTagIT.java | 1175 ++
.../iotdb/db/integration/IoTDBTimePartitionIT.java | 92 +
.../iotdb/db/integration/IoTDBTimeZoneIT.java | 158 +
.../iotdb/db/integration/IoTDBTracingIT.java | 84 +
.../db/integration/IoTDBTriggerExecutionIT.java | 678 +
.../db/integration/IoTDBTriggerManagementIT.java | 539 +
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 223 +
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 396 +
.../db/integration/IoTDBUDFWindowQueryIT.java | 781 ++
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 848 ++
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 1038 ++
.../db/integration/IoTDBUDTFHybridQueryIT.java | 160 +
.../db/integration/IoTDBUDTFNonAlignQueryIT.java | 341 +
.../db/integration/IoTDBUnseqOverlappedPageIT.java | 127 +
.../iotdb/db/integration/IoTDBVersionIT.java | 68 +
.../db/integration/IoTDBWithoutAllNullIT.java | 257 +
.../db/integration/IoTDBWithoutAnyNullIT.java | 249 +
.../aggregation/IoTDBAggregationByLevelIT.java | 693 +
.../aggregation/IoTDBAggregationDeleteIT.java | 94 +
.../aggregation/IoTDBAggregationIT.java | 1064 ++
.../aggregation/IoTDBAggregationLargeDataIT.java | 1010 ++
.../aggregation/IoTDBAggregationSmallDataIT.java | 799 ++
.../aggregation/IoTDBUDFNestAggregationIT.java | 774 ++
.../IoTDBUserDefinedAggregationFunctionIT.java | 732 +
.../db/integration/aligned/AlignedWriteUtil.java | 149 +
.../aligned/IoTDBAggregationGroupByLevelIT.java | 302 +
.../IoTDBAggregationWithValueFilter2IT.java | 65 +
.../aligned/IoTDBAggregationWithValueFilterIT.java | 264 +
...BAggregationWithValueFilterWithDeletion2IT.java | 85 +
...DBAggregationWithValueFilterWithDeletionIT.java | 221 +
.../IoTDBAggregationWithoutValueFilter2IT.java | 65 +
.../IoTDBAggregationWithoutValueFilterIT.java | 456 +
...gregationWithoutValueFilterWithDeletion2IT.java | 82 +
...ggregationWithoutValueFilterWithDeletionIT.java | 453 +
.../integration/aligned/IoTDBAlignByDevice2IT.java | 67 +
.../integration/aligned/IoTDBAlignByDeviceIT.java | 1623 +++
.../aligned/IoTDBDeleteTimeseriesIT.java | 217 +
.../db/integration/aligned/IoTDBDeletionIT.java | 554 +
.../aligned/IoTDBGroupByFillQueryBigDataIT.java | 192 +
.../aligned/IoTDBGroupByFillQueryIT.java | 989 ++
.../IoTDBGroupByQueryWithValueFilter2IT.java | 65 +
.../IoTDBGroupByQueryWithValueFilterIT.java | 1094 ++
...GroupByQueryWithValueFilterWithDeletion2IT.java | 76 +
...BGroupByQueryWithValueFilterWithDeletionIT.java | 826 ++
.../IoTDBGroupByQueryWithoutValueFilter2IT.java | 65 +
.../IoTDBGroupByQueryWithoutValueFilterIT.java | 1128 ++
...upByQueryWithoutValueFilterWithDeletion2IT.java | 77 +
...oupByQueryWithoutValueFilterWithDeletionIT.java | 818 ++
...GroupBySlidingWindowQueryWithValueFilterIT.java | 951 ++
...upBySlidingWindowQueryWithoutValueFilterIT.java | 947 ++
.../aligned/IoTDBInsertAlignedValuesIT.java | 391 +
.../db/integration/aligned/IoTDBLastQuery2IT.java | 65 +
.../db/integration/aligned/IoTDBLastQueryIT.java | 376 +
.../aligned/IoTDBLastQueryWithDeletion2IT.java | 80 +
.../aligned/IoTDBLastQueryWithDeletionIT.java | 379 +
.../aligned/IoTDBLastQueryWithoutLastCache2IT.java | 68 +
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 381 +
...DBLastQueryWithoutLastCacheWithDeletion2IT.java | 85 +
...TDBLastQueryWithoutLastCacheWithDeletionIT.java | 383 +
.../aligned/IoTDBLoadExternalAlignedTsFileIT.java | 1030 ++
.../aligned/IoTDBRawQueryWithValueFilter2IT.java | 65 +
.../aligned/IoTDBRawQueryWithValueFilterIT.java | 763 ++
...oTDBRawQueryWithValueFilterWithDeletion2IT.java | 82 +
...IoTDBRawQueryWithValueFilterWithDeletionIT.java | 778 ++
.../IoTDBRawQueryWithoutValueFilter2IT.java | 66 +
.../IoTDBRawQueryWithoutValueFilter3IT.java | 63 +
.../aligned/IoTDBRawQueryWithoutValueFilterIT.java | 633 +
...BRawQueryWithoutValueFilterWithDeletion2IT.java | 83 +
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 611 +
.../iotdb/db/integration/env/StandaloneEnv.java | 97 +
.../db/integration/env/StandaloneEnvConfig.java | 145 +
.../db/integration/groupby/IOTDBGroupByIT.java | 996 ++
.../groupby/IOTDBGroupByInnerIntervalIT.java | 342 +
.../db/integration/groupby/IoTDBGroupByFillIT.java | 2657 ++++
.../groupby/IoTDBGroupByFillMixPathsIT.java | 479 +
.../groupby/IoTDBGroupByFillWithRangeIT.java | 179 +
.../groupby/IoTDBGroupByMonthFillIT.java | 272 +
.../integration/groupby/IoTDBGroupByMonthIT.java | 366 +
.../integration/groupby/IoTDBGroupByUnseqIT.java | 185 +
.../sync/IoTDBSyncReceiverCollectorIT.java | 513 +
.../db/integration/sync/IoTDBSyncReceiverIT.java | 360 +
.../sync/IoTDBSyncReceiverLoaderIT.java | 212 +
.../db/integration/sync/IoTDBSyncSenderIT.java | 621 +
.../iotdb/db/integration/sync/SyncTestUtil.java | 238 +
.../db/integration/sync/TransportClientMock.java | 75 +
.../db/integration/sync/TransportHandlerMock.java | 61 +
.../versionadaption/IoTDBDDLVersionAdaptionIT.java | 365 +
.../IoTDBDeletionVersionAdaptionIT.java | 303 +
.../IoTDBQueryVersionAdaptionIT.java | 320 +
.../IoTDBWithoutNullAllFilterIT.java | 1973 +++
.../IoTDBWithoutNullAnyFilterIT.java | 1866 +++
.../iotdb/session/IoTDBSessionComplexIT.java | 929 ++
.../session/IoTDBSessionDisableMemControlIT.java | 210 +
.../iotdb/session/IoTDBSessionIteratorIT.java | 353 +
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 1678 +++
.../session/IoTDBSessionSyntaxConventionIT.java | 125 +
.../session/IoTDBSessionVectorABDeviceIT.java | 233 +
.../session/IoTDBSessionVectorAggregationIT.java | 262 +
.../IoTDBSessionVectorAggregationWithUnSeqIT.java | 195 +
.../iotdb/session/IoTDBSessionVectorInsertIT.java | 520 +
.../java/org/apache/iotdb/session/SessionTest.java | 673 +
.../apache/iotdb/session/pool/SessionPoolTest.java | 482 +
.../apache/iotdb/session/template/TemplateUT.java | 399 +
.../src/test/resources/iotdb-engine.properties | 21 +
integration/src/test/resources/logback-test.xml | 58 +
jdbc/README.md | 4 +-
jdbc/pom.xml | 7 +-
jdbc/src/main/feature/feature.xml | 2 +-
.../iotdb/jdbc/AbstractIoTDBJDBCResultSet.java | 96 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 3 +
.../main/java/org/apache/iotdb/jdbc/Constant.java | 21 +
.../src/main/java/org/apache/iotdb/jdbc/Field.java | 71 +
.../iotdb/jdbc/GroupedLSBWatermarkEncoder.java | 139 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 28 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 11 +
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 2775 +++-
.../java/org/apache/iotdb/jdbc/IoTDBDriver.java | 3 +-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 69 +-
.../iotdb/jdbc/IoTDBNonAlignJDBCResultSet.java | 56 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 589 +-
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 184 +-
.../org/apache/iotdb/jdbc/IoTDBSQLException.java | 2 +-
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 99 +-
.../org/apache/iotdb/jdbc/IoTDBTracingInfo.java | 103 +
.../java/org/apache/iotdb/jdbc/ListDataSet.java | 53 +
.../java/org/apache/iotdb/jdbc/StringUtils.java | 87 +
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 53 +-
.../org/apache/iotdb/jdbc/WatermarkEncoder.java | 35 +
.../test/java/org/apache/iotdb/jdbc/BatchTest.java | 2 +-
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 5 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 162 +
.../apache/iotdb/jdbc/IoTDBJDBCResultSetTest.java | 2 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 76 +-
.../apache/iotdb/jdbc/IoTDBResultMetadataTest.java | 23 +-
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 22 +-
jenkins.pom | 3 +-
library-udf/pom.xml | 171 +
.../org/apache/iotdb/library/dmatch/UDAFCov.java | 86 +
.../org/apache/iotdb/library/dmatch/UDAFDtw.java | 91 +
.../apache/iotdb/library/dmatch/UDAFPearson.java | 95 +
.../apache/iotdb/library/dmatch/UDTFPtnSym.java | 98 +
.../org/apache/iotdb/library/dmatch/UDTFXCorr.java | 86 +
.../library/dmatch/util/CrossCorrelation.java | 54 +
.../iotdb/library/dprofile/UDAFIntegral.java | 113 +
.../iotdb/library/dprofile/UDAFIntegralAvg.java | 89 +
.../org/apache/iotdb/library/dprofile/UDAFMad.java | 85 +
.../apache/iotdb/library/dprofile/UDAFMedian.java | 85 +
.../apache/iotdb/library/dprofile/UDAFMode.java | 177 +
.../iotdb/library/dprofile/UDAFPercentile.java | 168 +
.../apache/iotdb/library/dprofile/UDAFPeriod.java | 142 +
.../apache/iotdb/library/dprofile/UDAFSkew.java | 73 +
.../apache/iotdb/library/dprofile/UDAFSpread.java | 124 +
.../apache/iotdb/library/dprofile/UDAFStddev.java | 69 +
.../org/apache/iotdb/library/dprofile/UDTFACF.java | 79 +
.../iotdb/library/dprofile/UDTFDistinct.java | 189 +
.../iotdb/library/dprofile/UDTFHistogram.java | 88 +
.../apache/iotdb/library/dprofile/UDTFMinMax.java | 110 +
.../apache/iotdb/library/dprofile/UDTFMvAvg.java | 81 +
.../apache/iotdb/library/dprofile/UDTFPACF.java | 95 +
.../org/apache/iotdb/library/dprofile/UDTFQLB.java | 104 +
.../iotdb/library/dprofile/UDTFResample.java | 116 +
.../apache/iotdb/library/dprofile/UDTFSample.java | 133 +
.../apache/iotdb/library/dprofile/UDTFSegment.java | 123 +
.../apache/iotdb/library/dprofile/UDTFSpline.java | 100 +
.../apache/iotdb/library/dprofile/UDTFZScore.java | 105 +
.../library/dprofile/util/CrossCorrelation.java | 53 +
.../dprofile/util/ExactOrderStatistics.java | 281 +
.../iotdb/library/dprofile/util/GKArray.java | 179 +
.../iotdb/library/dprofile/util/MADSketch.java | 283 +
.../apache/iotdb/library/dprofile/util/Mad.java | 34 +
.../iotdb/library/dprofile/util/MaxSelector.java | 76 +
.../iotdb/library/dprofile/util/Resampler.java | 243 +
.../iotdb/library/dprofile/util/Segment.java | 161 +
.../iotdb/library/dprofile/util/YuleWalker.java | 71 +
.../iotdb/library/dquality/UDTFCompleteness.java | 76 +
.../iotdb/library/dquality/UDTFConsistency.java | 74 +
.../iotdb/library/dquality/UDTFTimeliness.java | 73 +
.../iotdb/library/dquality/UDTFValidity.java | 73 +
.../library/dquality/util/TimeSeriesQuality.java | 243 +
.../iotdb/library/drepair/UDTFTimestampRepair.java | 102 +
.../iotdb/library/drepair/UDTFValueFill.java | 104 +
.../iotdb/library/drepair/UDTFValueRepair.java | 122 +
.../apache/iotdb/library/drepair/util/ARFill.java | 93 +
.../iotdb/library/drepair/util/LikelihoodFill.java | 128 +
.../iotdb/library/drepair/util/LinearFill.java | 57 +
.../iotdb/library/drepair/util/LsGreedy.java | 141 +
.../apache/iotdb/library/drepair/util/MAFill.java | 57 +
.../iotdb/library/drepair/util/MeanFill.java | 40 +
.../iotdb/library/drepair/util/PreviousFill.java | 49 +
.../apache/iotdb/library/drepair/util/Screen.java | 138 +
.../iotdb/library/drepair/util/ScreenFill.java | 154 +
.../library/drepair/util/TimestampInterval.java | 213 +
.../library/drepair/util/TimestampRepair.java | 154 +
.../iotdb/library/drepair/util/ValueFill.java | 81 +
.../iotdb/library/drepair/util/ValueRepair.java | 130 +
.../apache/iotdb/library/frequency/UDTFConv.java | 82 +
.../apache/iotdb/library/frequency/UDTFDWT.java | 96 +
.../apache/iotdb/library/frequency/UDTFDeconv.java | 112 +
.../apache/iotdb/library/frequency/UDTFFFT.java | 106 +
.../iotdb/library/frequency/UDTFHighPass.java | 98 +
.../apache/iotdb/library/frequency/UDTFIDWT.java | 97 +
.../apache/iotdb/library/frequency/UDTFIFFT.java | 113 +
.../iotdb/library/frequency/UDTFLowPass.java | 95 +
.../iotdb/library/frequency/util/DWTUtil.java | 228 +
.../iotdb/library/frequency/util/FFTUtil.java | 82 +
.../library/series/UDTFConsecutiveSequences.java | 78 +
.../library/series/UDTFConsecutiveWindows.java | 90 +
.../iotdb/library/series/util/ConsecutiveUtil.java | 129 +
.../iotdb/library/string/UDTFRegexMatch.java | 71 +
.../iotdb/library/string/UDTFRegexReplace.java | 130 +
.../iotdb/library/string/UDTFRegexSplit.java | 76 +
.../iotdb/library/string/UDTFStrReplace.java | 153 +
.../iotdb/library/util/BooleanCircularQueue.java | 138 +
.../apache/iotdb/library/util/CircularQueue.java | 138 +
.../iotdb/library/util/DoubleCircularQueue.java | 138 +
.../iotdb/library/util/LinearRegression.java | 91 +
.../iotdb/library/util/LongCircularQueue.java | 138 +
.../iotdb/library/util/NoNumberException.java | 29 +
.../java/org/apache/iotdb/library/util/Util.java | 306 +
.../apache/iotdb/library/dmatch/DMatchTests.java | 826 ++
.../iotdb/library/dprofile/DProfileTests.java | 629 +
.../iotdb/library/dquality/DQualityTests.java | 385 +
.../apache/iotdb/library/drepair/DRepairTests.java | 317 +
.../iotdb/library/frequency/FrequencyTests.java | 300 +
.../apache/iotdb/library/series/SeriesTest.java | 467 +
.../apache/iotdb/library/string/StringTests.java | 258 +
metrics/ReadMe.md | 169 +
metrics/dropwizard-metrics/pom.xml | 58 +
.../dropwizard/DropwizardMetricManager.java | 456 +
.../iotdb/metrics/dropwizard/MetricName.java | 174 +
.../reporter/DropwizardIoTDBReporter.java | 75 +
.../dropwizard/reporter/DropwizardJmxReporter.java | 77 +
.../reporter/DropwizardMetricsExporter.java | 177 +
.../reporter/DropwizardPrometheusReporter.java | 120 +
.../metrics/dropwizard/reporter/IoTDBReporter.java | 259 +
.../metrics/dropwizard/reporter/MetricType.java | 38 +
.../dropwizard/reporter/PrometheusTextWriter.java | 79 +
.../dropwizard/type/DropwizardAutoGauge.java | 64 +
.../metrics/dropwizard/type/DropwizardCounter.java | 45 +
.../metrics/dropwizard/type/DropwizardGauge.java | 72 +
.../dropwizard/type/DropwizardHistogram.java | 47 +
.../type/DropwizardHistogramSnapshot.java | 73 +
.../metrics/dropwizard/type/DropwizardRate.java | 94 +
.../metrics/dropwizard/type/DropwizardTimer.java | 49 +
.../org.apache.iotdb.metrics.MetricManager | 18 +
.../org.apache.iotdb.metrics.reporter.Reporter | 20 +
.../dropwizard/DropwizardMetricManagerTest.java | 339 +
metrics/interface/pom.xml | 78 +
metrics/interface/src/main/assembly/metric.xml | 40 +
.../main/assembly/resources/conf/iotdb-metric.yml | 49 +
.../iotdb/metrics/DoNothingMetricService.java | 34 +
.../org/apache/iotdb/metrics/MetricManager.java | 178 +
.../org/apache/iotdb/metrics/MetricService.java | 173 +
.../apache/iotdb/metrics/config/MetricConfig.java | 249 +
.../metrics/config/MetricConfigDescriptor.java | 130 +
.../iotdb/metrics/config/MetricConstant.java | 29 +
.../apache/iotdb/metrics/config/ReloadLevel.java | 28 +
.../iotdb/metrics/impl/DoNothingCounter.java | 39 +
.../apache/iotdb/metrics/impl/DoNothingGauge.java | 40 +
.../iotdb/metrics/impl/DoNothingHistogram.java | 41 +
.../metrics/impl/DoNothingHistogramSnapshot.java | 66 +
.../iotdb/metrics/impl/DoNothingMetricManager.java | 174 +
.../apache/iotdb/metrics/impl/DoNothingRate.java | 59 +
.../apache/iotdb/metrics/impl/DoNothingTimer.java | 43 +
.../iotdb/metrics/reporter/CompositeReporter.java | 95 +
.../apache/iotdb/metrics/reporter/Reporter.java | 37 +
.../org/apache/iotdb/metrics/type/Counter.java | 31 +
.../java/org/apache/iotdb/metrics/type/Gauge.java | 34 +
.../org/apache/iotdb/metrics/type/Histogram.java | 31 +
.../iotdb/metrics/type/HistogramSnapshot.java | 54 +
.../org/apache/iotdb/metrics/type/IMetric.java | 29 +
.../java/org/apache/iotdb/metrics/type/Rate.java | 43 +
.../java/org/apache/iotdb/metrics/type/Timer.java | 53 +
.../apache/iotdb/metrics/utils/MetricLevel.java | 43 +
.../apache/iotdb/metrics/utils/MetricsUtils.java | 56 +
.../apache/iotdb/metrics/utils/MonitorType.java | 30 +
.../apache/iotdb/metrics/utils/OutPutFormat.java | 30 +
.../iotdb/metrics/utils/PredefinedMetric.java | 30 +
.../apache/iotdb/metrics/utils/ReporterType.java | 31 +
.../iotdb/metrics/config/MetricConfigTest.java | 61 +
.../interface/src/test/resources/iotdb-metric.yml | 49 +
metrics/micrometer-metrics/pom.xml | 57 +
.../iotdb/metrics/micrometer/MetricName.java | 66 +
.../micrometer/MicrometerMetricManager.java | 499 +
.../micrometer/reporter/IoTDBMeterRegistry.java | 146 +
.../micrometer/reporter/IoTDBRegistryConfig.java | 50 +
.../metrics/micrometer/reporter/JmxConfig.java | 29 +
.../reporter/MicrometerIoTDBReporter.java | 92 +
.../micrometer/reporter/MicrometerJmxReporter.java | 87 +
.../reporter/MicrometerPrometheusReporter.java | 112 +
.../micrometer/type/MicrometerAutoGauge.java | 70 +
.../metrics/micrometer/type/MicrometerCounter.java | 45 +
.../metrics/micrometer/type/MicrometerGauge.java | 57 +
.../micrometer/type/MicrometerHistogram.java | 47 +
.../type/MicrometerHistogramSnapshot.java | 90 +
.../metrics/micrometer/type/MicrometerRate.java | 81 +
.../metrics/micrometer/type/MicrometerTimer.java | 54 +
.../org.apache.iotdb.metrics.MetricManager | 18 +
.../org.apache.iotdb.metrics.reporter.Reporter | 20 +
.../micrometer/MicrometerMetricManagerTest.java | 83 +
metrics/pom.xml | 40 +
node-commons/pom.xml | 234 +
.../apache/iotdb/commons/ServerCommandLine.java | 67 +
.../apache/iotdb/commons/auth/AuthException.java | 38 +
.../commons/auth/authorizer/AuthorizerManager.java | 190 +
.../commons/auth/authorizer/BasicAuthorizer.java | 420 +
.../iotdb/commons/auth/authorizer/IAuthorizer.java | 261 +
.../auth/authorizer/LocalFileAuthorizer.java | 40 +
.../commons/auth/authorizer/OpenIdAuthorizer.java | 279 +
.../iotdb/commons/auth/entity/PathPrivilege.java | 128 +
.../iotdb/commons/auth/entity/PrivilegeType.java | 77 +
.../org/apache/iotdb/commons/auth/entity/Role.java | 143 +
.../org/apache/iotdb/commons/auth/entity/User.java | 231 +
.../iotdb/commons/auth/role/BasicRoleManager.java | 189 +
.../iotdb/commons/auth/role/IRoleAccessor.java | 64 +
.../iotdb/commons/auth/role/IRoleManager.java | 101 +
.../commons/auth/role/LocalFileRoleAccessor.java | 191 +
.../commons/auth/role/LocalFileRoleManager.java | 27 +
.../iotdb/commons/auth/user/BasicUserManager.java | 332 +
.../iotdb/commons/auth/user/IUserAccessor.java | 64 +
.../iotdb/commons/auth/user/IUserManager.java | 150 +
.../commons/auth/user/LocalFileUserAccessor.java | 245 +
.../commons/auth/user/LocalFileUserManager.java | 28 +
.../commons/client/AsyncBaseClientFactory.java | 47 +
.../iotdb/commons/client/BaseClientFactory.java | 41 +
.../commons/client/ClientFactoryProperty.java | 95 +
.../apache/iotdb/commons/client/ClientManager.java | 97 +
.../iotdb/commons/client/ClientPoolProperty.java | 84 +
.../iotdb/commons/client/IClientManager.java | 43 +
.../iotdb/commons/client/IClientPoolFactory.java | 28 +
.../async/AsyncConfigNodeIServiceClient.java | 145 +
.../async/AsyncDataNodeDataBlockServiceClient.java | 146 +
.../async/AsyncDataNodeInternalServiceClient.java | 157 +
.../client/sync/SyncConfigNodeIServiceClient.java | 126 +
.../sync/SyncDataNodeDataBlockServiceClient.java | 127 +
.../sync/SyncDataNodeInternalServiceClient.java | 138 +
.../commons/client/sync/SyncThriftClient.java | 25 +
.../sync/SyncThriftClientWithErrorHandler.java | 64 +
.../apache/iotdb/commons/concurrent/HashLock.java | 62 +
.../concurrent/IoTDBDaemonThreadFactory.java | 37 +
.../IoTDBDefaultThreadExceptionHandler.java | 33 +
.../commons/concurrent/IoTDBThreadPoolFactory.java | 289 +
.../iotdb/commons/concurrent/IoTThreadFactory.java | 58 +
.../iotdb/commons/concurrent/ThreadName.java | 96 +
.../iotdb/commons/concurrent/WrappedRunnable.java | 46 +
.../concurrent/threadpool/IThreadPoolMBean.java | 45 +
.../WrappedScheduledExecutorService.java | 193 +
.../WrappedScheduledExecutorServiceMBean.java | 22 +
.../WrappedSingleThreadExecutorService.java | 119 +
.../WrappedSingleThreadExecutorServiceMBean.java | 22 +
.../WrappedSingleThreadScheduledExecutor.java | 141 +
.../WrappedSingleThreadScheduledExecutorMBean.java | 22 +
.../threadpool/WrappedThreadPoolExecutor.java | 82 +
.../threadpool/WrappedThreadPoolExecutorMBean.java | 22 +
.../apache/iotdb/commons/conf/CommonConfig.java | 138 +
.../apache/iotdb/commons/conf/IoTDBConstant.java | 218 +
.../iotdb/commons/consensus/ConsensusGroupId.java | 88 +
.../iotdb/commons/consensus/DataRegionId.java | 34 +
.../iotdb/commons/consensus/PartitionRegionId.java | 34 +
.../iotdb/commons/consensus/SchemaRegionId.java | 34 +
.../commons/exception/BadNodeUrlException.java | 26 +
.../commons/exception/ConfigurationException.java | 44 +
.../commons/exception/IllegalPathException.java | 38 +
.../iotdb/commons/exception/IoTDBException.java | 67 +
.../iotdb/commons/exception/MetadataException.java | 62 +
.../iotdb/commons/exception/ShutdownException.java | 40 +
.../iotdb/commons/exception/StartupException.java | 40 +
.../exception/runtime/RPCServiceException.java | 32 +
.../exception/runtime/ThriftSerDeException.java | 26 +
.../iotdb/commons/file/SystemFileFactory.java | 69 +
.../iotdb/commons/partition/DataPartition.java | 248 +
.../commons/partition/DataPartitionQueryParam.java | 46 +
.../apache/iotdb/commons/partition/Partition.java | 43 +
.../iotdb/commons/partition/SchemaPartition.java | 173 +
.../executor/SeriesPartitionExecutor.java | 52 +
.../partition/executor/hash/APHashExecutor.java | 45 +
.../partition/executor/hash/BKDRHashExecutor.java | 43 +
.../partition/executor/hash/JSHashExecutor.java | 43 +
.../partition/executor/hash/SDBMHashExecutor.java | 41 +
.../org/apache/iotdb/commons/path/PartialPath.java | 520 +
.../org/apache/iotdb/commons/path/PathType.java | 38 +
.../security/encrypt/AsymmetricEncrypt.java | 47 +
.../security/encrypt/AsymmetricEncryptFactory.java | 78 +
.../security/encrypt/EncryptDecryptException.java | 31 +
.../security/encrypt/MessageDigestEncrypt.java | 59 +
.../service/AbstractThriftServiceThread.java | 322 +
.../org/apache/iotdb/commons/service/IService.java | 49 +
.../apache/iotdb/commons/service/JMXService.java | 92 +
.../iotdb/commons/service/RegisterManager.java | 85 +
.../apache/iotdb/commons/service/ServiceType.java | 96 +
.../apache/iotdb/commons/service/StartupCheck.java | 28 +
.../iotdb/commons/service/StartupChecks.java | 78 +
.../iotdb/commons/service/ThriftService.java | 173 +
.../iotdb/commons/service/ThriftServiceThread.java | 89 +
.../org/apache/iotdb/commons/utils/AuthUtils.java | 336 +
.../commons/utils/BasicStructureSerDeUtil.java | 242 +
.../org/apache/iotdb/commons/utils/IOUtils.java | 191 +
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 81 +
.../apache/iotdb/commons/utils/NodeUrlUtils.java | 188 +
.../org/apache/iotdb/commons/utils/PathUtils.java | 98 +
.../apache/iotdb/commons/utils/SerializeUtils.java | 563 +
.../apache/iotdb/commons/utils/StatusUtils.java | 223 +
.../org/apache/iotdb/commons/utils/TestOnly.java | 34 +
.../commons/utils/ThriftCommonsSerDeUtils.java | 168 +
.../commons/utils/ThriftConfigNodeSerDeUtils.java | 89 +
.../apache/iotdb/commons/ClientManagerTest.java | 474 +
.../apache/iotdb/commons/ConsensusGroupIdTest.java | 50 +
.../IoTDBDefaultThreadExceptionHandlerTest.java | 80 +
.../iotdb/commons/IoTDBThreadPoolFactoryTest.java | 221 +
.../commons/utils/BasicStructureSerDeUtilTest.java | 88 +
.../iotdb/commons/utils/NodeUrlUtilsTest.java | 62 +
.../commons/utils/ThriftCommonsSerDeUtilsTest.java | 120 +
.../utils/ThriftConfigNodeSerDeUtilsTest.java | 81 +
openapi/pom.xml | 124 +
openapi/src/main/openapi3/iotdb-rest.yaml | 268 +
pom.xml | 307 +-
procedure/pom.xml | 93 +
.../iotdb/procedure/CompletedProcedureCleaner.java | 88 +
.../procedure/CompletedProcedureRetainer.java | 36 +
.../apache/iotdb/procedure/InternalProcedure.java | 61 +
.../java/org/apache/iotdb/procedure/Procedure.java | 895 ++
.../apache/iotdb/procedure/ProcedureExecutor.java | 995 ++
.../apache/iotdb/procedure/ProcedureLockState.java | 26 +
.../apache/iotdb/procedure/RootProcedureStack.java | 177 +
.../iotdb/procedure/StateMachineProcedure.java | 329 +
.../apache/iotdb/procedure/StoppableThread.java | 49 +
.../iotdb/procedure/TimeoutExecutorThread.java | 107 +
.../iotdb/procedure/conf/ProcedureNodeConfig.java | 153 +
.../conf/ProcedureNodeConfigDescriptor.java | 219 +
.../procedure/conf/ProcedureNodeConstant.java | 32 +
.../procedure/env/ClusterProcedureEnvironment.java | 25 +
.../exception/ProcedureAbortedException.java | 30 +
.../procedure/exception/ProcedureException.java | 44 +
.../exception/ProcedureSuspendedException.java | 39 +
.../exception/ProcedureTimeoutException.java | 26 +
.../exception/ProcedureYieldException.java | 36 +
.../scheduler/AbstractProcedureScheduler.java | 211 +
.../procedure/scheduler/ProcedureScheduler.java | 109 +
.../scheduler/SimpleProcedureScheduler.java | 78 +
.../iotdb/procedure/service/ProcedureNode.java | 98 +
.../procedure/service/ProcedureNodeMBean.java | 22 +
.../iotdb/procedure/service/ProcedureServer.java | 118 +
.../service/ProcedureServerCommandLine.java | 52 +
.../service/ProcedureServerProcessor.java | 77 +
.../procedure/service/ProcedureServiceHanlder.java | 45 +
.../iotdb/procedure/store/IProcedureStore.java | 48 +
.../iotdb/procedure/store/ProcedureStore.java | 195 +
.../apache/iotdb/procedure/store/ProcedureWAL.java | 106 +
.../apache/iotdb/procedure/NoopProcedureStore.java | 70 +
.../org/apache/iotdb/procedure/TestLockRegime.java | 46 +
.../org/apache/iotdb/procedure/TestProcEnv.java | 57 +
.../apache/iotdb/procedure/TestProcedureBase.java | 83 +
.../iotdb/procedure/TestProcedureExecutor.java | 111 +
.../apache/iotdb/procedure/TestSTMProcedure.java | 57 +
.../iotdb/procedure/entity/IncProcedure.java | 57 +
.../iotdb/procedure/entity/NoopProcedure.java | 44 +
.../procedure/entity/SimpleLockProcedure.java | 80 +
.../iotdb/procedure/entity/SimpleSTMProcedure.java | 97 +
.../iotdb/procedure/entity/SleepProcedure.java | 46 +
.../iotdb/procedure/entity/StuckProcedure.java | 59 +
.../iotdb/procedure/entity/StuckSTMProcedure.java | 112 +
.../procedure/service/TestProcedureService.java | 87 +
.../iotdb/procedure/store/TestProcedureStore.java | 111 +
.../iotdb/procedure/util/ProcedureTestUtil.java | 66 +
schema-engine-rocksdb/README.md | 38 +
schema-engine-rocksdb/pom.xml | 80 +
.../resources/conf/schema-rocksdb.properties | 94 +
.../src/assembly/schema-engine-rocksdb.xml | 44 +
.../schemaregion/rocksdb/CheckKeyResult.java | 50 +
.../schemaregion/rocksdb/RSchemaConfLoader.java | 185 +
.../schemaregion/rocksdb/RSchemaConstants.java | 76 +
.../schemaregion/rocksdb/RSchemaLogger.java | 61 +
.../rocksdb/RSchemaReadWriteHandler.java | 515 +
.../schemaregion/rocksdb/RSchemaRegion.java | 1897 +++
.../schemaregion/rocksdb/RSchemaUtils.java | 592 +
.../schemaregion/rocksdb/mnode/REntityMNode.java | 124 +
.../schemaregion/rocksdb/mnode/RInternalMNode.java | 197 +
.../schemaregion/rocksdb/mnode/RMNode.java | 254 +
.../schemaregion/rocksdb/mnode/RMNodeType.java | 49 +
.../rocksdb/mnode/RMNodeValueType.java | 47 +
.../rocksdb/mnode/RMeasurementMNode.java | 262 +
.../rocksdb/mnode/RStorageGroupMNode.java | 120 +
.../metadata/rocksdb/MRocksDBBenchmark.java | 98 +
.../metadata/rocksdb/MRocksDBUnitTest.java | 265 +
.../rocksdb/RSchemaReadWriteHandlerTest.java | 77 +
.../rocksdb/RSchemaRegionAdvancedTest.java | 169 +
.../metadata/rocksdb/RocksDBBenchmarkEngine.java | 153 +
.../metadata/rocksdb/RocksDBBenchmarkTask.java | 109 +
.../metadata/rocksdb/RocksDBTestUtils.java | 72 +
server/file-changelists/mlog-changelist.md | 4 +
.../system.properties-changelist.md | 10 +
server/pom.xml | 134 +-
.../resources/conf/iotdb-engine.properties | 902 +-
server/src/assembly/resources/conf/iotdb-env.bat | 80 +-
server/src/assembly/resources/conf/iotdb-env.sh | 49 +-
.../assembly/resources/conf/iotdb-rest.properties | 58 +
.../resources/conf/iotdb-sync-client.properties | 35 -
server/src/assembly/resources/conf/logback.xml | 44 +-
.../src/assembly/resources/sbin/start-datanode.bat | 136 +
.../src/assembly/resources/sbin/start-datanode.sh | 97 +
.../src/assembly/resources/sbin/start-server.bat | 12 +-
server/src/assembly/resources/sbin/start-server.sh | 2 +-
.../src/assembly/resources/sbin/stop-datanode.bat | 27 +
.../src/assembly/resources/sbin/stop-datanode.sh | 39 +
server/src/assembly/resources/sbin/stop-server.sh | 44 +-
.../assembly/resources/tools/mlog/mLogParser.bat | 62 -
.../assembly/resources/tools/mlog/mLogParser.sh | 48 -
.../assembly/resources/tools/rocksdb-transfer.bat | 126 +
.../assembly/resources/tools/rocksdb-transfer.sh | 82 +
.../resources/tools/schema/SchemaFileSketcher.bat | 62 +
.../resources/tools/schema/SchemaFileSketcher.sh | 48 +
.../assembly/resources/tools/schema/mLogParser.bat | 62 +
.../assembly/resources/tools/schema/mLogParser.sh | 48 +
.../assembly/resources/tools/start-sync-client.bat | 71 -
.../assembly/resources/tools/start-sync-client.sh | 54 -
.../assembly/resources/tools/stop-sync-client.bat | 23 -
.../assembly/resources/tools/stop-sync-client.sh | 30 -
.../tools/tsfileToolSet/print-tsfile-visdata.bat | 62 +
.../tools/tsfileToolSet/print-tsfile-visdata.sh | 48 +
.../resources/tools/tsfileToolSet/settle.bat | 62 +
.../resources/tools/tsfileToolSet/settle.sh | 48 +
.../tools/tsfileToolSet/split-tsfile-tool.bat | 62 +
.../tools/tsfileToolSet/split-tsfile-tool.sh | 48 +
server/src/assembly/server.xml | 4 +
.../org/apache/iotdb/db/auth/AuthException.java | 37 -
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 286 +-
.../iotdb/db/auth/authorizer/BasicAuthorizer.java | 406 -
.../iotdb/db/auth/authorizer/IAuthorizer.java | 261 -
.../db/auth/authorizer/LocalFileAuthorizer.java | 44 -
.../iotdb/db/auth/authorizer/OpenIdAuthorizer.java | 282 -
.../apache/iotdb/db/auth/entity/PathPrivilege.java | 127 -
.../apache/iotdb/db/auth/entity/PrivilegeType.java | 60 -
.../java/org/apache/iotdb/db/auth/entity/Role.java | 143 -
.../java/org/apache/iotdb/db/auth/entity/User.java | 231 -
.../iotdb/db/auth/role/BasicRoleManager.java | 189 -
.../apache/iotdb/db/auth/role/IRoleAccessor.java | 64 -
.../apache/iotdb/db/auth/role/IRoleManager.java | 101 -
.../iotdb/db/auth/role/LocalFileRoleAccessor.java | 191 -
.../iotdb/db/auth/role/LocalFileRoleManager.java | 26 -
.../iotdb/db/auth/user/BasicUserManager.java | 331 -
.../apache/iotdb/db/auth/user/IUserAccessor.java | 64 -
.../apache/iotdb/db/auth/user/IUserManager.java | 150 -
.../iotdb/db/auth/user/LocalFileUserAccessor.java | 245 -
.../iotdb/db/auth/user/LocalFileUserManager.java | 28 -
.../apache/iotdb/db/client/ConfigNodeClient.java | 406 +
.../iotdb/db/client/DataNodeClientPoolFactory.java | 148 +
.../org/apache/iotdb/db/concurrent/HashLock.java | 62 -
.../IoTDBDefaultThreadExceptionHandler.java | 33 -
.../db/concurrent/IoTDBThreadPoolFactory.java | 145 -
.../iotdb/db/concurrent/IoTThreadFactory.java | 58 -
.../org/apache/iotdb/db/concurrent/ThreadName.java | 57 -
.../iotdb/db/concurrent/WrappedRunnable.java | 46 -
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 1608 ++-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 521 -
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 154 -
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 989 +-
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 452 +
.../org/apache/iotdb/db/conf/OperationType.java | 66 +
.../iotdb/db/conf/adapter/CompressionRatio.java | 4 +-
.../db/conf/directories/DirectoryManager.java | 6 +-
.../iotdb/db/conf/directories/FolderManager.java | 65 +
.../directories/strategy/DirectoryStrategy.java | 4 +-
.../strategy/DirectoryStrategyType.java | 26 +
.../strategy/MaxDiskUsableSpaceFirstStrategy.java | 6 +-
.../MinFolderOccupiedSpaceFirstStrategy.java | 6 +-
.../strategy/RandomOnDiskUsableSpaceStrategy.java | 4 +-
.../directories/strategy/SequenceStrategy.java | 6 +-
.../iotdb/db/conf/rest/IoTDBRestServiceCheck.java | 65 +
.../iotdb/db/conf/rest/IoTDBRestServiceConfig.java | 153 +
.../db/conf/rest/IoTDBRestServiceDescriptor.java | 167 +
.../apache/iotdb/db/consensus/ConsensusImpl.java | 77 +
.../consensus/statemachine/BaseStateMachine.java | 74 +
.../statemachine/DataRegionStateMachine.java | 101 +
.../statemachine/SchemaRegionStateMachine.java | 77 +
.../org/apache/iotdb/db/constant/TestConstant.java | 143 +
.../db/cost/statistic/ConcurrentCircularArray.java | 67 -
.../iotdb/db/cost/statistic/Measurement.java | 425 -
.../iotdb/db/cost/statistic/MeasurementMBean.java | 60 -
.../apache/iotdb/db/cost/statistic/Operation.java | 38 -
.../org/apache/iotdb/db/engine/StorageEngine.java | 802 +-
.../apache/iotdb/db/engine/StorageEngineV2.java | 608 +
.../iotdb/db/engine/cache/AccountableString.java | 64 -
.../iotdb/db/engine/cache/BloomFilterCache.java | 188 +
.../db/engine/cache/CacheHitRatioMonitor.java | 79 +-
.../engine/cache/CacheHitRatioMonitorMXBean.java | 28 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 156 +-
.../iotdb/db/engine/cache/LRULinkedHashMap.java | 138 -
.../db/engine/cache/TimeSeriesMetadataCache.java | 280 +-
.../compaction/CompactionExceptionHandler.java | 247 +
.../compaction/CompactionMergeTaskPoolManager.java | 158 -
.../compaction/CompactionMetricsManager.java | 171 +
.../compaction/CompactionRecoverManager.java | 119 +
.../db/engine/compaction/CompactionScheduler.java | 166 +
.../db/engine/compaction/CompactionStrategy.java | 38 -
.../engine/compaction/CompactionTaskManager.java | 429 +
.../db/engine/compaction/CompactionUtils.java | 243 +
.../db/engine/compaction/TsFileManagement.java | 437 -
.../DefaultCompactionTaskComparatorImpl.java | 110 +
.../comparator/ICompactionTaskComparator.java | 35 +
.../compaction/constant/CompactionPriority.java | 26 +
.../compaction/constant/CompactionTaskStatus.java | 26 +
.../engine/compaction/constant/CompactionType.java | 25 +
.../constant/CrossCompactionPerformer.java | 41 +
.../constant/CrossCompactionSelector.java | 47 +
.../constant/InnerSeqCompactionPerformer.java | 41 +
.../constant/InnerSequenceCompactionSelector.java | 48 +
.../constant/InnerUnseqCompactionPerformer.java | 41 +
.../InnerUnsequenceCompactionSelector.java | 48 +
.../compaction/constant/ProcessChunkType.java | 25 +
.../compaction/cross/CrossSpaceCompactionTask.java | 301 +
.../compaction/cross/ICrossSpaceSelector.java | 30 +
.../RewriteCrossSpaceCompactionResource.java | 206 +
.../RewriteCrossSpaceCompactionSelector.java | 130 +
.../selector/ICrossSpaceMergeFileSelector.java | 33 +
.../rewrite/selector/IFileQueryMemMeasurement.java | 36 +
.../selector/RewriteCompactionFileSelector.java | 396 +
.../rewrite/task/ReadPointPerformerSubTask.java | 107 +
.../compaction/inner/IInnerSeqSpaceSelector.java | 28 +
.../compaction/inner/IInnerUnseqSpaceSelector.java | 28 +
.../compaction/inner/InnerSpaceCompactionTask.java | 381 +
.../sizetiered/SizeTieredCompactionSelector.java | 198 +
.../utils/AlignedSeriesCompactionExecutor.java | 178 +
.../inner/utils/MultiTsFileDeviceIterator.java | 427 +
.../utils/SingleSeriesCompactionExecutor.java | 319 +
.../level/LevelCompactionTsFileManagement.java | 831 --
.../compaction/log/CompactionLogAnalyzer.java | 162 +
.../db/engine/compaction/log/CompactionLogger.java | 83 +
.../db/engine/compaction/log/TsFileIdentifier.java | 234 +
.../no/NoCompactionTsFileManagement.java | 266 -
.../compaction/performer/ICompactionPerformer.java | 49 +
.../performer/ICrossCompactionPerformer.java | 27 +
.../performer/ISeqCompactionPerformer.java | 27 +
.../performer/IUnseqCompactionPerformer.java | 27 +
.../impl/ReadChunkCompactionPerformer.java | 166 +
.../impl/ReadPointCompactionPerformer.java | 359 +
.../compaction/task/AbstractCompactionTask.java | 134 +
.../compaction/task/CompactionRecoverTask.java | 498 +
.../compaction/task/CompactionTaskSummary.java | 32 +
.../compaction/task/ICompactionSelector.java | 54 +
.../compaction/utils/CompactionLogAnalyzer.java | 112 -
.../engine/compaction/utils/CompactionLogger.java | 77 -
.../engine/compaction/utils/CompactionUtils.java | 442 -
.../writer/AbstractCompactionWriter.java | 180 +
.../writer/CrossSpaceCompactionWriter.java | 180 +
.../writer/InnerSpaceCompactionWriter.java | 85 +
.../org/apache/iotdb/db/engine/cq/CQLogReader.java | 47 +
.../org/apache/iotdb/db/engine/cq/CQLogWriter.java | 74 +
.../engine/cq/ContinuousQuerySchemaCheckTask.java | 99 +
.../iotdb/db/engine/cq/ContinuousQueryService.java | 303 +
.../iotdb/db/engine/cq/ContinuousQueryTask.java | 199 +
.../engine/cq/ContinuousQueryTaskPoolManager.java | 107 +
.../db/engine/fileSystem/SystemFileFactory.java | 69 -
.../iotdb/db/engine/flush/FlushListener.java | 17 +-
.../apache/iotdb/db/engine/flush/FlushManager.java | 65 +-
.../apache/iotdb/db/engine/flush/FlushStatus.java | 28 +
.../iotdb/db/engine/flush/MemTableFlushTask.java | 104 +-
.../iotdb/db/engine/flush/NotifyFlushMemTable.java | 7 -
.../iotdb/db/engine/flush/TsFileFlushPolicy.java | 11 +-
.../db/engine/flush/pool/AbstractPoolManager.java | 91 -
.../engine/flush/pool/FlushSubTaskPoolManager.java | 5 +-
.../db/engine/flush/pool/FlushTaskPoolManager.java | 5 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 734 +-
.../engine/memtable/AlignedWritableMemChunk.java | 412 +
.../memtable/AlignedWritableMemChunkGroup.java | 142 +
.../apache/iotdb/db/engine/memtable/IMemTable.java | 99 +-
.../db/engine/memtable/IWritableMemChunk.java | 76 +-
.../db/engine/memtable/IWritableMemChunkGroup.java | 54 +
.../db/engine/memtable/PrimitiveMemTable.java | 12 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 225 +-
.../db/engine/memtable/WritableMemChunkGroup.java | 174 +
.../iotdb/db/engine/merge/manage/MergeContext.java | 88 -
.../iotdb/db/engine/merge/manage/MergeFuture.java | 151 -
.../iotdb/db/engine/merge/manage/MergeManager.java | 410 -
.../db/engine/merge/manage/MergeManagerMBean.java | 26 -
.../db/engine/merge/manage/MergeResource.java | 293 -
.../db/engine/merge/manage/MergeThreadPool.java | 54 -
.../apache/iotdb/db/engine/merge/package-info.java | 25 -
.../iotdb/db/engine/merge/recover/LogAnalyzer.java | 326 -
.../iotdb/db/engine/merge/recover/MergeLogger.java | 131 -
.../merge/selector/IFileQueryMemMeasurement.java | 36 -
.../engine/merge/selector/IMergeFileSelector.java | 35 -
.../engine/merge/selector/IMergePathSelector.java | 31 -
.../merge/selector/MaxFileMergeFileSelector.java | 359 -
.../merge/selector/MaxSeriesMergeFileSelector.java | 115 -
.../engine/merge/selector/MergeFileStrategy.java | 27 -
.../engine/merge/selector/NaivePathSelector.java | 55 -
.../iotdb/db/engine/merge/task/MergeCallback.java | 40 -
.../iotdb/db/engine/merge/task/MergeFileTask.java | 400 -
.../db/engine/merge/task/MergeMultiChunkTask.java | 694 -
.../iotdb/db/engine/merge/task/MergeTask.java | 276 -
.../db/engine/merge/task/RecoverMergeTask.java | 300 -
.../iotdb/db/engine/modification/Deletion.java | 25 +-
.../iotdb/db/engine/modification/Modification.java | 4 +-
.../db/engine/modification/ModificationFile.java | 21 +-
.../io/LocalTextModificationAccessor.java | 38 +-
.../engine/modification/io/ModificationReader.java | 3 +-
.../engine/modification/io/ModificationWriter.java | 4 +-
.../modification/utils/TracedBufferedReader.java | 462 +
.../querycontext/AlignedReadOnlyMemChunk.java | 158 +
.../db/engine/querycontext/QueryDataSource.java | 62 +-
.../db/engine/querycontext/ReadOnlyMemChunk.java | 111 +-
.../selectinto/InsertTabletPlanGenerator.java | 252 +
.../selectinto/InsertTabletPlansIterator.java | 190 +
.../apache/iotdb/db/engine/settle/SettleLog.java | 116 +
.../apache/iotdb/db/engine/settle/SettleTask.java | 108 +
.../iotdb/db/engine/storagegroup/DataRegion.java | 3510 +++++
.../storagegroup/IDTableFlushTimeManager.java | 207 +
.../engine/storagegroup/ILastFlushTimeManager.java | 89 +
.../engine/storagegroup/LastFlushTimeManager.java | 268 +
.../db/engine/storagegroup/StorageGroupInfo.java | 55 +-
.../engine/storagegroup/StorageGroupProcessor.java | 2965 -----
.../db/engine/storagegroup/TsFileManager.java | 428 +
.../engine/storagegroup/TsFileNameGenerator.java | 290 +
.../db/engine/storagegroup/TsFileProcessor.java | 850 +-
.../engine/storagegroup/TsFileProcessorInfo.java | 40 +-
.../db/engine/storagegroup/TsFileResource.java | 693 +-
.../db/engine/storagegroup/TsFileResourceList.java | 420 +
.../engine/storagegroup/TsFileResourceStatus.java | 27 +
.../dataregion/HashVirtualPartitioner.java | 58 +
.../dataregion/StorageGroupManager.java | 499 +
.../dataregion/VirtualPartitioner.java | 39 +
.../storagegroup/timeindex/DeviceTimeIndex.java | 133 +-
.../storagegroup/timeindex/FileTimeIndex.java | 127 +-
.../engine/storagegroup/timeindex/ITimeIndex.java | 53 +-
.../storagegroup/timeindex/TimeIndexLevel.java | 22 +-
.../storagegroup/timeindex/V012FileTimeIndex.java | 176 +
.../virtualSg/HashVirtualPartitioner.java | 63 -
.../storagegroup/virtualSg/VirtualPartitioner.java | 39 -
.../virtualSg/VirtualStorageGroupManager.java | 408 -
.../iotdb/db/engine/trigger/api/Trigger.java | 116 +
.../db/engine/trigger/api/TriggerAttributes.java | 98 +
.../iotdb/db/engine/trigger/api/TriggerEvent.java | 35 -
.../db/engine/trigger/executor/TriggerEngine.java | 118 +
.../db/engine/trigger/executor/TriggerEvent.java | 53 +
.../engine/trigger/executor/TriggerExecutor.java | 243 +
.../engine/trigger/service/TriggerClassLoader.java | 55 +
.../trigger/service/TriggerClassLoaderManager.java | 94 +
.../engine/trigger/service/TriggerLogReader.java | 48 +
.../engine/trigger/service/TriggerLogWriter.java | 68 +
.../service/TriggerRegistrationInformation.java | 82 +
.../service/TriggerRegistrationService.java | 504 +
.../alertmanager/AlertManagerConfiguration.java | 35 +
.../sink/alertmanager/AlertManagerEvent.java | 123 +
.../sink/alertmanager/AlertManagerHandler.java | 83 +
.../db/engine/trigger/sink/api/Configuration.java | 22 +
.../iotdb/db/engine/trigger/sink/api/Event.java | 22 +
.../iotdb/db/engine/trigger/sink/api/Handler.java | 32 +
.../trigger/sink/exception/SinkException.java | 31 +
.../sink/local/LocalIoTDBConfiguration.java | 51 +
.../engine/trigger/sink/local/LocalIoTDBEvent.java | 41 +
.../trigger/sink/local/LocalIoTDBHandler.java | 104 +
.../trigger/sink/mqtt/MQTTConfiguration.java | 105 +
.../db/engine/trigger/sink/mqtt/MQTTEvent.java | 62 +
.../db/engine/trigger/sink/mqtt/MQTTHandler.java | 96 +
.../apache/iotdb/db/engine/upgrade/UpgradeLog.java | 2 +-
.../iotdb/db/engine/upgrade/UpgradeTask.java | 62 +-
.../version/SimpleFileVersionController.java | 3 +-
.../db/exception/BadNodeUrlFormatException.java | 28 +
.../iotdb/db/exception/BatchProcessException.java | 2 +-
.../db/exception/ContinuousQueryException.java | 36 +
.../iotdb/db/exception/DataRegionException.java | 35 +
.../apache/iotdb/db/exception/IoTDBException.java | 67 -
.../iotdb/db/exception/LoadFileException.java | 1 +
.../apache/iotdb/db/exception/MergeException.java | 1 +
.../db/exception/QueryIdNotExsitException.java | 1 +
.../exception/QueryInBatchStatementException.java | 1 +
.../iotdb/db/exception/ShutdownException.java | 40 -
.../iotdb/db/exception/StartupException.java | 40 -
.../iotdb/db/exception/StorageEngineException.java | 1 +
.../exception/StorageEngineReadonlyException.java | 32 +
.../exception/StorageGroupNotReadyException.java | 27 +
.../exception/StorageGroupProcessorException.java | 34 -
.../db/exception/SyncConnectionException.java | 1 +
.../SyncDeviceOwnerConflictException.java | 39 -
.../iotdb/db/exception/SystemCheckException.java | 1 +
.../db/exception/TriggerExecutionException.java | 32 +
.../db/exception/TriggerManagementException.java | 32 +
.../db/exception/TsFileProcessorException.java | 1 +
.../TsFileTimeseriesMetadataException.java | 26 +
.../db/exception/WriteLockFailedException.java | 27 +
.../iotdb/db/exception/WriteProcessException.java | 1 +
.../db/exception/index/IndexManagerException.java | 2 +-
.../metadata/AcquireLockTimeoutException.java | 28 +
.../metadata/AliasAlreadyExistException.java | 1 +
.../metadata/AlignedTimeseriesException.java | 36 +
.../metadata/DataTypeMismatchException.java | 7 +-
.../exception/metadata/DeleteFailedException.java | 1 +
.../metadata/IllegalParameterOfPathException.java | 1 +
.../exception/metadata/IllegalPathException.java | 32 -
.../metadata/MNodeTypeMismatchException.java | 31 +
.../db/exception/metadata/MetadataException.java | 63 -
.../metadata/PathAlreadyExistException.java | 1 +
.../exception/metadata/PathNotExistException.java | 1 +
.../SchemaDirCreationFailureException.java | 28 +
.../metadata/SeriesOverflowException.java | 34 +
.../metadata/StorageGroupAlreadySetException.java | 17 +
.../metadata/StorageGroupNotSetException.java | 11 +
.../metadata/cache/MNodeNotCachedException.java | 28 +
.../metadata/cache/MNodeNotPinnedException.java | 29 +
.../schemafile/RecordDuplicatedException.java | 34 +
.../metadata/schemafile/SchemaFileNotExists.java | 34 +
.../schemafile/SchemaPageOverflowException.java | 34 +
.../schemafile/SegmentNotFoundException.java | 41 +
.../schemafile/SegmentOverflowException.java | 41 +
.../template/DifferentTemplateException.java | 34 +
.../template/DuplicatedTemplateException.java | 32 +
.../template/NoTemplateOnMNodeException.java | 34 +
.../template/TemplateImcompatibeException.java | 41 +
.../template/TemplateIsInUseException.java | 34 +
.../template/UndefinedTemplateException.java | 32 +
.../exception/query/LogicalOperatorException.java | 2 +-
.../exception/query/LogicalOptimizeException.java | 9 +-
.../exception/query/PathNumOverLimitException.java | 15 +-
.../db/exception/query/QueryProcessException.java | 6 +-
.../query/QueryTimeoutRuntimeException.java | 4 +-
.../db/exception/runtime/RPCServiceException.java | 32 -
.../db/exception/runtime/SQLParserException.java | 35 -
.../iotdb/db/exception/sql/SQLParserException.java | 35 +
.../iotdb/db/exception/sql/SemanticException.java | 27 +
.../exception/sql/StatementAnalyzeException.java | 40 +
.../sync/PipeDataLoadBearableException.java | 25 +
.../db/exception/sync/PipeDataLoadException.java | 25 +
.../sync/PipeDataLoadUnbearableException.java | 25 +
.../iotdb/db/exception/sync/PipeException.java | 36 +
.../db/exception/sync/PipeServerException.java | 34 +
.../iotdb/db/exception/sync/PipeSinkException.java | 42 +
.../iotdb/db/localconfignode/LocalConfigNode.java | 815 ++
.../localconfignode/LocalDataPartitionTable.java | 126 +
.../localconfignode/LocalSchemaPartitionTable.java | 121 +
.../iotdb/db/metadata/LocalSchemaProcessor.java | 1409 ++
.../apache/iotdb/db/metadata/MLogTxtWriter.java | 267 -
.../org/apache/iotdb/db/metadata/MManager.java | 1962 ---
.../java/org/apache/iotdb/db/metadata/MTree.java | 1572 ---
.../apache/iotdb/db/metadata/MeasurementMeta.java | 85 -
.../org/apache/iotdb/db/metadata/MetaUtils.java | 140 -
.../org/apache/iotdb/db/metadata/Metadata.java | 120 -
.../apache/iotdb/db/metadata/MetadataConstant.java | 37 +-
.../iotdb/db/metadata/MetadataOperationType.java | 36 -
.../org/apache/iotdb/db/metadata/PartialPath.java | 315 -
.../org/apache/iotdb/db/metadata/TagLogFile.java | 169 -
.../db/metadata/cache/DataNodeSchemaCache.java | 117 +
.../iotdb/db/metadata/cache/SchemaCacheEntry.java | 58 +
.../idtable/AppendOnlyDiskSchemaManager.java | 202 +
.../apache/iotdb/db/metadata/idtable/IDTable.java | 202 +
.../db/metadata/idtable/IDTableHashmapImpl.java | 467 +
.../iotdb/db/metadata/idtable/IDTableManager.java | 137 +
.../db/metadata/idtable/IDiskSchemaManager.java | 55 +
.../db/metadata/idtable/entry/DeviceEntry.java | 185 +
.../db/metadata/idtable/entry/DeviceIDFactory.java | 97 +
.../db/metadata/idtable/entry/DiskSchemaEntry.java | 124 +
.../iotdb/db/metadata/idtable/entry/IDeviceID.java | 35 +
.../idtable/entry/InsertMeasurementMNode.java | 295 +
.../db/metadata/idtable/entry/PlainDeviceID.java | 70 +
.../db/metadata/idtable/entry/SHA256DeviceID.java | 169 +
.../db/metadata/idtable/entry/SchemaEntry.java | 216 +
.../db/metadata/idtable/entry/TimeseriesID.java | 51 +
.../db/metadata/lastCache/LastCacheManager.java | 255 +
.../lastCache/container/ILastCacheContainer.java | 45 +
.../lastCache/container/LastCacheContainer.java | 70 +
.../lastCache/container/value/ILastCacheValue.java | 35 +
.../lastCache/container/value/LastCacheValue.java | 55 +
.../iotdb/db/metadata/logfile/MLogReader.java | 6 +-
.../iotdb/db/metadata/logfile/MLogTxtReader.java | 4 +-
.../iotdb/db/metadata/logfile/MLogTxtWriter.java | 458 +
.../iotdb/db/metadata/logfile/MLogWriter.java | 275 +-
.../db/metadata/logfile/MetadataOperationType.java | 48 +
.../iotdb/db/metadata/mnode/EntityMNode.java | 163 +
.../iotdb/db/metadata/mnode/IEntityMNode.java | 47 +
.../org/apache/iotdb/db/metadata/mnode/IMNode.java | 103 +
.../iotdb/db/metadata/mnode/IMeasurementMNode.java | 54 +
.../db/metadata/mnode/IStorageGroupMNode.java | 39 +
.../iotdb/db/metadata/mnode/InternalMNode.java | 242 +
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 339 +-
.../apache/iotdb/db/metadata/mnode/MNodeUtils.java | 77 +
.../iotdb/db/metadata/mnode/MeasurementMNode.java | 261 +-
.../db/metadata/mnode/StorageGroupEntityMNode.java | 89 +
.../iotdb/db/metadata/mnode/StorageGroupMNode.java | 69 +-
.../metadata/mnode/container/IMNodeContainer.java | 25 +
.../mnode/container/MNodeContainerMapImpl.java | 26 +
.../metadata/mnode/container/MNodeContainers.java | 103 +
.../mnode/estimator/BasicMNodSizeEstimator.java | 117 +
.../mnode/estimator/IMNodeSizeEstimator.java | 38 +
.../db/metadata/mnode/iterator/IMNodeIterator.java | 28 +
.../db/metadata/mnode/iterator/MNodeIterator.java | 48 +
.../iotdb/db/metadata/mtree/IMTreeBelowSG.java | 308 +
.../iotdb/db/metadata/mtree/MTreeAboveSG.java | 597 +
.../db/metadata/mtree/MTreeBelowSGCachedImpl.java | 1516 +++
.../db/metadata/mtree/MTreeBelowSGMemoryImpl.java | 1348 ++
.../db/metadata/mtree/store/CachedMTreeStore.java | 590 +
.../iotdb/db/metadata/mtree/store/IMTreeStore.java | 61 +
.../db/metadata/mtree/store/MemMTreeStore.java | 170 +
.../mtree/store/disk/CachedMNodeContainer.java | 443 +
.../mtree/store/disk/ICachedMNodeContainer.java | 80 +
.../mtree/store/disk/MTreeFlushTaskManager.java | 71 +
.../mtree/store/disk/MTreeReleaseTaskManager.java | 73 +
.../db/metadata/mtree/store/disk/SegmentLock.java | 91 +
.../mtree/store/disk/cache/CacheEntry.java | 48 +
.../mtree/store/disk/cache/CacheManager.java | 542 +
.../mtree/store/disk/cache/ICacheManager.java | 52 +
.../mtree/store/disk/cache/LRUCacheManager.java | 256 +
.../mtree/store/disk/cache/PlainCacheManager.java | 72 +
.../disk/memcontrol/CachedMNodeSizeEstimator.java | 71 +
.../mtree/store/disk/memcontrol/IMemManager.java | 52 +
.../store/disk/memcontrol/MemManagerHolder.java | 41 +
.../MemManagerNodeEstimatedSizeBasedImpl.java | 132 +
.../memcontrol/MemManagerNodeNumBasedImpl.java | 105 +
.../mtree/store/disk/schemafile/ISchemaFile.java | 63 +
.../mtree/store/disk/schemafile/ISchemaPage.java | 125 +
.../mtree/store/disk/schemafile/ISegment.java | 97 +
.../store/disk/schemafile/MockSchemaFile.java | 235 +
.../mtree/store/disk/schemafile/RecordUtils.java | 365 +
.../mtree/store/disk/schemafile/SchemaFile.java | 1019 ++
.../mtree/store/disk/schemafile/SchemaPage.java | 622 +
.../mtree/store/disk/schemafile/Segment.java | 759 ++
.../db/metadata/mtree/traverser/Traverser.java | 470 +
.../traverser/collector/CollectorTraverser.java | 96 +
.../mtree/traverser/collector/EntityCollector.java | 65 +
.../traverser/collector/MNodeAboveSGCollector.java | 59 +
.../mtree/traverser/collector/MNodeCollector.java | 98 +
.../traverser/collector/MeasurementCollector.java | 93 +
.../traverser/collector/StorageGroupCollector.java | 62 +
.../mtree/traverser/counter/CounterTraverser.java | 40 +
.../mtree/traverser/counter/EntityCounter.java | 46 +
.../counter/MNodeAboveSGLevelCounter.java | 60 +
.../mtree/traverser/counter/MNodeLevelCounter.java | 83 +
.../traverser/counter/MeasurementCounter.java | 49 +
.../counter/MeasurementGroupByLevelCounter.java | 102 +
.../traverser/counter/StorageGroupCounter.java | 48 +
.../apache/iotdb/db/metadata/path/AlignedPath.java | 295 +
.../iotdb/db/metadata/path/MeasurementPath.java | 198 +
.../db/metadata/path/PathDeserializeUtil.java | 43 +
.../iotdb/db/metadata/rescon/MemoryStatistics.java | 97 +
.../db/metadata/rescon/SchemaResourceManager.java | 67 +
.../db/metadata/rescon/TimeseriesStatistics.java | 76 +
.../db/metadata/schemaregion/ISchemaRegion.java | 363 +
.../metadata/schemaregion/RSchemaRegionLoader.java | 111 +
.../db/metadata/schemaregion/SchemaEngine.java | 239 +
.../db/metadata/schemaregion/SchemaEngineMode.java | 26 +
.../schemaregion/SchemaRegionMemoryImpl.java | 1714 +++
.../schemaregion/SchemaRegionSchemaFileImpl.java | 1838 +++
.../metadata/schemaregion/SchemaRegionUtils.java | 101 +
.../storagegroup/IStorageGroupSchemaManager.java | 218 +
.../storagegroup/StorageGroupLogReader.java | 47 +
.../storagegroup/StorageGroupLogWriter.java | 56 +
.../storagegroup/StorageGroupSchemaManager.java | 291 +
.../apache/iotdb/db/metadata/tag/TagLogFile.java | 158 +
.../apache/iotdb/db/metadata/tag/TagManager.java | 573 +
.../iotdb/db/metadata/template/Template.java | 716 +
.../db/metadata/template/TemplateLogReader.java | 46 +
.../db/metadata/template/TemplateLogWriter.java | 64 +
.../db/metadata/template/TemplateManager.java | 384 +
.../db/metadata/template/TemplateQueryType.java | 30 +
.../db/metadata/tree/AbstractTreeVisitor.java | 380 +
.../tree/AbstractTreeVisitorWithLimitOffset.java | 106 +
.../apache/iotdb/db/metadata/tree/ITreeNode.java | 25 +
.../db/metadata/upgrade/MetadataUpgrader.java | 437 +
.../iotdb/db/metadata/utils/MetaFormatUtils.java | 168 +
.../apache/iotdb/db/metadata/utils/MetaUtils.java | 192 +
.../db/metadata/utils/ResourceByPathUtils.java | 606 +
.../metadata/visitor/SchemaExecutionVisitor.java | 149 +
.../apache/iotdb/db/metrics/server/JettyUtil.java | 107 -
.../iotdb/db/metrics/server/MetricsSystem.java | 82 -
.../iotdb/db/metrics/server/QueryServlet.java | 56 -
.../iotdb/db/metrics/server/ServerArgument.java | 324 -
.../iotdb/db/metrics/server/SqlArgument.java | 84 -
.../apache/iotdb/db/metrics/sink/ConsoleSink.java | 54 -
.../iotdb/db/metrics/sink/MetricsServletSink.java | 53 -
.../org/apache/iotdb/db/metrics/sink/Sink.java | 28 -
.../apache/iotdb/db/metrics/source/JvmSource.java | 50 -
.../iotdb/db/metrics/source/MetricsSource.java | 134 -
.../org/apache/iotdb/db/metrics/source/Source.java | 24 -
.../apache/iotdb/db/metrics/ui/MetricsPage.java | 187 -
.../apache/iotdb/db/metrics/ui/MetricsWebUI.java | 68 -
.../org/apache/iotdb/db/monitor/IStatistic.java | 54 -
.../apache/iotdb/db/monitor/MonitorConstants.java | 47 -
.../org/apache/iotdb/db/monitor/StatMonitor.java | 308 -
.../apache/iotdb/db/monitor/StatMonitorMBean.java | 38 -
.../iotdb/db/mpp/aggregation/Accumulator.java | 70 +
.../db/mpp/aggregation/AccumulatorFactory.java | 71 +
.../iotdb/db/mpp/aggregation/Aggregator.java | 122 +
.../iotdb/db/mpp/aggregation/AvgAccumulator.java | 180 +
.../iotdb/db/mpp/aggregation/CountAccumulator.java | 101 +
.../db/mpp/aggregation/ExtremeAccumulator.java | 296 +
.../db/mpp/aggregation/FirstValueAccumulator.java | 319 +
.../mpp/aggregation/FirstValueDescAccumulator.java | 91 +
.../db/mpp/aggregation/LastValueAccumulator.java | 305 +
.../mpp/aggregation/LastValueDescAccumulator.java | 135 +
.../db/mpp/aggregation/MaxTimeAccumulator.java | 101 +
.../db/mpp/aggregation/MaxTimeDescAccumulator.java | 57 +
.../db/mpp/aggregation/MaxValueAccumulator.java | 270 +
.../db/mpp/aggregation/MinTimeAccumulator.java | 105 +
.../db/mpp/aggregation/MinTimeDescAccumulator.java | 41 +
.../db/mpp/aggregation/MinValueAccumulator.java | 270 +
.../iotdb/db/mpp/aggregation/SumAccumulator.java | 172 +
.../iotdb/db/mpp/common/FragmentInstanceId.java | 102 +
.../iotdb/db/mpp/common/MPPQueryContext.java | 79 +
.../apache/iotdb/db/mpp/common/PlanFragmentId.java | 99 +
.../org/apache/iotdb/db/mpp/common/QueryId.java | 138 +
.../iotdb/db/mpp/common/ResultNodeContext.java | 67 +
.../apache/iotdb/db/mpp/common/SchemaRegion.java | 29 +
.../apache/iotdb/db/mpp/common/SessionInfo.java | 26 +
.../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 +
.../iotdb/db/mpp/common/header/ColumnHeader.java | 108 +
.../iotdb/db/mpp/common/header/DatasetHeader.java | 94 +
.../iotdb/db/mpp/common/header/HeaderConstant.java | 130 +
.../db/mpp/common/schematree/DeviceSchemaInfo.java | 117 +
.../db/mpp/common/schematree/PathPatternNode.java | 116 +
.../db/mpp/common/schematree/PathPatternTree.java | 283 +
.../iotdb/db/mpp/common/schematree/SchemaTree.java | 293 +
.../common/schematree/node/SchemaEntityNode.java | 119 +
.../common/schematree/node/SchemaInternalNode.java | 97 +
.../schematree/node/SchemaMeasurementNode.java | 102 +
.../db/mpp/common/schematree/node/SchemaNode.java | 82 +
.../visitor/SchemaTreeDeviceVisitor.java | 61 +
.../visitor/SchemaTreeMeasurementVisitor.java | 80 +
.../schematree/visitor/SchemaTreeVisitor.java | 60 +
.../iotdb/db/mpp/execution/FutureStateChange.java | 74 +
.../apache/iotdb/db/mpp/execution/QueryState.java | 49 +
.../iotdb/db/mpp/execution/QueryStateMachine.java | 140 +
.../iotdb/db/mpp/execution/StateMachine.java | 322 +
.../execution/datatransfer/DataBlockManager.java | 476 +
.../execution/datatransfer/DataBlockService.java | 137 +
.../datatransfer/DataBlockServiceMBean.java | 34 +
.../DataBlockServiceThriftHandler.java | 44 +
.../execution/datatransfer/IDataBlockManager.java | 85 +
.../datatransfer/IDataBlockManagerCallback.java | 24 +
.../db/mpp/execution/datatransfer/ISinkHandle.java | 73 +
.../mpp/execution/datatransfer/ISourceHandle.java | 57 +
.../execution/datatransfer/LocalSinkHandle.java | 146 +
.../execution/datatransfer/LocalSourceHandle.java | 125 +
.../execution/datatransfer/SharedTsBlockQueue.java | 152 +
.../db/mpp/execution/datatransfer/SinkHandle.java | 374 +
.../mpp/execution/datatransfer/SourceHandle.java | 430 +
.../datatransfer/TsBlockSerdeFactory.java | 31 +
.../iotdb/db/mpp/execution/driver/DataDriver.java | 193 +
.../db/mpp/execution/driver/DataDriverContext.java | 64 +
.../iotdb/db/mpp/execution/driver/Driver.java | 452 +
.../db/mpp/execution/driver/DriverContext.java | 56 +
.../iotdb/db/mpp/execution/driver/IDriver.java | 71 +
.../db/mpp/execution/driver/SchemaDriver.java | 45 +
.../mpp/execution/driver/SchemaDriverContext.java | 38 +
.../db/mpp/execution/fragment/FragmentInfo.java | 44 +
.../fragment/FragmentInstanceContext.java | 164 +
.../fragment/FragmentInstanceExecution.java | 119 +
.../fragment/FragmentInstanceFailureListener.java | 25 +
.../execution/fragment/FragmentInstanceInfo.java | 40 +
.../fragment/FragmentInstanceManager.java | 232 +
.../execution/fragment/FragmentInstanceState.java | 80 +
.../fragment/FragmentInstanceStateMachine.java | 183 +
.../db/mpp/execution/fragment/FragmentState.java | 71 +
.../mpp/execution/memory/LocalMemoryManager.java | 43 +
.../iotdb/db/mpp/execution/memory/MemoryPool.java | 202 +
.../iotdb/db/mpp/execution/operator/Operator.java | 55 +
.../db/mpp/execution/operator/OperatorContext.java | 54 +
.../operator/process/AggregateOperator.java | 72 +
.../operator/process/DeviceMergeOperator.java | 274 +
.../operator/process/DeviceViewOperator.java | 152 +
.../execution/operator/process/FillOperator.java | 56 +
.../operator/process/FilterNullOperator.java | 57 +
.../execution/operator/process/FilterOperator.java | 161 +
.../execution/operator/process/LimitOperator.java | 80 +
.../execution/operator/process/OffsetOperator.java | 79 +
.../operator/process/ProcessOperator.java | 24 +
.../execution/operator/process/SortOperator.java | 57 +
.../operator/process/TimeJoinOperator.java | 251 +
.../operator/process/TransformOperator.java | 261 +
.../operator/process/merge/AscTimeComparator.java | 33 +
.../operator/process/merge/ColumnMerger.java | 60 +
.../operator/process/merge/DescTimeComparator.java | 33 +
.../operator/process/merge/MultiColumnMerger.java | 96 +
.../merge/NonOverlappedMultiColumnMerger.java | 87 +
.../operator/process/merge/SingleColumnMerger.java | 113 +
.../operator/process/merge/TimeComparator.java | 28 +
.../operator/schema/CountMergeOperator.java | 133 +
.../operator/schema/DevicesCountOperator.java | 90 +
.../operator/schema/DevicesSchemaScanOperator.java | 83 +
.../schema/LevelTimeSeriesCountOperator.java | 100 +
.../operator/schema/SchemaFetchMergeOperator.java | 94 +
.../operator/schema/SchemaFetchScanOperator.java | 128 +
.../operator/schema/SchemaQueryMergeOperator.java | 94 +
.../operator/schema/SchemaQueryScanOperator.java | 112 +
.../operator/schema/TimeSeriesCountOperator.java | 90 +
.../schema/TimeSeriesSchemaScanOperator.java | 125 +
.../operator/sink/FragmentSinkOperator.java | 66 +
.../mpp/execution/operator/sink/SinkOperator.java | 43 +
.../operator/source/AlignedSeriesScanOperator.java | 149 +
.../operator/source/AlignedSeriesScanUtil.java | 91 +
.../operator/source/DataSourceOperator.java | 26 +
.../operator/source/ExchangeOperator.java | 86 +
.../source/SeriesAggregateScanOperator.java | 461 +
.../operator/source/SeriesScanOperator.java | 153 +
.../execution/operator/source/SeriesScanUtil.java | 1426 ++
.../execution/operator/source/SourceOperator.java | 27 +
.../execution/schedule/AbstractDriverThread.java | 71 +
.../db/mpp/execution/schedule/DriverScheduler.java | 357 +
.../mpp/execution/schedule/DriverTaskThread.java | 85 +
.../schedule/DriverTaskTimeoutSentinelThread.java | 56 +
.../mpp/execution/schedule/ExecutionContext.java | 46 +
.../schedule/FragmentInstanceAbortedException.java | 35 +
.../mpp/execution/schedule/IDriverScheduler.java | 61 +
.../db/mpp/execution/schedule/ITaskScheduler.java | 72 +
.../iotdb/db/mpp/execution/schedule/queue/ID.java | 22 +
.../schedule/queue/IDIndexedAccessible.java | 48 +
.../schedule/queue/IndexedBlockingQueue.java | 201 +
.../execution/schedule/queue/L1PriorityQueue.java | 102 +
.../execution/schedule/queue/L2PriorityQueue.java | 129 +
.../db/mpp/execution/schedule/task/DriverTask.java | 217 +
.../mpp/execution/schedule/task/DriverTaskID.java | 68 +
.../execution/schedule/task/DriverTaskStatus.java | 37 +
.../org/apache/iotdb/db/mpp/plan/Coordinator.java | 150 +
.../apache/iotdb/db/mpp/plan/analyze/Analysis.java | 238 +
.../apache/iotdb/db/mpp/plan/analyze/Analyzer.java | 1061 ++
.../mpp/plan/analyze/ClusterPartitionFetcher.java | 603 +
.../db/mpp/plan/analyze/ClusterSchemaFetcher.java | 355 +
.../plan/analyze/ColumnPaginationController.java | 73 +
.../db/mpp/plan/analyze/ConcatPathRewriter.java | 135 +
.../db/mpp/plan/analyze/ExpressionAnalyzer.java | 854 ++
.../iotdb/db/mpp/plan/analyze/ExpressionUtils.java | 242 +
.../mpp/plan/analyze/FakePartitionFetcherImpl.java | 158 +
.../db/mpp/plan/analyze/FakeSchemaFetcherImpl.java | 99 +
.../mpp/plan/analyze/GroupByLevelController.java | 144 +
.../db/mpp/plan/analyze/IPartitionFetcher.java | 43 +
.../iotdb/db/mpp/plan/analyze/ISchemaFetcher.java | 44 +
.../iotdb/db/mpp/plan/analyze/QueryType.java | 24 +
.../iotdb/db/mpp/plan/analyze/SchemaValidator.java | 57 +
.../plan/analyze/StandalonePartitionFetcher.java | 127 +
.../mpp/plan/analyze/StandaloneSchemaFetcher.java | 89 +
.../iotdb/db/mpp/plan/analyze/TypeProvider.java | 94 +
.../iotdb/db/mpp/plan/constant/FilterConstant.java | 103 +
.../iotdb/db/mpp/plan/constant/StatementType.java | 139 +
.../db/mpp/plan/execution/ExecutionResult.java | 32 +
.../db/mpp/plan/execution/IQueryExecution.java | 46 +
.../db/mpp/plan/execution/QueryExecution.java | 360 +
.../execution/config/AuthorizerConfigTask.java | 183 +
.../mpp/plan/execution/config/ConfigExecution.java | 166 +
.../plan/execution/config/ConfigTaskResult.java | 61 +
.../plan/execution/config/ConfigTaskVisitor.java | 86 +
.../execution/config/CountStorageGroupTask.java | 96 +
.../db/mpp/plan/execution/config/IConfigTask.java | 26 +
.../plan/execution/config/SetStorageGroupTask.java | 96 +
.../db/mpp/plan/execution/config/SetTTLTask.java | 94 +
.../execution/config/ShowStorageGroupTask.java | 111 +
.../db/mpp/plan/execution/config/ShowTTLTask.java | 133 +
.../db/mpp/plan/execution/config/UnSetTTLTask.java | 29 +
.../db/mpp/plan/optimization/PlanOptimizer.java | 26 +
.../iotdb/db/mpp/plan/parser/ASTVisitor.java | 1740 +++
.../db/mpp/plan/parser/StatementGenerator.java | 402 +
.../db/mpp/plan/planner/DistributionPlanner.java | 607 +
.../mpp/plan/planner/IFragmentParallelPlaner.java | 38 +
.../db/mpp/plan/planner/LocalExecutionPlanner.java | 753 ++
.../db/mpp/plan/planner/LogicalPlanBuilder.java | 251 +
.../iotdb/db/mpp/plan/planner/LogicalPlanner.java | 346 +
.../planner/SimpleFragmentParallelPlanner.java | 142 +
.../plan/planner/WriteFragmentParallelPlanner.java | 69 +
.../plan/planner/plan/DistributedQueryPlan.java | 57 +
.../db/mpp/plan/planner/plan/FragmentInstance.java | 178 +
.../db/mpp/plan/planner/plan/LogicalQueryPlan.java | 45 +
.../db/mpp/plan/planner/plan/PlanFragment.java | 156 +
.../iotdb/db/mpp/plan/planner/plan/SubPlan.java | 69 +
.../plan/planner/plan/node/PlanGraphPrinter.java | 309 +
.../db/mpp/plan/planner/plan/node/PlanNode.java | 118 +
.../db/mpp/plan/planner/plan/node/PlanNodeId.java | 61 +
.../mpp/plan/planner/plan/node/PlanNodeType.java | 205 +
.../mpp/plan/planner/plan/node/PlanNodeUtil.java | 116 +
.../db/mpp/plan/planner/plan/node/PlanVisitor.java | 194 +
.../planner/plan/node/SimplePlanNodeRewriter.java | 48 +
.../mpp/plan/planner/plan/node/WritePlanNode.java | 36 +
.../metedata/read/AbstractSchemaMergeNode.java | 61 +
.../node/metedata/read/CountSchemaMergeNode.java | 54 +
.../plan/node/metedata/read/DevicesCountNode.java | 68 +
.../node/metedata/read/DevicesSchemaScanNode.java | 110 +
.../metedata/read/LevelTimeSeriesCountNode.java | 98 +
.../node/metedata/read/SchemaFetchMergeNode.java | 59 +
.../node/metedata/read/SchemaFetchScanNode.java | 117 +
.../node/metedata/read/SchemaQueryMergeNode.java | 64 +
.../node/metedata/read/SchemaQueryScanNode.java | 155 +
.../node/metedata/read/TimeSeriesCountNode.java | 68 +
.../metedata/read/TimeSeriesSchemaScanNode.java | 143 +
.../node/metedata/write/AlterTimeSeriesNode.java | 298 +
.../write/CreateAlignedTimeSeriesNode.java | 379 +
.../node/metedata/write/CreateTimeSeriesNode.java | 332 +
.../planner/plan/node/process/AggregationNode.java | 186 +
.../planner/plan/node/process/DeviceMergeNode.java | 149 +
.../planner/plan/node/process/DeviceViewNode.java | 166 +
.../planner/plan/node/process/ExchangeNode.java | 209 +
.../plan/planner/plan/node/process/FillNode.java | 117 +
.../plan/planner/plan/node/process/FilterNode.java | 115 +
.../planner/plan/node/process/FilterNullNode.java | 128 +
.../plan/node/process/GroupByLevelNode.java | 172 +
.../planner/plan/node/process/GroupByTimeNode.java | 165 +
.../plan/planner/plan/node/process/LimitNode.java | 128 +
.../plan/planner/plan/node/process/OffsetNode.java | 119 +
.../planner/plan/node/process/ProcessNode.java | 29 +
.../planner/plan/node/process/ProjectNode.java | 115 +
.../plan/planner/plan/node/process/SortNode.java | 119 +
.../planner/plan/node/process/TimeJoinNode.java | 135 +
.../planner/plan/node/process/TransformNode.java | 164 +
.../planner/plan/node/sink/FragmentSinkNode.java | 188 +
.../mpp/plan/planner/plan/node/sink/SinkNode.java | 31 +
.../source/AlignedSeriesAggregationScanNode.java | 268 +
.../plan/node/source/AlignedSeriesScanNode.java | 264 +
.../node/source/SeriesAggregationScanNode.java | 318 +
.../planner/plan/node/source/SeriesScanNode.java | 312 +
.../plan/planner/plan/node/source/SourceNode.java | 36 +
.../planner/plan/node/write/BatchInsertNode.java | 40 +
.../plan/node/write/InsertMultiTabletsNode.java | 272 +
.../plan/planner/plan/node/write/InsertNode.java | 300 +
.../planner/plan/node/write/InsertRowNode.java | 609 +
.../planner/plan/node/write/InsertRowsNode.java | 246 +
.../plan/node/write/InsertRowsOfOneDeviceNode.java | 282 +
.../planner/plan/node/write/InsertTabletNode.java | 828 ++
.../plan/parameter/AggregationDescriptor.java | 106 +
.../planner/plan/parameter/AggregationStep.java | 97 +
.../planner/plan/parameter/FillDescriptor.java | 79 +
.../plan/parameter/FilterNullParameter.java | 99 +
.../plan/parameter/GroupByTimeParameter.java | 184 +
.../plan/planner/plan/parameter/InputLocation.java | 72 +
.../plan/planner/plan/parameter/OutputColumn.java | 91 +
.../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 +
.../scheduler/AbstractFragInsStateTracker.java | 84 +
.../db/mpp/plan/scheduler/ClusterScheduler.java | 169 +
.../scheduler/FixedRateFragInsStateTracker.java | 86 +
.../plan/scheduler/FragInstanceDispatchResult.java | 32 +
.../plan/scheduler/IFragInstanceDispatcher.java | 37 +
.../plan/scheduler/IFragInstanceStateTracker.java | 26 +
.../db/mpp/plan/scheduler/IQueryTerminator.java | 26 +
.../iotdb/db/mpp/plan/scheduler/IScheduler.java | 40 +
.../scheduler/SimpleFragInstanceDispatcher.java | 87 +
.../mpp/plan/scheduler/SimpleQueryTerminator.java | 101 +
.../db/mpp/plan/scheduler/StandaloneScheduler.java | 113 +
.../db/mpp/plan/statement/IConfigStatement.java | 36 +
.../iotdb/db/mpp/plan/statement/Statement.java | 67 +
.../iotdb/db/mpp/plan/statement/StatementNode.java | 32 +
.../db/mpp/plan/statement/StatementVisitor.java | 173 +
.../plan/statement/component/FillComponent.java | 48 +
.../mpp/plan/statement/component/FillPolicy.java | 25 +
.../statement/component/FilterNullComponent.java | 97 +
.../plan/statement/component/FilterNullPolicy.java | 25 +
.../plan/statement/component/FromComponent.java | 42 +
.../statement/component/GroupByLevelComponent.java | 36 +
.../statement/component/GroupByTimeComponent.java | 101 +
.../db/mpp/plan/statement/component/OrderBy.java | 28 +
.../mpp/plan/statement/component/ResultColumn.java | 112 +
.../plan/statement/component/ResultSetFormat.java | 27 +
.../plan/statement/component/SelectComponent.java | 101 +
.../plan/statement/component/WhereCondition.java | 43 +
.../plan/statement/crud/InsertBaseStatement.java | 78 +
.../crud/InsertMultiTabletsStatement.java | 86 +
.../plan/statement/crud/InsertRowStatement.java | 128 +
.../crud/InsertRowsOfOneDeviceStatement.java | 90 +
.../plan/statement/crud/InsertRowsStatement.java | 86 +
.../mpp/plan/statement/crud/InsertStatement.java | 101 +
.../plan/statement/crud/InsertTabletStatement.java | 104 +
.../db/mpp/plan/statement/crud/QueryStatement.java | 289 +
.../mpp/plan/statement/literal/BooleanLiteral.java | 73 +
.../mpp/plan/statement/literal/DoubleLiteral.java | 70 +
.../db/mpp/plan/statement/literal/Literal.java | 59 +
.../db/mpp/plan/statement/literal/LongLiteral.java | 70 +
.../db/mpp/plan/statement/literal/NullLiteral.java | 54 +
.../mpp/plan/statement/literal/StringLiteral.java | 66 +
.../metadata/AlterTimeSeriesStatement.java | 127 +
.../statement/metadata/CountDevicesStatement.java | 34 +
.../metadata/CountLevelTimeSeriesStatement.java | 41 +
.../statement/metadata/CountNodesStatement.java | 31 +
.../plan/statement/metadata/CountStatement.java | 55 +
.../metadata/CountStorageGroupStatement.java | 42 +
.../metadata/CountTimeSeriesStatement.java | 34 +
.../metadata/CreateAlignedTimeSeriesStatement.java | 193 +
.../metadata/CreateTimeSeriesStatement.java | 132 +
.../statement/metadata/SchemaFetchStatement.java | 64 +
.../metadata/SetStorageGroupStatement.java | 64 +
.../plan/statement/metadata/SetTTLStatement.java | 73 +
.../statement/metadata/ShowDevicesStatement.java | 66 +
.../mpp/plan/statement/metadata/ShowStatement.java | 69 +
.../metadata/ShowStorageGroupStatement.java | 64 +
.../plan/statement/metadata/ShowTTLStatement.java | 60 +
.../metadata/ShowTimeSeriesStatement.java | 87 +
.../plan/statement/metadata/UnSetTTLStatement.java | 37 +
.../db/mpp/plan/statement/sys/AuthorStatement.java | 209 +
.../apache/iotdb/db/mqtt/BrokerAuthenticator.java | 47 -
.../apache/iotdb/db/mqtt/JSONPayloadFormatter.java | 84 -
.../java/org/apache/iotdb/db/mqtt/Message.java | 76 -
.../apache/iotdb/db/mqtt/PayloadFormatManager.java | 45 -
.../org/apache/iotdb/db/mqtt/PayloadFormatter.java | 40 -
.../org/apache/iotdb/db/mqtt/PublishHandler.java | 128 -
.../protocol/influxdb/constant/InfluxConstant.java | 28 +
.../influxdb/constant/InfluxSQLConstant.java | 64 +
.../iotdb/db/protocol/influxdb/dto/IoTDBPoint.java | 152 +
.../protocol/influxdb/function/InfluxFunction.java | 58 +
.../influxdb/function/InfluxFunctionFactory.java | 68 +
.../influxdb/function/InfluxFunctionValue.java | 46 +
.../function/aggregator/InfluxAggregator.java | 35 +
.../function/aggregator/InfluxCountFunction.java | 59 +
.../function/aggregator/InfluxMeanFunction.java | 72 +
.../function/aggregator/InfluxMedianFunction.java | 75 +
.../function/aggregator/InfluxModeFunction.java | 88 +
.../function/aggregator/InfluxSpreadFunction.java | 88 +
.../function/aggregator/InfluxStddevFunction.java | 68 +
.../function/aggregator/InfluxSumFunction.java | 68 +
.../function/selector/InfluxFirstFunction.java | 73 +
.../function/selector/InfluxLastFunction.java | 73 +
.../function/selector/InfluxMaxFunction.java | 102 +
.../function/selector/InfluxMinFunction.java | 102 +
.../influxdb/function/selector/InfluxSelector.java | 57 +
.../db/protocol/influxdb/handler/QueryHandler.java | 955 ++
.../protocol/influxdb/input/InfluxLineParser.java | 167 +
.../influxdb/meta/InfluxDBMetaManager.java | 225 +
.../db/protocol/influxdb/meta/TagInfoRecords.java | 97 +
.../influxdb/operator/InfluxQueryOperator.java | 38 +
.../influxdb/operator/InfluxSelectComponent.java | 98 +
.../influxdb/sql/InfluxDBLogicalGenerator.java | 66 +
.../protocol/influxdb/sql/InfluxDBSqlVisitor.java | 298 +
.../db/protocol/influxdb/util/CommonUtils.java | 40 +
.../db/protocol/influxdb/util/FieldUtils.java | 51 +
.../db/protocol/influxdb/util/FilterUtils.java | 83 +
.../db/protocol/influxdb/util/JacksonUtils.java | 44 +
.../protocol/influxdb/util/QueryResultUtils.java | 290 +
.../db/protocol/influxdb/util/StringUtils.java | 98 +
.../db/protocol/mqtt/BrokerAuthenticator.java | 47 +
.../db/protocol/mqtt/JSONPayloadFormatter.java | 105 +
.../org/apache/iotdb/db/protocol/mqtt/Message.java | 76 +
.../db/protocol/mqtt/PayloadFormatManager.java | 122 +
.../iotdb/db/protocol/mqtt/PayloadFormatter.java | 46 +
.../iotdb/db/protocol/mqtt/PublishHandler.java | 140 +
.../apache/iotdb/db/protocol/rest/RestService.java | 156 +
.../db/protocol/rest/filter/ApiOriginFilter.java | 45 +
.../protocol/rest/filter/AuthorizationFilter.java | 138 +
.../protocol/rest/filter/BasicSecurityContext.java | 56 +
.../apache/iotdb/db/protocol/rest/filter/User.java | 38 +
.../iotdb/db/protocol/rest/filter/UserCache.java | 56 +
.../rest/handler/AuthorizationHandler.java | 47 +
.../db/protocol/rest/handler/ExceptionHandler.java | 75 +
.../handler/PhysicalPlanConstructionHandler.java | 156 +
.../handler/PhysicalPlanValidationHandler.java | 79 +
.../protocol/rest/handler/QueryDataSetHandler.java | 332 +
.../rest/handler/RequestValidationHandler.java | 53 +
.../protocol/rest/impl/GrafanaApiServiceImpl.java | 225 +
.../db/protocol/rest/impl/PingApiServiceImpl.java | 51 +
.../db/protocol/rest/impl/RestApiServiceImpl.java | 169 +
.../main/java/org/apache/iotdb/db/qp/Planner.java | 236 +-
.../iotdb/db/qp/constant/FilterConstant.java | 114 +
.../apache/iotdb/db/qp/constant/SQLConstant.java | 158 +-
.../apache/iotdb/db/qp/executor/IPlanExecutor.java | 17 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 1444 +-
.../org/apache/iotdb/db/qp/logical/Operator.java | 171 +-
.../apache/iotdb/db/qp/logical/RootOperator.java | 30 -
.../qp/logical/crud/AggregationQueryOperator.java | 187 +
.../db/qp/logical/crud/BasicFunctionOperator.java | 56 +-
.../db/qp/logical/crud/BasicOperatorType.java | 28 +-
.../db/qp/logical/crud/DeleteDataOperator.java | 39 +-
.../db/qp/logical/crud/FillClauseComponent.java | 49 +
.../db/qp/logical/crud/FillQueryOperator.java | 92 +
.../iotdb/db/qp/logical/crud/FilterOperator.java | 90 +-
.../iotdb/db/qp/logical/crud/FromComponent.java | 41 +
.../iotdb/db/qp/logical/crud/FromOperator.java | 45 -
.../iotdb/db/qp/logical/crud/FunctionOperator.java | 10 +-
.../db/qp/logical/crud/GroupByClauseComponent.java | 92 +
.../logical/crud/GroupByFillClauseComponent.java | 49 +
.../qp/logical/crud/GroupByFillQueryOperator.java | 71 +
.../db/qp/logical/crud/GroupByQueryOperator.java | 102 +
.../iotdb/db/qp/logical/crud/InOperator.java | 34 +-
.../iotdb/db/qp/logical/crud/InsertOperator.java | 85 +-
.../db/qp/logical/crud/LastQueryOperator.java | 64 +
.../iotdb/db/qp/logical/crud/LikeOperator.java | 134 +
.../iotdb/db/qp/logical/crud/QueryOperator.java | 620 +-
.../iotdb/db/qp/logical/crud/RegexpOperator.java | 133 +
.../iotdb/db/qp/logical/crud/SFWOperator.java | 98 -
.../iotdb/db/qp/logical/crud/SelectComponent.java | 139 +
.../db/qp/logical/crud/SelectIntoOperator.java | 133 +
.../iotdb/db/qp/logical/crud/SelectOperator.java | 116 -
.../db/qp/logical/crud/SpecialClauseComponent.java | 162 +
.../db/qp/logical/crud/UDAFQueryOperator.java | 179 +
.../db/qp/logical/crud/UDTFQueryOperator.java | 48 +
.../iotdb/db/qp/logical/crud/WhereComponent.java | 40 +
.../qp/logical/sys/ActivateTemplateOperator.java | 51 +
.../db/qp/logical/sys/AlterTimeSeriesOperator.java | 16 +-
.../iotdb/db/qp/logical/sys/AuthorOperator.java | 22 +-
.../db/qp/logical/sys/ClearCacheOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/CountOperator.java | 29 +-
.../sys/CreateAlignedTimeSeriesOperator.java | 184 +
.../logical/sys/CreateContinuousQueryOperator.java | 108 +
.../db/qp/logical/sys/CreateFunctionOperator.java | 23 +-
.../db/qp/logical/sys/CreateIndexOperator.java | 27 +-
.../db/qp/logical/sys/CreatePipeOperator.java | 69 +
.../db/qp/logical/sys/CreatePipeSinkOperator.java | 61 +
.../db/qp/logical/sys/CreateSnapshotOperator.java | 30 -
.../db/qp/logical/sys/CreateTemplateOperator.java | 108 +
.../qp/logical/sys/CreateTimeSeriesOperator.java | 25 +-
.../db/qp/logical/sys/CreateTriggerOperator.java | 18 +-
.../iotdb/db/qp/logical/sys/DataAuthOperator.java | 12 +-
.../db/qp/logical/sys/DeletePartitionOperator.java | 16 +-
.../qp/logical/sys/DeleteStorageGroupOperator.java | 14 +-
.../qp/logical/sys/DeleteTimeSeriesOperator.java | 14 +-
.../logical/sys/DropContinuousQueryOperator.java | 50 +
.../db/qp/logical/sys/DropFunctionOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/DropIndexOperator.java | 28 +-
.../iotdb/db/qp/logical/sys/DropPipeOperator.java | 44 +
.../db/qp/logical/sys/DropPipeSinkOperator.java | 43 +
.../db/qp/logical/sys/DropTemplateOperator.java | 49 +
.../db/qp/logical/sys/DropTriggerOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/FlushOperator.java | 16 +-
.../iotdb/db/qp/logical/sys/KillQueryOperator.java | 14 +-
.../qp/logical/sys/LoadConfigurationOperator.java | 13 +-
.../iotdb/db/qp/logical/sys/LoadDataOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/LoadFilesOperator.java | 37 +-
.../iotdb/db/qp/logical/sys/MergeOperator.java | 19 +-
.../iotdb/db/qp/logical/sys/MoveFileOperator.java | 45 -
.../db/qp/logical/sys/RemoveFileOperator.java | 14 +-
.../db/qp/logical/sys/SetStorageGroupOperator.java | 14 +-
.../db/qp/logical/sys/SetSystemModeOperator.java | 53 +
.../iotdb/db/qp/logical/sys/SetTTLOperator.java | 16 +-
.../db/qp/logical/sys/SetTemplateOperator.java | 65 +
.../iotdb/db/qp/logical/sys/SettleOperator.java | 71 +
.../db/qp/logical/sys/ShowChildNodesOperator.java | 13 +-
.../db/qp/logical/sys/ShowChildPathsOperator.java | 13 +-
.../logical/sys/ShowContinuousQueriesOperator.java | 28 +
.../db/qp/logical/sys/ShowDevicesOperator.java | 12 +-
.../db/qp/logical/sys/ShowFunctionsOperator.java | 17 +-
.../db/qp/logical/sys/ShowLockInfoOperator.java | 36 +
.../db/qp/logical/sys/ShowMergeStatusOperator.java | 30 -
.../logical/sys/ShowNodesInTemplateOperator.java | 43 +
.../iotdb/db/qp/logical/sys/ShowOperator.java | 34 +-
.../logical/sys/ShowPathsSetTemplateOperator.java | 43 +
.../sys/ShowPathsUsingTemplateOperator.java | 43 +
.../iotdb/db/qp/logical/sys/ShowPipeOperator.java | 45 +
.../db/qp/logical/sys/ShowPipeServerOperator.java | 38 +
.../db/qp/logical/sys/ShowPipeSinkOperator.java | 45 +
.../qp/logical/sys/ShowPipeSinkTypeOperator.java | 38 +
.../qp/logical/sys/ShowQueryResourceOperate.java | 39 +
.../qp/logical/sys/ShowStorageGroupOperator.java | 13 +-
.../iotdb/db/qp/logical/sys/ShowTTLOperator.java | 10 +-
.../db/qp/logical/sys/ShowTemplatesOperator.java | 27 +
.../db/qp/logical/sys/ShowTimeSeriesOperator.java | 17 +-
.../db/qp/logical/sys/ShowTriggersOperator.java | 17 +-
.../iotdb/db/qp/logical/sys/StartPipeOperator.java | 44 +
.../db/qp/logical/sys/StartPipeServerOperator.java | 38 +
.../db/qp/logical/sys/StartTriggerOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/StopPipeOperator.java | 44 +
.../db/qp/logical/sys/StopPipeServerOperator.java | 38 +
.../db/qp/logical/sys/StopTriggerOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/TracingOperator.java | 14 +-
.../iotdb/db/qp/logical/sys/UnSetTTLOperator.java | 52 +
.../db/qp/logical/sys/UnloadFileOperator.java | 55 +
.../db/qp/logical/sys/UnsetTemplateOperator.java | 65 +
.../org/apache/iotdb/db/qp/physical/BatchPlan.java | 73 +
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 308 +-
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 151 +-
.../db/qp/physical/crud/AlignByDevicePlan.java | 243 +-
.../db/qp/physical/crud/DeletePartitionPlan.java | 4 +-
.../iotdb/db/qp/physical/crud/DeletePlan.java | 71 +-
.../iotdb/db/qp/physical/crud/FillQueryPlan.java | 18 +-
.../db/qp/physical/crud/GroupByTimeFillPlan.java | 75 +
.../iotdb/db/qp/physical/crud/GroupByTimePlan.java | 55 +-
.../db/qp/physical/crud/InsertMultiTabletPlan.java | 321 -
.../qp/physical/crud/InsertMultiTabletsPlan.java | 447 +
.../iotdb/db/qp/physical/crud/InsertPlan.java | 85 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 427 +-
.../physical/crud/InsertRowsOfOneDevicePlan.java | 189 +-
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 89 +-
.../db/qp/physical/crud/InsertTabletPlan.java | 612 +-
.../iotdb/db/qp/physical/crud/LastQueryPlan.java | 55 +-
.../iotdb/db/qp/physical/crud/MeasurementInfo.java | 62 +
.../iotdb/db/qp/physical/crud/QueryIndexPlan.java | 12 +
.../iotdb/db/qp/physical/crud/QueryPlan.java | 170 +-
.../db/qp/physical/crud/RawDataQueryPlan.java | 157 +-
.../iotdb/db/qp/physical/crud/SelectIntoPlan.java | 130 +
.../apache/iotdb/db/qp/physical/crud/UDAFPlan.java | 81 +
.../apache/iotdb/db/qp/physical/crud/UDFPlan.java | 9 +-
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 158 +-
.../db/qp/physical/sys/ActivateTemplatePlan.java | 83 +
.../db/qp/physical/sys/AlterTimeSeriesPlan.java | 8 +-
.../db/qp/physical/sys/AppendTemplatePlan.java | 218 +
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 16 +-
.../qp/physical/sys/AutoCreateDeviceMNodePlan.java | 83 +
.../iotdb/db/qp/physical/sys/ChangeAliasPlan.java | 10 +-
.../db/qp/physical/sys/ChangeTagOffsetPlan.java | 10 +-
.../iotdb/db/qp/physical/sys/ClearCachePlan.java | 21 +-
.../apache/iotdb/db/qp/physical/sys/CountPlan.java | 2 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 444 +
.../qp/physical/sys/CreateContinuousQueryPlan.java | 156 +
.../db/qp/physical/sys/CreateFunctionPlan.java | 45 +-
.../iotdb/db/qp/physical/sys/CreateIndexPlan.java | 10 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 70 +-
.../iotdb/db/qp/physical/sys/CreatePipePlan.java | 110 +
.../db/qp/physical/sys/CreatePipeSinkPlan.java | 98 +
.../db/qp/physical/sys/CreateSnapshotPlan.java | 39 -
.../db/qp/physical/sys/CreateTemplatePlan.java | 515 +
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 20 +-
.../db/qp/physical/sys/CreateTriggerPlan.java | 105 +-
.../iotdb/db/qp/physical/sys/DataAuthPlan.java | 8 +-
.../db/qp/physical/sys/DeleteStorageGroupPlan.java | 10 +-
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 41 +-
.../qp/physical/sys/DropContinuousQueryPlan.java | 63 +
.../iotdb/db/qp/physical/sys/DropFunctionPlan.java | 29 +-
.../iotdb/db/qp/physical/sys/DropIndexPlan.java | 10 +-
.../iotdb/db/qp/physical/sys/DropPipeSinkPlan.java | 45 +
.../iotdb/db/qp/physical/sys/DropTemplatePlan.java | 78 +
.../iotdb/db/qp/physical/sys/DropTriggerPlan.java | 62 +-
.../apache/iotdb/db/qp/physical/sys/FlushPlan.java | 12 +-
.../iotdb/db/qp/physical/sys/KillQueryPlan.java | 4 +-
.../db/qp/physical/sys/LoadConfigurationPlan.java | 8 +-
.../iotdb/db/qp/physical/sys/LoadDataPlan.java | 4 +-
.../apache/iotdb/db/qp/physical/sys/LogPlan.java | 75 +
.../apache/iotdb/db/qp/physical/sys/MNodePlan.java | 16 +-
.../db/qp/physical/sys/MeasurementMNodePlan.java | 17 +-
.../apache/iotdb/db/qp/physical/sys/MergePlan.java | 23 +-
.../iotdb/db/qp/physical/sys/OperateFilePlan.java | 31 +-
.../iotdb/db/qp/physical/sys/OperatePipePlan.java | 45 +
.../db/qp/physical/sys/PruneTemplatePlan.java | 107 +
.../db/qp/physical/sys/SetStorageGroupPlan.java | 10 +-
.../db/qp/physical/sys/SetSystemModePlan.java | 79 +
.../iotdb/db/qp/physical/sys/SetTTLPlan.java | 10 +-
.../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 107 +
.../iotdb/db/qp/physical/sys/SettlePlan.java | 65 +
.../db/qp/physical/sys/ShowChildNodesPlan.java | 2 +-
.../db/qp/physical/sys/ShowChildPathsPlan.java | 2 +-
.../qp/physical/sys/ShowContinuousQueriesPlan.java | 27 +
.../iotdb/db/qp/physical/sys/ShowDevicesPlan.java | 8 +-
.../db/qp/physical/sys/ShowFunctionsPlan.java | 9 +-
.../iotdb/db/qp/physical/sys/ShowLockInfoPlan.java | 36 +
.../db/qp/physical/sys/ShowMergeStatusPlan.java | 27 -
.../qp/physical/sys/ShowNodesInTemplatePlan.java | 34 +
.../qp/physical/sys/ShowPathsSetTemplatePlan.java | 34 +
.../physical/sys/ShowPathsUsingTemplatePlan.java | 34 +
.../iotdb/db/qp/physical/sys/ShowPipePlan.java | 33 +
.../db/qp/physical/sys/ShowPipeServerPlan.java | 26 +
.../iotdb/db/qp/physical/sys/ShowPipeSinkPlan.java | 33 +
.../db/qp/physical/sys/ShowPipeSinkTypePlan.java | 26 +
.../apache/iotdb/db/qp/physical/sys/ShowPlan.java | 29 +-
.../db/qp/physical/sys/ShowQueryResourcePlan.java | 38 +
.../db/qp/physical/sys/ShowStorageGroupPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/ShowTTLPlan.java | 2 +-
.../db/qp/physical/sys/ShowTemplatesPlan.java | 27 +
.../db/qp/physical/sys/ShowTimeSeriesPlan.java | 8 +-
.../iotdb/db/qp/physical/sys/ShowTriggersPlan.java | 10 +-
.../db/qp/physical/sys/StartPipeServerPlan.java | 56 +
.../iotdb/db/qp/physical/sys/StartTriggerPlan.java | 62 +-
.../db/qp/physical/sys/StopPipeServerPlan.java | 56 +
.../iotdb/db/qp/physical/sys/StopTriggerPlan.java | 62 +-
.../db/qp/physical/sys/StorageGroupMNodePlan.java | 8 +-
.../iotdb/db/qp/physical/sys/TracingPlan.java | 4 +-
.../db/qp/physical/sys/UnsetTemplatePlan.java | 109 +
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 3980 ++++--
.../iotdb/db/qp/strategy/LogicalChecker.java | 46 +
.../iotdb/db/qp/strategy/LogicalGenerator.java | 134 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 924 +-
.../qp/strategy/optimizer/ConcatPathOptimizer.java | 582 +-
.../qp/strategy/optimizer/DnfFilterOptimizer.java | 22 +-
.../qp/strategy/optimizer/ILogicalOptimizer.java | 3 +-
.../optimizer/MergeSingleFilterOptimizer.java | 6 +-
.../qp/strategy/optimizer/RemoveNotOptimizer.java | 28 +-
.../apache/iotdb/db/qp/utils/DatetimeUtils.java | 135 +-
.../iotdb/db/qp/utils/EmptyOutputStream.java | 35 +
.../iotdb/db/qp/utils/GroupByLevelController.java | 316 +
.../apache/iotdb/db/qp/utils/WildcardsRemover.java | 145 +
.../db/query/aggregation/AggregateResult.java | 86 +-
.../db/query/aggregation/AggregationType.java | 8 +-
.../aggregation/RemovableAggregateResult.java | 30 +
.../db/query/aggregation/impl/AvgAggrResult.java | 48 +-
.../db/query/aggregation/impl/CountAggrResult.java | 61 +-
.../query/aggregation/impl/ExtremeAggrResult.java | 175 +
.../aggregation/impl/FirstValueAggrResult.java | 42 +-
.../aggregation/impl/FirstValueDescAggrResult.java | 29 +-
.../aggregation/impl/LastValueAggrResult.java | 31 +-
.../aggregation/impl/LastValueDescAggrResult.java | 29 +-
.../query/aggregation/impl/MaxTimeAggrResult.java | 29 +-
.../aggregation/impl/MaxTimeDescAggrResult.java | 23 +-
.../query/aggregation/impl/MaxValueAggrResult.java | 35 +-
.../query/aggregation/impl/MinTimeAggrResult.java | 32 +-
.../aggregation/impl/MinTimeDescAggrResult.java | 21 +-
.../query/aggregation/impl/MinValueAggrResult.java | 33 +-
.../db/query/aggregation/impl/SumAggrResult.java | 116 +-
.../iotdb/db/query/context/QueryContext.java | 104 +-
.../iotdb/db/query/control/FileReaderManager.java | 131 +-
.../iotdb/db/query/control/QueryFileManager.java | 65 +-
.../db/query/control/QueryResourceManager.java | 230 +-
.../iotdb/db/query/control/QueryTimeManager.java | 151 +-
.../iotdb/db/query/control/SessionManager.java | 405 +
.../db/query/control/SessionTimeoutManager.java | 115 +
.../iotdb/db/query/control/TracingManager.java | 234 -
.../db/query/control/tracing/TracingConstant.java | 30 +
.../db/query/control/tracing/TracingInfo.java | 164 +
.../db/query/control/tracing/TracingManager.java | 88 +
.../db/query/dataset/AlignByDeviceDataSet.java | 168 +-
.../iotdb/db/query/dataset/IUDFInputDataSet.java | 42 +
.../apache/iotdb/db/query/dataset/ListDataSet.java | 2 +-
.../db/query/dataset/NonAlignEngineDataSet.java | 8 +-
.../dataset/RawQueryDataSetWithValueFilter.java | 76 +-
.../dataset/RawQueryDataSetWithoutValueFilter.java | 420 +-
.../query/dataset/ShowContinuousQueriesResult.java | 75 +
.../apache/iotdb/db/query/dataset/ShowDataSet.java | 14 +-
.../iotdb/db/query/dataset/ShowDevicesDataSet.java | 27 +-
.../iotdb/db/query/dataset/ShowDevicesResult.java | 31 +-
.../db/query/dataset/ShowTimeSeriesResult.java | 13 +
.../db/query/dataset/ShowTimeseriesDataSet.java | 22 +-
.../iotdb/db/query/dataset/SingleDataSet.java | 6 +-
.../iotdb/db/query/dataset/UDFInputDataSet.java | 42 +-
.../UDFRawQueryInputDataSetWithoutValueFilter.java | 67 +
.../db/query/dataset/UDTFAlignByTimeDataSet.java | 251 +-
.../apache/iotdb/db/query/dataset/UDTFDataSet.java | 128 +-
.../db/query/dataset/UDTFNonAlignDataSet.java | 26 +-
.../dataset/groupby/GroupByEngineDataSet.java | 181 -
.../db/query/dataset/groupby/GroupByExecutor.java | 40 -
.../query/dataset/groupby/GroupByFillDataSet.java | 422 +-
.../query/dataset/groupby/GroupByLevelDataSet.java | 98 +
.../query/dataset/groupby/GroupByTimeDataSet.java | 164 +-
.../dataset/groupby/GroupByTimeEngineDataSet.java | 93 +
.../groupby/GroupByWithValueFilterDataSet.java | 272 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 254 +-
.../dataset/groupby/LocalGroupByExecutor.java | 353 -
.../db/query/executor/AggregationExecutor.java | 582 +-
.../iotdb/db/query/executor/FillQueryExecutor.java | 254 +-
.../iotdb/db/query/executor/IQueryRouter.java | 6 +
.../iotdb/db/query/executor/LastQueryExecutor.java | 326 +-
.../iotdb/db/query/executor/QueryRouter.java | 244 +-
.../db/query/executor/RawDataQueryExecutor.java | 174 +-
.../iotdb/db/query/executor/UDFQueryExecutor.java | 112 +
.../iotdb/db/query/executor/UDTFQueryExecutor.java | 109 -
.../executor/fill/AlignedLastPointReader.java | 58 +
.../apache/iotdb/db/query/executor/fill/IFill.java | 95 +-
.../db/query/executor/fill/LastPointReader.java | 100 +-
.../iotdb/db/query/executor/fill/LinearFill.java | 91 +-
.../iotdb/db/query/executor/fill/PreviousFill.java | 50 +-
.../iotdb/db/query/executor/fill/ValueFill.java | 152 +
.../executor/groupby/AlignedGroupByExecutor.java | 37 +
.../db/query/executor/groupby/GroupByExecutor.java | 40 +
.../groupby/SlidingWindowGroupByExecutor.java | 66 +
.../SlidingWindowGroupByExecutorFactory.java | 117 +
.../EmptyQueueSlidingWindowGroupByExecutor.java | 51 +
.../groupby/impl/LocalAlignedGroupByExecutor.java | 365 +
.../groupby/impl/LocalGroupByExecutor.java | 366 +
...MonotonicQueueSlidingWindowGroupByExecutor.java | 73 +
.../NormalQueueSlidingWindowGroupByExecutor.java | 61 +
.../SmoothQueueSlidingWindowGroupByExecutor.java | 55 +
.../iotdb/db/query/expression/Expression.java | 360 +
.../iotdb/db/query/expression/ExpressionType.java | 69 +
.../iotdb/db/query/expression/ResultColumn.java | 207 +
.../expression/binary/AdditionExpression.java | 56 +
.../query/expression/binary/BinaryExpression.java | 285 +
.../expression/binary/DivisionExpression.java | 56 +
.../query/expression/binary/EqualToExpression.java | 55 +
.../expression/binary/GreaterEqualExpression.java | 56 +
.../expression/binary/GreaterThanExpression.java | 56 +
.../expression/binary/LessEqualExpression.java | 55 +
.../expression/binary/LessThanExpression.java | 55 +
.../expression/binary/LogicAndExpression.java | 55 +
.../query/expression/binary/LogicOrExpression.java | 55 +
.../query/expression/binary/ModuloExpression.java | 55 +
.../binary/MultiplicationExpression.java | 56 +
.../expression/binary/NonEqualExpression.java | 55 +
.../expression/binary/SubtractionExpression.java | 56 +
.../db/query/expression/leaf/ConstantOperand.java | 138 +
.../db/query/expression/leaf/LeafOperand.java | 42 +
.../query/expression/leaf/TimeSeriesOperand.java | 141 +
.../db/query/expression/leaf/TimestampOperand.java | 134 +
.../query/expression/multi/FunctionExpression.java | 437 +
.../db/query/expression/unary/InExpression.java | 99 +
.../db/query/expression/unary/LikeExpression.java | 143 +
.../query/expression/unary/LogicNotExpression.java | 66 +
.../query/expression/unary/NegationExpression.java | 67 +
.../query/expression/unary/RegularExpression.java | 90 +
.../db/query/expression/unary/UnaryExpression.java | 170 +
.../db/query/factory/AggregateResultFactory.java | 7 +
.../iotdb/db/query/pool/QueryTaskManager.java | 90 +
.../iotdb/db/query/pool/QueryTaskPoolManager.java | 78 -
.../db/query/pool/RawQueryReadTaskPoolManager.java | 123 +
.../db/query/reader/chunk/ChunkReaderWrap.java | 3 +-
.../query/reader/chunk/DiskAlignedChunkLoader.java | 67 +
.../db/query/reader/chunk/DiskChunkLoader.java | 21 +-
.../reader/chunk/DiskChunkReaderByTimestamp.java | 8 +-
.../query/reader/chunk/MemAlignedChunkLoader.java | 52 +
.../query/reader/chunk/MemAlignedChunkReader.java | 66 +
.../query/reader/chunk/MemAlignedPageReader.java | 161 +
.../db/query/reader/chunk/MemChunkLoader.java | 8 +-
.../db/query/reader/chunk/MemChunkReader.java | 3 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 136 +-
.../metadata/DiskAlignedChunkMetadataLoader.java | 109 +
.../chunk/metadata/DiskChunkMetadataLoader.java | 69 +-
.../metadata/MemAlignedChunkMetadataLoader.java | 89 +
.../chunk/metadata/MemChunkMetadataLoader.java | 36 +-
.../resource/CachedUnseqResourceMergeReader.java | 1 +
.../series/AlignedSeriesAggregateReader.java | 189 +
.../query/reader/series/AlignedSeriesReader.java | 109 +
.../db/query/reader/series/IAggregateReader.java | 2 +-
.../query/reader/series/SeriesAggregateReader.java | 34 +-
.../reader/series/SeriesRawDataBatchReader.java | 51 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 705 +-
.../reader/series/SeriesReaderByTimestamp.java | 46 +-
.../universal/AlignedDescPriorityMergeReader.java | 39 +
.../universal/AlignedPriorityMergeReader.java | 51 +
.../reader/universal/DescPriorityMergeReader.java | 10 +-
.../reader/universal/PriorityMergeReader.java | 35 +-
.../query/timegenerator/ServerTimeGenerator.java | 95 +-
.../apache/iotdb/db/query/udf/api/access/Row.java | 18 +-
.../iotdb/db/query/udf/api/access/RowWindow.java | 40 +
.../parameter/UDFParameterValidator.java | 2 +-
.../api/customizer/parameter/UDFParameters.java | 53 +-
.../UDFOutputSeriesDataTypeNotValidException.java | 30 +
.../db/query/udf/builtin/BuiltinFunction.java | 21 +-
.../apache/iotdb/db/query/udf/builtin/UDTFAbs.java | 2 +-
.../iotdb/db/query/udf/builtin/UDTFCast.java | 259 +
.../iotdb/db/query/udf/builtin/UDTFConst.java | 123 +
.../iotdb/db/query/udf/builtin/UDTFConstE.java | 43 +
.../iotdb/db/query/udf/builtin/UDTFConstPi.java | 43 +
.../query/udf/builtin/UDTFContinuouslySatisfy.java | 239 +
.../iotdb/db/query/udf/builtin/UDTFCosh.java | 28 +
.../iotdb/db/query/udf/builtin/UDTFDerivative.java | 2 +-
.../udf/builtin/UDTFEqualSizeBucketAggSample.java | 487 +
.../udf/builtin/UDTFEqualSizeBucketM4Sample.java | 238 +
.../builtin/UDTFEqualSizeBucketOutlierSample.java | 834 ++
.../builtin/UDTFEqualSizeBucketRandomSample.java | 68 +
.../udf/builtin/UDTFEqualSizeBucketSample.java | 48 +
.../iotdb/db/query/udf/builtin/UDTFInRange.java | 90 +
.../iotdb/db/query/udf/builtin/UDTFJexl.java | 359 +
.../iotdb/db/query/udf/builtin/UDTFMath.java | 2 +-
.../db/query/udf/builtin/UDTFNonZeroCount.java | 63 +
.../db/query/udf/builtin/UDTFNonZeroDuration.java | 63 +
.../iotdb/db/query/udf/builtin/UDTFOnOff.java | 86 +
.../iotdb/db/query/udf/builtin/UDTFSelectK.java | 4 +-
.../iotdb/db/query/udf/builtin/UDTFSinh.java | 28 +
.../iotdb/db/query/udf/builtin/UDTFTanh.java | 28 +
.../db/query/udf/builtin/UDTFValueDifference.java | 2 +-
.../iotdb/db/query/udf/builtin/UDTFValueTrend.java | 3 +-
.../iotdb/db/query/udf/builtin/UDTFZeroCount.java | 63 +
.../db/query/udf/builtin/UDTFZeroDuration.java | 63 +
...ializableRowRecordListBackedMultiColumnRow.java | 97 +
...izableRowRecordListBackedMultiColumnWindow.java | 104 +
...wRecordListBackedMultiColumnWindowIterator.java | 62 +
...ticSerializableTVListBackedSingleColumnRow.java | 99 +
...SerializableTVListBackedSingleColumnWindow.java | 99 +
...ableTVListBackedSingleColumnWindowIterator.java | 60 +
.../LayerPointReaderBackedSingleColumnRow.java | 91 +
.../iotdb/db/query/udf/core/access/RowImpl.java | 97 -
.../db/query/udf/core/access/RowIteratorImpl.java | 62 -
.../db/query/udf/core/access/RowWindowImpl.java | 80 -
.../db/query/udf/core/context/UDFContext.java | 142 -
.../db/query/udf/core/executor/UDTFContext.java | 67 +
.../db/query/udf/core/executor/UDTFExecutor.java | 44 +-
.../iotdb/db/query/udf/core/input/InputLayer.java | 571 -
.../iotdb/db/query/udf/core/input/SafetyLine.java | 77 -
.../udf/core/layer/ConstantIntermediateLayer.java | 66 +
.../iotdb/db/query/udf/core/layer/DAGBuilder.java | 113 +
.../query/udf/core/layer/EvaluationDAGBuilder.java | 100 +
.../db/query/udf/core/layer/InputRowUtils.java | 62 +
.../db/query/udf/core/layer/IntermediateLayer.java | 80 +
.../db/query/udf/core/layer/LayerCacheUtils.java | 107 +
.../query/udf/core/layer/LayerMemoryAssigner.java | 69 +
.../layer/MultiInputColumnIntermediateLayer.java | 383 +
.../query/udf/core/layer/RawQueryInputLayer.java | 302 +
.../iotdb/db/query/udf/core/layer/SafetyLine.java | 80 +
...InputColumnMultiReferenceIntermediateLayer.java | 374 +
...nputColumnSingleReferenceIntermediateLayer.java | 286 +
.../query/udf/core/layer/TsBlockInputDataSet.java | 64 +
.../udf/core/reader/ConstantLayerPointReader.java | 137 +
.../db/query/udf/core/reader/LayerPointReader.java | 4 +
.../db/query/udf/core/reader/LayerRowReader.java | 5 +-
.../core/transformer/RawQueryPointTransformer.java | 73 -
.../db/query/udf/core/transformer/Transformer.java | 8 +
.../core/transformer/UDFQueryRowTransformer.java | 46 -
.../transformer/UDFQueryRowWindowTransformer.java | 47 -
.../udf/core/transformer/UDFQueryTransformer.java | 102 -
.../binary/ArithmeticAdditionTransformer.java | 35 +
.../binary/ArithmeticBinaryTransformer.java | 49 +
.../binary/ArithmeticDivisionTransformer.java | 35 +
.../binary/ArithmeticModuloTransformer.java | 35 +
.../ArithmeticMultiplicationTransformer.java | 35 +
.../binary/ArithmeticSubtractionTransformer.java | 35 +
.../core/transformer/binary/BinaryTransformer.java | 125 +
.../binary/CompareBinaryTransformer.java | 49 +
.../binary/CompareEqualToTransformer.java | 56 +
.../binary/CompareGreaterEqualTransformer.java | 35 +
.../binary/CompareGreaterThanTransformer.java | 35 +
.../binary/CompareLessEqualTransformer.java | 35 +
.../binary/CompareLessThanTransformer.java | 35 +
.../binary/CompareNonEqualTransformer.java | 56 +
.../transformer/binary/LogicAndTransformer.java | 33 +
.../transformer/binary/LogicBinaryTransformer.java | 54 +
.../transformer/binary/LogicOrTransformer.java | 34 +
.../transformer/multi/UDFQueryRowTransformer.java | 49 +
.../multi/UDFQueryRowWindowTransformer.java | 47 +
.../transformer/multi/UDFQueryTransformer.java | 112 +
.../unary/ArithmeticNegationTransformer.java | 59 +
.../udf/core/transformer/unary/InTransformer.java | 233 +
.../transformer/unary/LogicNotTransformer.java | 48 +
.../core/transformer/unary/RegularTransformer.java | 58 +
.../transformer/unary/TransparentTransformer.java | 70 +
.../core/transformer/unary/UnaryTransformer.java | 62 +
.../query/udf/datastructure/SerializableList.java | 2 +-
.../primitive/ElasticSerializableIntList.java | 99 -
.../query/udf/datastructure/primitive/IntList.java | 33 -
.../primitive/SerializableIntList.java | 133 -
.../datastructure/primitive/WrappedIntArray.java | 51 -
.../row/ElasticSerializableRowRecordList.java | 85 +-
.../row/SerializableRowRecordList.java | 13 +-
.../tv/ElasticSerializableBinaryTVList.java | 8 +-
.../tv/ElasticSerializableTVList.java | 56 +-
.../datastructure/tv/SerializableBinaryTVList.java | 7 +-
.../tv/SerializableBooleanTVList.java | 7 +-
.../datastructure/tv/SerializableDoubleTVList.java | 7 +-
.../datastructure/tv/SerializableFloatTVList.java | 7 +-
.../datastructure/tv/SerializableIntTVList.java | 5 +-
.../datastructure/tv/SerializableLongTVList.java | 7 +-
.../udf/service/TemporaryQueryDataFileService.java | 8 +-
.../iotdb/db/query/udf/service/UDFClassLoader.java | 2 +-
.../query/udf/service/UDFClassLoaderManager.java | 8 +-
.../iotdb/db/query/udf/service/UDFLogWriter.java | 2 +-
.../udf/service/UDFRegistrationInformation.java | 13 +-
.../query/udf/service/UDFRegistrationService.java | 76 +-
.../iotdb/db/rescon/AbstractPoolManager.java | 102 +
.../apache/iotdb/db/rescon/CachedStringPool.java | 42 -
.../apache/iotdb/db/rescon/MemTableManager.java | 18 +-
.../iotdb/db/rescon/PrimitiveArrayManager.java | 361 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 248 +-
.../apache/iotdb/db/rescon/TVListAllocator.java | 94 -
.../iotdb/db/rescon/TVListAllocatorMBean.java | 24 -
.../iotdb/db/rescon/TsFileResourceManager.java | 126 +
.../java/org/apache/iotdb/db/service/DataNode.java | 365 +
.../org/apache/iotdb/db/service/DataNodeMBean.java | 21 +
.../db/service/DataNodeServerCommandLine.java | 84 +
.../java/org/apache/iotdb/db/service/IService.java | 49 -
.../iotdb/db/service/InfluxDBRPCService.java | 99 +
.../iotdb/db/service/InfluxDBRPCServiceMBean.java | 21 +
.../apache/iotdb/db/service/InternalService.java | 94 +
.../iotdb/db/service/InternalServiceMBean.java | 22 +
.../java/org/apache/iotdb/db/service/IoTDB.java | 174 +-
.../org/apache/iotdb/db/service/IoTDBMBean.java | 4 +-
.../apache/iotdb/db/service/IoTDBShutdownHook.java | 11 +
.../org/apache/iotdb/db/service/JMXService.java | 101 -
.../org/apache/iotdb/db/service/MQTTService.java | 6 +-
.../apache/iotdb/db/service/MetricsService.java | 207 -
.../iotdb/db/service/MetricsServiceMBean.java | 32 -
.../org/apache/iotdb/db/service/RPCService.java | 48 +-
.../apache/iotdb/db/service/RPCServiceMBean.java | 2 +-
.../iotdb/db/service/RPCServiceThriftHandler.java | 52 -
.../apache/iotdb/db/service/RegisterManager.java | 85 -
.../org/apache/iotdb/db/service/ServiceType.java | 74 -
.../org/apache/iotdb/db/service/SettleService.java | 192 +
.../org/apache/iotdb/db/service/StartupCheck.java | 28 -
.../org/apache/iotdb/db/service/StartupChecks.java | 78 -
.../org/apache/iotdb/db/service/StaticResps.java | 14 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 2006 ---
.../org/apache/iotdb/db/service/UpgradeSevice.java | 42 +-
.../db/service/basic/BasicOpenSessionResp.java | 34 +
.../db/service/basic/QueryFrequencyRecorder.java | 54 +
.../iotdb/db/service/basic/ServiceProvider.java | 101 +
.../service/basic/StandaloneServiceProvider.java | 55 +
.../apache/iotdb/db/service/metrics/Metric.java | 44 +
.../iotdb/db/service/metrics/MetricsService.java | 228 +
.../db/service/metrics/MetricsServiceMBean.java | 30 +
.../apache/iotdb/db/service/metrics/Operation.java | 39 +
.../org/apache/iotdb/db/service/metrics/Tag.java | 31 +
.../db/service/thrift/ProcessorWithMetrics.java | 77 +
.../iotdb/db/service/thrift/ThriftService.java | 163 -
.../db/service/thrift/ThriftServiceThread.java | 180 -
.../handler/InfluxDBServiceThriftHandler.java | 59 +
.../handler/InternalServiceThriftHandler.java | 44 +
.../thrift/handler/RPCServiceThriftHandler.java | 54 +
.../thrift/impl/DataNodeTSIServiceImpl.java | 896 ++
.../service/thrift/impl/InfluxDBServiceImpl.java | 177 +
.../service/thrift/impl/InternalServiceImpl.java | 243 +
.../db/service/thrift/impl/TSIEventHandler.java | 25 +
.../db/service/thrift/impl/TSServiceImpl.java | 2096 +++
.../apache/iotdb/db/sync/conf/SyncConstant.java | 86 +-
.../apache/iotdb/db/sync/conf/SyncPathUtil.java | 143 +
.../iotdb/db/sync/conf/SyncSenderConfig.java | 127 -
.../iotdb/db/sync/conf/SyncSenderDescriptor.java | 124 -
.../org/apache/iotdb/db/sync/package-info.java | 38 -
.../iotdb/db/sync/pipedata/DeletionPipeData.java | 85 +
.../apache/iotdb/db/sync/pipedata/PipeData.java | 96 +
.../iotdb/db/sync/pipedata/SchemaPipeData.java | 98 +
.../iotdb/db/sync/pipedata/TsFilePipeData.java | 177 +
.../sync/pipedata/queue/BufferedPipeDataQueue.java | 446 +
.../db/sync/pipedata/queue/PipeDataQueue.java | 39 +
.../sync/pipedata/queue/PipeDataQueueFactory.java | 57 +
.../iotdb/db/sync/receiver/ReceiverService.java | 300 +
.../iotdb/db/sync/receiver/SyncServerManager.java | 123 -
.../db/sync/receiver/SyncServerManagerMBean.java | 34 -
.../db/sync/receiver/SyncServerThriftHandler.java | 56 -
.../db/sync/receiver/collector/Collector.java | 171 +
.../db/sync/receiver/load/DeletionLoader.java | 48 +
.../iotdb/db/sync/receiver/load/FileLoader.java | 203 -
.../db/sync/receiver/load/FileLoaderManager.java | 213 -
.../iotdb/db/sync/receiver/load/IFileLoader.java | 50 -
.../iotdb/db/sync/receiver/load/ILoadLogger.java | 57 -
.../iotdb/db/sync/receiver/load/ILoader.java | 29 +
.../iotdb/db/sync/receiver/load/LoadLogger.java | 72 -
.../iotdb/db/sync/receiver/load/LoadType.java | 25 -
.../iotdb/db/sync/receiver/load/SchemaLoader.java | 73 +
.../iotdb/db/sync/receiver/load/TsFileLoader.java | 67 +
.../iotdb/db/sync/receiver/manager/PipeInfo.java | 85 +
.../db/sync/receiver/manager/PipeMessage.java | 76 +
.../db/sync/receiver/manager/ReceiverManager.java | 227 +
.../receiver/recover/ISyncReceiverLogAnalyzer.java | 33 -
.../sync/receiver/recover/ISyncReceiverLogger.java | 50 -
.../receiver/recover/SyncReceiverLogAnalyzer.java | 154 -
.../sync/receiver/recover/SyncReceiverLogger.java | 72 -
.../db/sync/receiver/recovery/ReceiverLog.java | 127 +
.../receiver/recovery/ReceiverLogAnalyzer.java | 153 +
.../db/sync/receiver/transfer/SyncServiceImpl.java | 357 -
.../db/sync/sender/manage/ISyncFileManager.java | 72 -
.../db/sync/sender/manage/SyncFileManager.java | 291 -
.../db/sync/sender/manager/SchemaSyncManager.java | 149 +
.../db/sync/sender/manager/TsFileSyncManager.java | 106 +
.../iotdb/db/sync/sender/pipe/IoTDBPipeSink.java | 113 +
.../org/apache/iotdb/db/sync/sender/pipe/Pipe.java | 116 +
.../apache/iotdb/db/sync/sender/pipe/PipeSink.java | 47 +
.../iotdb/db/sync/sender/pipe/TsFilePipe.java | 400 +
.../sender/recover/ISyncSenderLogAnalyzer.java | 47 -
.../db/sync/sender/recover/ISyncSenderLogger.java | 67 -
.../sync/sender/recover/SyncSenderLogAnalyzer.java | 128 -
.../db/sync/sender/recover/SyncSenderLogger.java | 72 -
.../db/sync/sender/recovery/SenderLogAnalyzer.java | 165 +
.../db/sync/sender/recovery/SenderLogger.java | 141 +
.../db/sync/sender/recovery/TsFilePipeLogger.java | 155 +
.../iotdb/db/sync/sender/service/MsgManager.java | 114 +
.../db/sync/sender/service/SenderService.java | 392 +
.../db/sync/sender/service/TransportHandler.java | 152 +
.../iotdb/db/sync/sender/transfer/ISyncClient.java | 95 -
.../iotdb/db/sync/sender/transfer/SyncClient.java | 752 --
.../db/sync/transport/client/ITransportClient.java | 28 +
.../db/sync/transport/client/TransportClient.java | 545 +
.../db/sync/transport/conf/TransportConfig.java | 45 +
.../db/sync/transport/conf/TransportConstant.java | 36 +
.../transport/server/TransportServerManager.java | 124 +
.../server/TransportServerManagerMBean.java | 34 +
.../server/TransportServerThriftHandler.java | 52 +
.../transport/server/TransportServiceImpl.java | 398 +
.../apache/iotdb/db/tools/IoTDBDataDirViewer.java | 6 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 2 +-
.../apache/iotdb/db/tools/TsFileRewriteTool.java | 301 +-
.../apache/iotdb/db/tools/TsFileSelfCheckTool.java | 190 +
.../apache/iotdb/db/tools/TsFileSketchTool.java | 579 +-
.../org/apache/iotdb/db/tools/TsFileSplitTool.java | 310 +
.../java/org/apache/iotdb/db/tools/WalChecker.java | 83 +-
.../db/tools/dataregion/DeviceMappingViewer.java | 63 +
.../org/apache/iotdb/db/tools/mlog/MLogParser.java | 207 -
.../apache/iotdb/db/tools/schema/MLogParser.java | 251 +
.../db/tools/schema/SchemaFileSketchTool.java | 165 +
.../db/tools/settle/TsFileAndModSettleTool.java | 363 +
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 237 +-
.../db/tools/virtualsg/DeviceMappingViewer.java | 63 -
.../iotdb/db/tools/vis/TsFileExtractVisdata.java | 170 +
.../main/java/org/apache/iotdb/db/tools/vis/vis.m | 290 +
.../db/tools/watermark/WatermarkDetector.java | 4 +-
.../iotdb/db/utils/AlignedValueIterator.java | 59 +
.../java/org/apache/iotdb/db/utils/AuthUtils.java | 321 -
.../org/apache/iotdb/db/utils/CommonUtils.java | 82 +-
.../org/apache/iotdb/db/utils/DataTypeUtils.java | 149 +
.../apache/iotdb/db/utils/ErrorHandlingUtils.java | 172 +
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 164 +-
.../org/apache/iotdb/db/utils/FilePathUtils.java | 259 -
.../java/org/apache/iotdb/db/utils/FileUtils.java | 24 +
.../iotdb/db/utils/IExpressionDeserializeUtil.java | 51 +
.../java/org/apache/iotdb/db/utils/IOUtils.java | 182 -
.../java/org/apache/iotdb/db/utils/MathUtils.java | 51 +
.../java/org/apache/iotdb/db/utils/MemUtils.java | 179 +-
.../java/org/apache/iotdb/db/utils/MergeUtils.java | 234 +-
.../org/apache/iotdb/db/utils/OpenFileNumUtil.java | 5 +-
.../org/apache/iotdb/db/utils/ParameterUtils.java | 35 +
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 343 +-
.../java/org/apache/iotdb/db/utils/QueryUtils.java | 130 +-
.../apache/iotdb/db/utils/RandomDeleteCache.java | 76 -
.../org/apache/iotdb/db/utils/SchemaUtils.java | 64 +-
.../org/apache/iotdb/db/utils/SerializeUtils.java | 561 -
.../org/apache/iotdb/db/utils/SerializedSize.java | 29 +
.../org/apache/iotdb/db/utils/StatusUtils.java | 46 -
.../java/org/apache/iotdb/db/utils/SyncUtils.java | 109 -
.../java/org/apache/iotdb/db/utils/TestOnly.java | 34 -
.../org/apache/iotdb/db/utils/ThreadUtils.java | 51 +
.../apache/iotdb/db/utils/TimeValuePairUtils.java | 232 +
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 30 +-
.../org/apache/iotdb/db/utils/UpgradeUtils.java | 13 +-
.../org/apache/iotdb/db/utils/ValueIterator.java | 56 +
.../db/utils/datastructure/AlignedTVList.java | 1179 ++
.../iotdb/db/utils/datastructure/BinaryTVList.java | 145 +-
.../db/utils/datastructure/BooleanTVList.java | 141 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 142 +-
.../datastructure/FixedPriorityBlockingQueue.java | 190 +
.../iotdb/db/utils/datastructure/FloatTVList.java | 142 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 141 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 145 +-
.../iotdb/db/utils/datastructure/TVList.java | 226 +-
.../iotdb/db/utils/datastructure/TimeSelector.java | 18 +
.../org/apache/iotdb/db/utils/stats/CpuTimer.java | 156 +
.../timerangeiterator/AggrWindowIterator.java | 165 +
.../timerangeiterator/ITimeRangeIterator.java | 39 +
.../timerangeiterator/PreAggrWindowIterator.java | 158 +
.../PreAggrWindowWithNaturalMonthIterator.java | 123 +
.../SingleTimeWindowIterator.java | 65 +
.../TimeRangeIteratorFactory.java | 69 +
.../iotdb/db/utils/windowing/api/Evaluator.java | 33 +
.../iotdb/db/utils/windowing/api/Window.java | 70 +
.../windowing/configuration/Configuration.java | 38 +
.../SlidingSizeWindowConfiguration.java | 61 +
.../SlidingTimeWindowConfiguration.java | 61 +
.../windowing/exception/WindowingException.java | 31 +
.../SlidingSizeWindowEvaluationHandler.java | 58 +
.../SlidingTimeWindowEvaluationHandler.java | 78 +
.../handler/SlidingWindowEvaluationHandler.java | 124 +
.../windowing/runtime/WindowEvaluationTask.java | 44 +
.../runtime/WindowEvaluationTaskPoolManager.java | 99 +
.../utils/windowing/window/EvictableBatchList.java | 173 +
.../db/utils/windowing/window/WindowImpl.java | 204 +
.../iotdb/db/utils/writelog/BatchLogReader.java | 83 +
.../apache/iotdb/db/utils/writelog/ILogReader.java | 50 +
.../apache/iotdb/db/utils/writelog/ILogWriter.java | 50 +
.../apache/iotdb/db/utils/writelog/LogWriter.java | 133 +
.../db/utils/writelog/MultiFileLogReader.java | 76 +
.../db/utils/writelog/SingleFileLogReader.java | 166 +
.../java/org/apache/iotdb/db/wal/WALManager.java | 251 +
.../iotdb/db/wal/buffer/AbstractWALBuffer.java | 71 +
.../org/apache/iotdb/db/wal/buffer/IWALBuffer.java | 40 +
.../iotdb/db/wal/buffer/IWALByteBufferView.java | 52 +
.../apache/iotdb/db/wal/buffer/SignalWALEntry.java | 51 +
.../org/apache/iotdb/db/wal/buffer/WALBuffer.java | 480 +
.../org/apache/iotdb/db/wal/buffer/WALEntry.java | 220 +
.../apache/iotdb/db/wal/buffer/WALEntryType.java | 55 +
.../apache/iotdb/db/wal/buffer/WALEntryValue.java | 30 +
.../apache/iotdb/db/wal/checkpoint/Checkpoint.java | 102 +
.../iotdb/db/wal/checkpoint/CheckpointManager.java | 285 +
.../iotdb/db/wal/checkpoint/CheckpointType.java | 49 +
.../iotdb/db/wal/checkpoint/MemTableInfo.java | 113 +
.../iotdb/db/wal/exception/WALException.java | 38 +
.../db/wal/exception/WALNodeClosedException.java | 25 +
.../db/wal/exception/WALRecoverException.java | 29 +
.../apache/iotdb/db/wal/io/CheckpointReader.java | 63 +
.../apache/iotdb/db/wal/io/CheckpointWriter.java | 61 +
.../org/apache/iotdb/db/wal/io/ILogWriter.java | 61 +
.../java/org/apache/iotdb/db/wal/io/LogWriter.java | 96 +
.../java/org/apache/iotdb/db/wal/io/WALReader.java | 114 +
.../java/org/apache/iotdb/db/wal/io/WALWriter.java | 60 +
.../org/apache/iotdb/db/wal/node/IWALNode.java | 52 +
.../org/apache/iotdb/db/wal/node/WALFakeNode.java | 118 +
.../java/org/apache/iotdb/db/wal/node/WALNode.java | 391 +
.../db/wal/recover/CheckpointRecoverUtils.java | 78 +
.../iotdb/db/wal/recover/WALNodeRecoverTask.java | 157 +
.../iotdb/db/wal/recover/WALRecoverManager.java | 175 +
.../file/AbstractTsFileRecoverPerformer.java | 126 +
.../recover/file/SealedTsFileRecoverPerformer.java | 54 +
.../db/wal/recover/file/TsFilePlanRedoer.java | 210 +
.../file/UnsealedTsFileRecoverPerformer.java | 276 +
.../org/apache/iotdb/db/wal/utils/WALMode.java | 35 +
.../apache/iotdb/db/wal/utils/WALWriteUtils.java | 193 +
.../wal/utils/listener/AbstractResultListener.java | 87 +
.../db/wal/utils/listener/WALFlushListener.java | 26 +
.../db/wal/utils/listener/WALRecoverListener.java | 35 +
.../apache/iotdb/db/writelog/WALFlushListener.java | 50 -
.../iotdb/db/writelog/io/BatchLogReader.java | 83 -
.../apache/iotdb/db/writelog/io/ILogReader.java | 50 -
.../apache/iotdb/db/writelog/io/ILogWriter.java | 50 -
.../org/apache/iotdb/db/writelog/io/LogWriter.java | 133 -
.../iotdb/db/writelog/io/MultiFileLogReader.java | 76 -
.../iotdb/db/writelog/io/SingleFileLogReader.java | 142 -
.../writelog/manager/MultiFileLogNodeManager.java | 165 -
.../db/writelog/manager/WriteLogNodeManager.java | 49 -
.../db/writelog/node/ExclusiveWriteLogNode.java | 377 -
.../iotdb/db/writelog/node/WriteLogNode.java | 86 -
.../iotdb/db/writelog/recover/LogReplayer.java | 206 -
.../writelog/recover/TsFileRecoverPerformer.java | 242 -
.../org.apache.iotdb.db.mqtt.PayloadFormatter | 20 -
....apache.iotdb.db.protocol.mqtt.PayloadFormatter | 20 +
.../src/main/resources/iotdb/ui/static/index.html | 79 -
.../main/resources/iotdb/ui/static/iotdb-logo.png | Bin 1187 -> 0 bytes
.../src/main/resources/iotdb/ui/static/webui.css | 194 -
.../apache/iotdb/db/auth/AuthorityCheckerTest.java | 55 +-
.../auth/authorizer/LocalFileAuthorizerTest.java | 18 +-
.../db/auth/authorizer/OpenIdAuthorizerTest.java | 8 +-
.../iotdb/db/auth/entity/PathPrivilegeTest.java | 2 +
.../org/apache/iotdb/db/auth/entity/RoleTest.java | 3 +
.../org/apache/iotdb/db/auth/entity/UserTest.java | 3 +
.../db/auth/role/LocalFileRoleAccessorTest.java | 5 +-
.../db/auth/role/LocalFileRoleManagerTest.java | 13 +-
.../db/auth/user/LocalFileUserAccessorTest.java | 5 +-
.../db/auth/user/LocalFileUserManagerTest.java | 33 +-
.../IoTDBDefaultThreadExceptionHandlerTest.java | 80 -
.../db/concurrent/IoTDBThreadPoolFactoryTest.java | 218 -
.../apache/iotdb/db/conf/IoTDBDescriptorTest.java | 2 +
.../db/conf/adapter/CompressionRatioTest.java | 3 +-
.../strategy/DirectoryStrategyTest.java | 24 +-
.../org/apache/iotdb/db/constant/TestConstant.java | 106 -
.../db/cost/statistic/PerformanceStatTest.java | 105 -
.../iotdb/db/engine/MetadataManagerHelper.java | 50 +-
.../db/engine/cache/BloomFilterCacheTest.java | 208 +
.../iotdb/db/engine/cache/ChunkCacheTest.java | 239 +
.../engine/compaction/AbstractCompactionTest.java | 296 +
.../db/engine/compaction/CompactionChunkTest.java | 244 -
.../engine/compaction/CompactionSchedulerTest.java | 1903 +++
.../compaction/CompactionTaskComparatorTest.java | 346 +
.../compaction/CompactionTaskManagerTest.java | 348 +
.../compaction/LevelCompactionCacheTest.java | 126 -
.../engine/compaction/LevelCompactionLogTest.java | 86 -
.../compaction/LevelCompactionMergeTest.java | 161 -
.../engine/compaction/LevelCompactionModsTest.java | 92 -
.../compaction/LevelCompactionMoreDataTest.java | 238 -
.../compaction/LevelCompactionRecoverTest.java | 703 -
.../compaction/LevelCompactionSelectorTest.java | 76 -
.../db/engine/compaction/LevelCompactionTest.java | 234 -
.../LevelCompactionTsFileManagementTest.java | 159 -
.../NoCompactionTsFileManagementTest.java | 164 -
.../ReadPointCompactionPerformerTest.java | 3826 ++++++
.../compaction/TestUtilsForAlignedSeries.java | 228 +
.../db/engine/compaction/TsFileIdentifierUT.java | 195 +
.../cross/CrossSpaceCompactionExceptionTest.java | 526 +
.../compaction/cross/CrossSpaceCompactionTest.java | 1074 ++
.../db/engine/compaction/cross/MergeTest.java | 203 +
.../engine/compaction/cross/MergeUpgradeTest.java | 193 +
.../cross/RewriteCompactionFileSelectorTest.java | 922 ++
.../RewriteCrossSpaceCompactionRecoverTest.java | 633 +
.../cross/RewriteCrossSpaceCompactionTest.java | 803 ++
.../inner/AbstractInnerSpaceCompactionTest.java | 275 +
.../inner/InnerCompactionEmptyTsFileTest.java | 89 +
.../compaction/inner/InnerCompactionLogTest.java | 84 +
.../inner/InnerCompactionMoreDataTest.java | 242 +
.../inner/InnerCompactionSchedulerTest.java | 166 +
.../compaction/inner/InnerCompactionTest.java | 214 +
.../compaction/inner/InnerSeqCompactionTest.java | 959 ++
.../inner/InnerSpaceCompactionExceptionTest.java | 449 +
.../compaction/inner/InnerUnseqCompactionTest.java | 793 ++
.../ReadChunkCompactionPerformerAlignedTest.java | 534 +
.../ReadChunkCompactionPerformerNoAlignedTest.java | 918 ++
.../inner/ReadChunkCompactionPerformerOldTest.java | 133 +
.../SizeTieredCompactionRecoverTest.java | 1231 ++
.../inner/sizetiered/SizeTieredCompactionTest.java | 291 +
...eCrossSpaceCompactionRecoverCompatibleTest.java | 405 +
.../SizeTieredCompactionRecoverCompatibleTest.java | 265 +
.../recover/SizeTieredCompactionRecoverTest.java | 795 ++
.../compaction/utils/CompactionCheckerUtils.java | 564 +
.../compaction/utils/CompactionClearUtils.java | 91 +
.../compaction/utils/CompactionConfigRestorer.java | 70 +
.../utils/CompactionFileGeneratorUtils.java | 313 +
.../compaction/utils/CompactionOverlapType.java | 27 +
.../compaction/utils/CompactionTimeseriesType.java | 26 +
.../db/engine/memtable/MemTableFlushTaskTest.java | 60 +-
.../db/engine/memtable/MemTableTestUtils.java | 88 +-
.../db/engine/memtable/MemtableBenchmark.java | 15 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 390 +-
.../engine/merge/MaxFileMergeFileSelectorTest.java | 239 -
.../merge/MaxSeriesMergeFileSelectorTest.java | 108 -
.../apache/iotdb/db/engine/merge/MergeLogTest.java | 92 -
.../iotdb/db/engine/merge/MergeManagerTest.java | 176 -
.../iotdb/db/engine/merge/MergeOverLapTest.java | 226 -
.../iotdb/db/engine/merge/MergePerfTest.java | 108 -
.../iotdb/db/engine/merge/MergeTaskTest.java | 503 -
.../apache/iotdb/db/engine/merge/MergeTest.java | 232 -
.../iotdb/db/engine/merge/MergeUpgradeTest.java | 190 -
.../engine/modification/DeletionFileNodeTest.java | 184 +-
.../db/engine/modification/DeletionQueryTest.java | 206 +-
.../engine/modification/ModificationFileTest.java | 2 +-
.../io/LocalTextModificationAccessorTest.java | 51 +-
.../db/engine/storagegroup/DataRegionTest.java | 922 ++
.../engine/storagegroup/FakedTsFileResource.java | 72 +
.../storagegroup/FileNodeManagerBenchmark.java | 15 +-
.../storagegroup/StorageGroupProcessorTest.java | 380 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 160 +-
.../db/engine/storagegroup/TsFileManagerTest.java | 240 +
.../engine/storagegroup/TsFileProcessorTest.java | 258 +-
.../engine/storagegroup/TsFileProcessorV2Test.java | 482 +
.../storagegroup/TsFileResourceListTest.java | 215 +
.../dataregion/HashVirtualPartitionerTest.java | 63 +
.../virtualSg/HashVirtualPartitionerTest.java | 63 -
.../iotdb/db/integration/IOTDBGroupByIT.java | 948 --
.../integration/IOTDBGroupByInnerIntervalIT.java | 341 -
.../apache/iotdb/db/integration/IOTDBInsertIT.java | 126 -
.../iotdb/db/integration/IoTDBAddSubDeviceIT.java | 248 -
.../apache/iotdb/db/integration/IoTDBAliasIT.java | 338 -
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 1277 --
.../org/apache/iotdb/db/integration/IoTDBAsIT.java | 608 -
.../db/integration/IoTDBAutoCreateSchemaIT.java | 250 -
.../iotdb/db/integration/IoTDBBigDateTimeIT.java | 61 -
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 161 -
.../iotdb/db/integration/IoTDBClearCacheIT.java | 174 -
.../apache/iotdb/db/integration/IoTDBCloseIT.java | 197 -
.../iotdb/db/integration/IoTDBCompleteIT.java | 487 -
.../iotdb/db/integration/IoTDBCompressTypeIT.java | 109 -
.../db/integration/IoTDBCreateSnapshotIT.java | 187 -
.../db/integration/IoTDBCreateTimeseriesIT.java | 157 -
.../apache/iotdb/db/integration/IoTDBDaemonIT.java | 470 -
.../db/integration/IoTDBDeleteStorageGroupIT.java | 169 -
.../db/integration/IoTDBDeleteTimeseriesIT.java | 179 -
.../iotdb/db/integration/IoTDBDeletionIT.java | 427 -
.../iotdb/db/integration/IoTDBDisableAlignIT.java | 419 -
.../iotdb/db/integration/IoTDBEncodingIT.java | 291 -
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 283 -
.../iotdb/db/integration/IoTDBExecuteBatchIT.java | 197 -
.../iotdb/db/integration/IoTDBFilePathUtilsIT.java | 110 -
.../apache/iotdb/db/integration/IoTDBFillIT.java | 882 --
.../db/integration/IoTDBFloatPrecisionIT.java | 174 -
.../db/integration/IoTDBFlushQueryMergeIT.java | 214 -
.../iotdb/db/integration/IoTDBGroupByFillIT.java | 828 --
.../integration/IoTDBGroupByFillWithRangeIT.java | 182 -
.../iotdb/db/integration/IoTDBGroupByMonthIT.java | 180 -
.../iotdb/db/integration/IoTDBInsertNaNIT.java | 203 -
.../db/integration/IoTDBInsertWithQueryIT.java | 532 -
.../iotdb/db/integration/IoTDBKillQueryIT.java | 81 -
.../iotdb/db/integration/IoTDBLargeDataIT.java | 395 -
.../apache/iotdb/db/integration/IoTDBLastIT.java | 559 -
.../db/integration/IoTDBLevelCompactionIT.java | 1200 --
.../iotdb/db/integration/IoTDBLimitSlimitIT.java | 208 -
.../db/integration/IoTDBLoadExternalTsfileIT.java | 706 -
...IoTDBLoadExternalTsfileWithTimePartitionIT.java | 192 -
.../apache/iotdb/db/integration/IoTDBMergeIT.java | 386 -
.../iotdb/db/integration/IoTDBMetadataFetchIT.java | 639 -
.../iotdb/db/integration/IoTDBMultiDeviceIT.java | 308 -
.../IoTDBMultiOverlappedChunkInUnseqIT.java | 120 -
.../db/integration/IoTDBMultiOverlappedPageIT.java | 180 -
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 512 -
.../db/integration/IoTDBMultiStatementsIT.java | 202 -
.../db/integration/IoTDBNewTsFileCompactionIT.java | 1057 --
.../iotdb/db/integration/IoTDBNumberPathIT.java | 484 -
.../db/integration/IoTDBOverlappedPageIT.java | 158 -
.../iotdb/db/integration/IoTDBQueryDemoIT.java | 486 -
.../db/integration/IoTDBQueryMemoryControlIT.java | 299 -
.../iotdb/db/integration/IoTDBQueryTimeoutIT.java | 151 -
.../iotdb/db/integration/IoTDBQuotedPathIT.java | 149 -
.../iotdb/db/integration/IoTDBRecoverIT.java | 435 -
.../db/integration/IoTDBRecoverUnclosedIT.java | 288 -
.../db/integration/IoTDBRemovePartitionIT.java | 330 -
.../iotdb/db/integration/IoTDBRestartIT.java | 408 -
.../iotdb/db/integration/IoTDBResultSetIT.java | 126 -
.../db/integration/IoTDBRpcCompressionIT.java | 151 -
.../IoTDBSameMeasurementsDifferentTypesIT.java | 187 -
.../iotdb/db/integration/IoTDBSensorUpdateIT.java | 85 -
.../db/integration/IoTDBSequenceDataQueryIT.java | 319 -
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 490 -
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 1243 --
.../integration/IoTDBSortedShowTimeseriesIT.java | 335 -
.../iotdb/db/integration/IoTDBTagAlterIT.java | 640 -
.../apache/iotdb/db/integration/IoTDBTagIT.java | 1161 --
.../iotdb/db/integration/IoTDBTimeZoneIT.java | 163 -
.../iotdb/db/integration/IoTDBTracingIT.java | 70 -
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 213 -
.../iotdb/db/integration/IoTDBUDFManagementIT.java | 460 -
.../db/integration/IoTDBUDFWindowQueryIT.java | 557 -
.../integration/IoTDBUDTFAlignByTimeQueryIT.java | 830 --
.../db/integration/IoTDBUDTFBuiltinFunctionIT.java | 285 -
.../db/integration/IoTDBUDTFHybridQueryIT.java | 181 -
.../db/integration/IoTDBUDTFNonAlignQueryIT.java | 368 -
.../iotdb/db/integration/IoTDBVersionIT.java | 70 -
.../aggregation/IoTDBAggregationByLevelIT.java | 339 -
.../aggregation/IoTDBAggregationDeleteIT.java | 91 -
.../aggregation/IoTDBAggregationIT.java | 1029 --
.../aggregation/IoTDBAggregationLargeDataIT.java | 991 --
.../aggregation/IoTDBAggregationSmallDataIT.java | 774 --
.../db/integration/auth/IoTDBAuthorizationIT.java | 1010 --
.../iotdb/db/metadata/MManagerAdvancedTest.java | 230 -
.../iotdb/db/metadata/MManagerBasicTest.java | 739 --
.../iotdb/db/metadata/MManagerImproveTest.java | 187 -
.../org/apache/iotdb/db/metadata/MTreeTest.java | 870 --
.../apache/iotdb/db/metadata/MetaUtilsTest.java | 129 +-
.../apache/iotdb/db/metadata/PartialPathTest.java | 57 +-
.../iotdb/db/metadata/SchemaAdvancedTest.java | 228 +
.../apache/iotdb/db/metadata/SchemaBasicTest.java | 2703 ++++
.../iotdb/db/metadata/SchemaImproveTest.java | 188 +
.../org/apache/iotdb/db/metadata/TemplateTest.java | 492 +
.../db/metadata/cache/DataNodeSchemaCacheTest.java | 152 +
.../db/metadata/idtable/IDTableFlushTimeTest.java | 226 +
.../db/metadata/idtable/IDTableLogFileTest.java | 160 +
.../db/metadata/idtable/IDTableRecoverTest.java | 211 +
.../idtable/IDTableResourceControlTest.java | 167 +
.../db/metadata/idtable/IDTableRestartTest.java | 205 +
.../iotdb/db/metadata/idtable/IDTableTest.java | 663 +
.../db/metadata/idtable/InsertWithIDTableTest.java | 759 ++
.../db/metadata/idtable/LastQueryWithIDTable.java | 180 +
.../QueryAlignedTimeseriesWithIDTableTest.java | 373 +
.../db/metadata/idtable/QueryWithIDTableTest.java | 375 +
.../db/metadata/idtable/entry/DeviceIDTest.java | 45 +
.../db/metadata/idtable/entry/SchemaEntryTest.java | 68 +
.../metadata/idtable/trigger_example/Counter.java | 96 +
.../apache/iotdb/db/metadata/mnode/MNodeTest.java | 64 +-
.../iotdb/db/metadata/mtree/MTreeAboveSGTest.java | 339 +
.../iotdb/db/metadata/mtree/MTreeBelowSGTest.java | 838 ++
.../mtree/disk/CachedMNodeContainerTest.java | 51 +
.../db/metadata/mtree/disk/MemManagerTest.java | 112 +
.../mtree/multimode/MTreeDiskModeTest.java | 42 +
.../mtree/multimode/MTreeFullMemoryTest.java | 28 +
.../mtree/multimode/MTreeMemoryModeTest.java | 35 +
.../mtree/multimode/MTreeNonMemoryTest.java | 28 +
.../mtree/multimode/MTreePartialMemoryTest.java | 28 +
.../metadata/mtree/schemafile/RecordUtilTests.java | 78 +
.../metadata/mtree/schemafile/SchemaFileTest.java | 790 ++
.../metadata/mtree/schemafile/SchemaPageTest.java | 131 +
.../db/metadata/mtree/schemafile/SegmentTest.java | 151 +
.../db/metadata/multimode/SchemaDiskModeTest.java | 42 +
.../metadata/multimode/SchemaFullMemoryTest.java | 29 +
.../metadata/multimode/SchemaMemoryModeTest.java | 35 +
.../db/metadata/multimode/SchemaNonMemoryTest.java | 29 +
.../multimode/SchemaPartialMemoryTest.java | 28 +
.../db/metadata/upgrade/MetadataUpgradeTest.java | 313 +
.../iotdb/db/monitor/IoTDBStatMonitorTest.java | 177 -
.../iotdb/db/mpp/aggregation/AccumulatorTest.java | 349 +
.../mpp/common/schematree/PathPatternTreeTest.java | 193 +
.../db/mpp/common/schematree/SchemaTreeTest.java | 539 +
.../db/mpp/execution/ConfigExecutionTest.java | 172 +
.../iotdb/db/mpp/execution/DataDriverTest.java | 238 +
.../db/mpp/execution/QueryStateMachineTest.java | 143 +
.../datatransfer/DataBlockManagerTest.java | 121 +
.../datatransfer/LocalSinkHandleTest.java | 153 +
.../datatransfer/LocalSourceHandleTest.java | 119 +
.../datatransfer/SharedTsBlockQueueTest.java | 160 +
.../mpp/execution/datatransfer/SinkHandleTest.java | 528 +
.../execution/datatransfer/SourceHandleTest.java | 642 +
.../mpp/execution/datatransfer/StubSinkHandle.java | 99 +
.../iotdb/db/mpp/execution/datatransfer/Utils.java | 112 +
.../db/mpp/execution/memory/MemoryPoolTest.java | 275 +
.../operator/AlignedSeriesScanOperatorTest.java | 748 ++
.../execution/operator/AlignedSeriesTestUtil.java | 260 +
.../operator/DeviceMergeOperatorTest.java | 547 +
.../execution/operator/DeviceViewOperatorTest.java | 198 +
.../mpp/execution/operator/LimitOperatorTest.java | 188 +
.../execution/operator/MultiColumnMergerTest.java | 208 +
.../NonOverlappedMultiColumnMergerTest.java | 230 +
.../mpp/execution/operator/OffsetOperatorTest.java | 391 +
.../operator/SeriesAggregateScanOperatorTest.java | 485 +
.../execution/operator/SeriesScanOperatorTest.java | 135 +
.../execution/operator/SingleColumnMergerTest.java | 210 +
.../execution/operator/TimeJoinOperatorTest.java | 414 +
.../operator/schema/CountMergeOperatorTest.java | 193 +
.../operator/schema/SchemaCountOperatorTest.java | 231 +
.../schema/SchemaFetchScanOperatorTest.java | 149 +
.../schema/SchemaQueryScanOperatorTest.java | 253 +
.../schedule/DefaultTaskSchedulerTest.java | 399 +
.../execution/schedule/DriverSchedulerTest.java | 164 +
.../DriverTaskTimeoutSentinelThreadTest.java | 269 +
.../schedule/queue/L1PriorityQueueTest.java | 182 +
.../schedule/queue/L2PriorityQueueTest.java | 196 +
.../mpp/execution/schedule/queue/QueueElement.java | 80 +
.../iotdb/db/mpp/plan/analyze/AnalyzeFailTest.java | 63 +
.../iotdb/db/mpp/plan/analyze/AnalyzeTest.java | 55 +
.../iotdb/db/mpp/plan/parser/ASTVisitorTest.java | 41 +
.../db/mpp/plan/parser/StatementGeneratorTest.java | 76 +
.../db/mpp/plan/plan/DistributionPlannerTest.java | 523 +
.../db/mpp/plan/plan/FragmentInstanceIdTest.java | 38 +
.../mpp/plan/plan/FragmentInstanceSerdeTest.java | 164 +
.../iotdb/db/mpp/plan/plan/LogicalPlannerTest.java | 473 +
.../db/mpp/plan/plan/QueryLogicalPlanUtil.java | 769 ++
.../iotdb/db/mpp/plan/plan/QueryPlannerTest.java | 96 +
.../plan/plan/node/PlanNodeDeserializeHelper.java | 37 +
.../read/DeviceSchemaScanNodeSerdeTest.java | 76 +
.../metadata/read/SchemaCountNodeSerdeTest.java | 92 +
.../metadata/read/SchemaFetchScanNodeTest.java | 51 +
.../read/TimeSeriesSchemaScanNodeSerdeTest.java | 79 +
.../node/process/AggregationNodeSerdeTest.java | 89 +
.../plan/node/process/DeviceViewNodeSerdeTest.java | 55 +
.../plan/node/process/ExchangeNodeSerdeTest.java | 64 +
.../plan/plan/node/process/FillNodeSerdeTest.java | 54 +
.../plan/node/process/FilterNodeSerdeTest.java | 63 +
.../plan/node/process/FilterNullNodeSerdeTest.java | 58 +
.../node/process/GroupByLevelNodeSerdeTest.java | 106 +
.../plan/plan/node/process/LimitNodeSerdeTest.java | 67 +
.../plan/node/process/OffsetNodeSerdeTest.java | 65 +
.../plan/plan/node/process/SortNodeSerdeTest.java | 66 +
.../plan/node/process/TimeJoinNodeSerdeTest.java | 81 +
.../plan/node/sink/FragmentSinkNodeSerdeTest.java | 56 +
.../source/SeriesAggregationScanNodeSerdeTest.java | 79 +
.../plan/node/source/SeriesScanNodeSerdeTest.java | 64 +
.../write/InsertMultiTabletsNodeSerdeTest.java | 95 +
.../plan/node/write/InsertRowNodeSerdeTest.java | 195 +
.../plan/node/write/InsertRowsNodeSerdeTest.java | 72 +
.../write/InsertRowsOfOneDeviceNodeSerdeTest.java | 81 +
.../plan/node/write/InsertTabletNodeSerdeTest.java | 170 +
.../plan/node/write/WritePlanNodeSplitTest.java | 278 +
.../iotdb/db/mqtt/BrokerAuthenticatorTest.java | 52 -
.../iotdb/db/mqtt/JSONPayloadFormatTest.java | 71 -
.../iotdb/db/mqtt/PayloadFormatManagerTest.java | 35 -
.../apache/iotdb/db/mqtt/PublishHandlerTest.java | 62 -
.../db/protocol/influxdb/dto/IoTDBPointTest.java | 57 +
.../influxdb/input/InfluxLineParserTest.java | 56 +
.../influxdb/sql/InfluxDBLogicalGeneratorTest.java | 70 +
.../db/protocol/mqtt/BrokerAuthenticatorTest.java | 52 +
.../db/protocol/mqtt/JSONPayloadFormatterTest.java | 71 +
.../db/protocol/mqtt/PayloadFormatManagerTest.java | 42 +
.../iotdb/db/protocol/mqtt/PublishHandlerTest.java | 126 +
.../db/protocol/rest/GrafanaApiServiceIT.java | 359 +
.../iotdb/db/protocol/rest/IoTDBRestServiceIT.java | 895 ++
.../java/org/apache/iotdb/db/qp/PlannerTest.java | 92 +-
.../iotdb/db/qp/logical/IndexLogicalPlanTest.java | 156 -
.../iotdb/db/qp/logical/LogicalPlanSmallTest.java | 199 +-
.../iotdb/db/qp/other/TSPlanContextAuthorTest.java | 10 +-
.../iotdb/db/qp/physical/ConcatOptimizerTest.java | 22 +-
.../physical/IndexSubMatchingPhysicalPlanTest.java | 163 -
.../IndexWholeMatchingPhysicalPlanTest.java | 168 -
.../iotdb/db/qp/physical/InsertRowPlanTest.java | 395 +
.../qp/physical/InsertRowsOfOneDevicePlanTest.java | 75 +
.../db/qp/physical/InsertTabletMultiPlanTest.java | 209 +-
.../iotdb/db/qp/physical/InsertTabletPlanTest.java | 344 +-
.../db/qp/physical/PhysicalPlanSerializeTest.java | 52 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 587 +-
.../iotdb/db/qp/physical/SerializationTest.java | 20 +-
.../iotdb/db/qp/physical/SerializedSizeTest.java | 130 +
.../org/apache/iotdb/db/qp/sql/ASTVisitorTest.java | 43 +
.../iotdb/db/qp/sql/IoTDBsqlVisitorTest.java | 14 +-
.../db/qp/utils/DatetimeQueryDataSetUtilsTest.java | 121 +-
.../db/query/aggregation/AggregateResultTest.java | 25 +
.../query/aggregation/DescAggregateResultTest.java | 63 +
.../db/query/control/FileReaderManagerTest.java | 21 +-
.../iotdb/db/query/control/TracingManagerTest.java | 114 -
.../dataset/EngineDataSetWithValueFilterTest.java | 7 +-
.../iotdb/db/query/dataset/ListDataSetTest.java | 25 +-
.../db/query/dataset/ShowDevicesResultTest.java | 3 +-
.../db/query/dataset/ShowTimeSeriesResultTest.java | 2 +
.../iotdb/db/query/dataset/SingleDataSetTest.java | 6 +-
.../query/dataset/UDTFAlignByTimeDataSetTest.java | 44 +-
.../query/dataset/groupby/GroupByDataSetTest.java | 226 +
.../dataset/groupby/GroupByEngineDataSetTest.java | 504 -
.../dataset/groupby/GroupByFillDataSetTest.java | 6 +-
.../dataset/groupby/GroupByLevelDataSetTest.java | 20 +-
.../dataset/groupby/GroupByTimeDataSetTest.java | 635 +-
.../reader/series/SeriesAggregateReaderTest.java | 43 +-
.../reader/series/SeriesReaderByTimestampTest.java | 31 +-
.../db/query/reader/series/SeriesReaderTest.java | 17 +-
.../query/reader/series/SeriesReaderTestUtil.java | 98 +-
.../universal/AlignedPriorityMergeReaderTest.java | 91 +
.../ElasticSerializableRowRecordListTest.java | 127 +-
.../ElasticSerializableTVListTest.java | 177 +-
.../SerializableBinaryTVListTest.java | 3 +-
.../datastructure/SerializableFloatTVListTest.java | 3 +-
.../datastructure/SerializableIntTVListTest.java | 3 +-
.../datastructure/SerializableLongTVListTest.java | 3 +-
.../iotdb/db/query/udf/example/Accumulator.java | 95 -
.../apache/iotdb/db/query/udf/example/Adder.java | 4 +-
.../apache/iotdb/db/query/udf/example/Counter.java | 83 -
.../org/apache/iotdb/db/query/udf/example/Max.java | 76 -
.../SlidingTimeWindowConstructionTester.java | 74 -
.../valuefilter/RawQueryWithValueFilterTest.java | 147 +
.../iotdb/db/rescon/ResourceManagerTest.java | 400 +
.../org/apache/iotdb/db/script/EnvScriptIT.java | 6 +-
.../security/encrypt/MessageDigestEncryptTest.java | 95 +
.../iotdb/db/service/InternalServiceImplTest.java | 280 +
.../org/apache/iotdb/db/sink/AlertManagerTest.java | 328 +
.../apache/iotdb/db/sink/LocalIoTDBSinkTest.java | 218 +
.../org/apache/iotdb/db/sink/MQTTSinkTest.java | 210 +
.../sync/pipedata/BufferedPipeDataQueueTest.java | 543 +
.../iotdb/db/sync/pipedata/PipeDataTest.java | 91 +
.../db/sync/receiver/load/FileLoaderTest.java | 411 -
.../sync/receiver/manager/ReceiverManagerTest.java | 98 +
.../recover/SyncReceiverLogAnalyzerTest.java | 232 -
.../receiver/recover/SyncReceiverLoggerTest.java | 115 -
.../receiver/recovery/ReceiverLogAnalyzerTest.java | 123 +
.../db/sync/sender/manage/SyncFileManagerTest.java | 350 -
.../sender/recover/SyncSenderLogAnalyzerTest.java | 201 -
.../sync/sender/recover/SyncSenderLoggerTest.java | 112 -
.../db/sync/sender/transfer/SyncClientTest.java | 161 -
.../db/sync/transport/TransportServiceTest.java | 208 +
.../apache/iotdb/db/tools/IoTDBWatermarkTest.java | 3 +-
.../org/apache/iotdb/db/tools/MLogParserTest.java | 197 +-
.../iotdb/db/tools/SchemaFileSketchTest.java | 158 +
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 237 +
.../iotdb/db/tools/TsFileSelfCheckToolTest.java | 243 +
.../iotdb/db/tools/TsFileSketchToolTest.java | 192 +
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 119 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 132 +-
.../apache/iotdb/db/utils/FilePathUtilsTest.java | 124 -
.../iotdb/db/utils/MathQueryDataSetUtilsTest.java | 2 +-
.../org/apache/iotdb/db/utils/MemUtilsTest.java | 24 +-
.../org/apache/iotdb/db/utils/SchemaTestUtils.java | 39 +
.../org/apache/iotdb/db/utils/SchemaUtilsTest.java | 12 +-
.../apache/iotdb/db/utils/SerializeUtilsTest.java | 744 ++
.../iotdb/db/utils/TimeRangeIteratorTest.java | 298 +
.../iotdb/db/utils/TsFileRewriteToolTest.java | 243 +-
.../iotdb/db/utils/TypeInferenceUtilsTest.java | 23 +-
.../db/utils/datastructure/BinaryTVListTest.java | 63 +-
.../db/utils/datastructure/BooleanTVListTest.java | 71 +-
.../db/utils/datastructure/DoubleTVListTest.java | 73 +-
.../FixedPriorityBlockingQueueTest.java | 321 +
.../db/utils/datastructure/FloatTVListTest.java | 73 +-
.../db/utils/datastructure/IntTVListTest.java | 73 +-
.../db/utils/datastructure/LongTVListTest.java | 74 +-
.../db/utils/datastructure/PrecisionTest.java | 8 +-
.../db/utils/datastructure/TimeSelectorTest.java | 22 +
.../db/utils/datastructure/VectorTVListTest.java | 208 +
.../SlidingSizeWindowEvaluationHandlerTest.java | 184 +
.../SlidingTimeWindowEvaluationHandlerTest.java | 226 +
.../db/utils/writelog/LogWriterReaderTest.java | 205 +
.../db/utils/writelog/MultiFileLogReaderTest.java | 86 +
.../org/apache/iotdb/db/wal/DisableWALTest.java | 54 +
.../org/apache/iotdb/db/wal/WALManagerTest.java | 115 +
.../iotdb/db/wal/buffer/WALBufferCommonTest.java | 160 +
.../apache/iotdb/db/wal/buffer/WALBufferTest.java | 38 +
.../db/wal/checkpoint/CheckpointManagerTest.java | 157 +
.../apache/iotdb/db/wal/io/CheckpointFileTest.java | 135 +
.../org/apache/iotdb/db/wal/io/WALFileTest.java | 337 +
.../apache/iotdb/db/wal/node/WALFakeNodeTest.java | 74 +
.../org/apache/iotdb/db/wal/node/WALNodeTest.java | 276 +
.../db/wal/recover/WALRecoverManagerTest.java | 474 +
.../file/SealedTsFileRecoverPerformerTest.java | 310 +
.../db/wal/recover/file/TsFilePlanRedoerTest.java | 402 +
.../file/UnsealedTsFileRecoverPerformerTest.java | 263 +
.../db/wal/utils/TsFileUtilsForRecoverTest.java | 39 +
.../iotdb/db/wal/utils/WALByteBufferForTest.java | 75 +
.../iotdb/db/writelog/IoTDBLogFileSizeTest.java | 221 -
.../apache/iotdb/db/writelog/PerformanceTest.java | 219 -
.../iotdb/db/writelog/WriteLogNodeManagerTest.java | 185 -
.../apache/iotdb/db/writelog/WriteLogNodeTest.java | 324 -
.../iotdb/db/writelog/io/LogWriterReaderTest.java | 97 -
.../db/writelog/io/MultiFileLogReaderTest.java | 89 -
.../db/writelog/recover/DeviceStringTest.java | 132 -
.../iotdb/db/writelog/recover/LogReplayerTest.java | 281 -
.../recover/RecoverResourceFromReaderTest.java | 263 -
.../db/writelog/recover/SeqTsFileRecoverTest.java | 327 -
.../writelog/recover/UnseqTsFileRecoverTest.java | 276 -
.../datanode1conf/iotdb-engine.properties | 37 +
.../test/resources/datanode1conf/iotdb-metric.yml | 21 +
.../src/test/resources/datanode1conf/logback.xml | 302 +
.../datanode2conf/iotdb-engine.properties | 37 +
.../test/resources/datanode2conf/iotdb-metric.yml | 21 +
.../src/test/resources/datanode2conf/logback.xml | 302 +
.../datanode3conf/iotdb-engine.properties | 37 +
.../test/resources/datanode3conf/iotdb-metric.yml | 21 +
.../src/test/resources/datanode3conf/logback.xml | 302 +
server/src/test/resources/iotdb-engine.properties | 40 +-
server/src/test/resources/iotdb-rest.properties | 58 +
server/src/test/resources/logback-test.xml | 60 +
server/src/test/resources/logback.xml | 58 -
.../src/test/resources/testcontainers.properties | 17 +
service-rpc/pom.xml | 7 +-
.../iotdb/rpc/AutoScalingBufferReadTransport.java | 13 +
.../iotdb/rpc/AutoScalingBufferWriteTransport.java | 15 +
.../apache/iotdb/rpc/BatchExecutionException.java | 2 +-
.../iotdb/rpc/ConfigNodeConnectionException.java | 26 +
.../iotdb/rpc/InfluxDBSynchronizedHandler.java | 56 +
.../org/apache/iotdb/rpc/IoTDBJDBCDataSet.java | 619 +
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 31 +-
.../org/apache/iotdb/rpc/RedirectException.java | 18 +-
.../org/apache/iotdb/rpc/RpcTransportFactory.java | 37 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 76 +-
.../iotdb/rpc/StatementExecutionException.java | 8 +-
.../rpc/TCompressedElasticFramedTransport.java | 2 +-
.../org/apache/iotdb/rpc/TConfigurationConst.java | 31 +
.../apache/iotdb/rpc/TElasticFramedTransport.java | 20 +-
.../iotdb/rpc/TNonblockingSocketWrapper.java | 60 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 59 +-
.../java/org/apache/iotdb/rpc/TSocketWrapper.java | 68 +
.../rpc/TimeoutChangeableTFastFramedTransport.java | 8 +-
.../TimeoutChangeableTSnappyFramedTransport.java | 20 +-
.../org/apache/iotdb/rpc/TSStatusCodeTest.java | 31 +
session/pom.xml | 15 +-
.../main/java/org/apache/iotdb/session/Config.java | 14 +-
.../org/apache/iotdb/session/InsertConsumer.java | 31 +
.../java/org/apache/iotdb/session/Session.java | 1677 ++-
.../apache/iotdb/session/SessionConnection.java | 330 +-
.../org/apache/iotdb/session/SessionDataSet.java | 9 +-
.../org/apache/iotdb/session/SessionUtils.java | 91 -
.../iotdb/session/pool/SessionDataSetWrapper.java | 3 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 1766 ++-
.../iotdb/session/template/InternalNode.java | 59 +
.../iotdb/session/template/MeasurementNode.java | 67 +
.../apache/iotdb/session/template/Template.java | 136 +
.../iotdb/session/template/TemplateNode.java | 55 +
.../iotdb/session/template/TemplateQueryType.java | 30 +
.../apache/iotdb/session/util/SessionUtils.java | 266 +
.../org/apache/iotdb/session/util/ThreadUtils.java | 45 +
.../org/apache/iotdb/session/util/Version.java | 25 +
.../iotdb/session/IoTDBSessionComplexIT.java | 803 --
.../iotdb/session/IoTDBSessionIteratorIT.java | 343 -
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 684 -
.../apache/iotdb/session/SessionCacheLeaderUT.java | 467 +-
.../java/org/apache/iotdb/session/SessionUT.java | 202 -
.../apache/iotdb/session/pool/SessionPoolTest.java | 309 -
.../apache/iotdb/session/util/ThreadUtilsTest.java | 35 +
session/src/test/resources/iotdb-rest.properties | 58 +
session/src/test/resources/logback.xml | 40 +
site/README-zh.md | 9 +-
site/README.md | 7 +-
site/iotdb-doap.rdf | 16 +-
site/pom.xml | 336 +-
site/src/main/.asf.yaml | 25 +
site/src/main/.vuepress/config.js | 759 +-
.../.vuepress/public/img/contributor-avatar/cw.jpg | Bin 0 -> 163225 bytes
.../public/img/contributor-avatar/ericpai.jpg | Bin 0 -> 265364 bytes
.../public/img/contributor-avatar/qhl.jpg | Bin 0 -> 365541 bytes
site/src/main/.vuepress/redirects | 2 +
site/src/main/.vuepress/theme/components/Page.vue | 15 +-
.../theme/global-components/Contributor.vue | 75 +-
.../.vuepress/theme/global-components/IoTDB.vue | 2 +-
.../.vuepress/theme/global-components/IoTDBZH.vue | 2 +-
site/src/main/package.json | 3 +-
spark-iotdb-connector/Readme.md | 168 -
spark-iotdb-connector/pom.xml | 37 +-
.../org/apache/iotdb/spark/db/SQLConstant.java | 28 -
.../org/apache/iotdb/spark/db/Converter.scala | 6 +-
.../org/apache/iotdb/spark/db/DataFrameTools.scala | 131 +
.../org/apache/iotdb/spark/db/DefaultSource.scala | 28 +-
.../org/apache/iotdb/spark/db/IoTDBOptions.scala | 2 +-
.../scala/org/apache/iotdb/spark/db/IoTDBRDD.scala | 16 +-
.../org/apache/iotdb/spark/db/SQLConstant.scala | 27 +
.../org/apache/iotdb/spark/db/Transformer.scala | 18 +-
.../apache/iotdb/spark/db/EnvironmentUtils.java | 154 +-
.../org/apache/iotdb/spark/db/IoTDBTest.scala | 36 +-
.../org/apache/iotdb/spark/db/IoTDBWriteTest.scala | 117 +
.../iotdb/spark/db/unit/DataFrameToolsTest.scala | 95 +
spark-tsfile/README.md | 335 -
spark-tsfile/pom.xml | 4 +-
.../org/apache/iotdb/spark/tsfile/qp/Executor.java | 4 +-
.../apache/iotdb/spark/tsfile/DefaultSource.scala | 8 +-
.../iotdb/spark/tsfile/NarrowConverter.scala | 4 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 7 +-
.../org/apache/iotdb/spark/tool/TsFileExample.java | 29 +-
.../apache/iotdb/spark/tool/TsFileWriteTool.java | 85 +-
test/e2e/base/docker-compose.yaml | 4 +-
test/e2e/cases/cli/cleanup.sh | 0
test/e2e/cases/cli/run.sh | 0
testcontainer/Readme.md | 66 +
testcontainer/pom.xml | 166 +
.../test/java/org/apache/iotdb/db/sql/Cases.java | 995 ++
.../java/org/apache/iotdb/db/sql/ClusterIT.java | 105 +
.../iotdb/db/sql/ClusterSessionSimpleIT.java | 85 +
.../java/org/apache/iotdb/db/sql/SingleNodeIT.java | 88 +
.../iotdb/db/sql/node1/OneNodeClusterIT.java | 54 +
.../db/sql/nodes3/AbstractThreeNodeClusterIT.java | 61 +
.../iotdb/db/sql/nodes3/ThreeNodeCluster1IT.java | 23 +
.../iotdb/db/sql/nodes3/ThreeNodeCluster2IT.java | 32 +
.../db/sql/nodes5/AbstractFiveNodeClusterIT.java | 85 +
.../iotdb/db/sql/nodes5/FiveNodeCluster1IT.java | 23 +
.../iotdb/db/sql/nodes5/FiveNodeCluster2IT.java | 32 +
.../iotdb/db/sql/nodes5/FiveNodeCluster4IT.java | 32 +
.../NoProjectNameDockerComposeContainer.java | 38 +
.../src/test/resources/1node/docker-compose.yaml | 44 +
.../test/resources/1node/iotdb-cluster.properties | 35 +
.../src/test/resources/3nodes/docker-compose.yaml | 44 +
.../test/resources/3nodes/iotdb-cluster.properties | 35 +
.../src/test/resources/5nodes/docker-compose.yaml | 43 +
.../test/resources/5nodes/iotdb-cluster.properties | 35 +
.../src/test/resources/iotdb-engine.properties | 0
.../src/test/resources/logback-container.xml | 39 +
testcontainer/src/test/resources/logback.xml | 52 +
testcontainer/src/tool/README.md | 33 +
testcontainer/src/tool/parser.py | 79 +
thrift-cluster/pom.xml | 7 +-
thrift-cluster/src/main/thrift/cluster.thrift | 156 +-
thrift-commons/pom.xml | 62 +
thrift-commons/src/main/thrift/common.thrift | 70 +
thrift-confignode/pom.xml | 67 +
.../src/main/thrift/confignode.thrift | 229 +
thrift-influxdb/README.md | 22 +
thrift-influxdb/pom.xml | 98 +
thrift-influxdb/src/main/thrift/influxdb.thrift | 111 +
thrift-procedure/pom.xml | 66 +
thrift-procedure/src/main/thrift/procedure.thrift | 42 +
thrift-sync/pom.xml | 7 +-
thrift-sync/src/main/thrift/sync.thrift | 51 -
thrift-sync/src/main/thrift/transport.thrift | 90 +
thrift/pom.xml | 7 +-
thrift/rpc-changelist.md | 29 +
thrift/src/main/thrift/mpp.thrift | 189 +
thrift/src/main/thrift/rpc.thrift | 229 +-
tsfile/README.md | 2 +-
tsfile/format-changelist.md | 2 +-
tsfile/pom.xml | 47 +-
.../iotdb/tsfile/common/cache/Accountable.java | 26 -
.../iotdb/tsfile/common/conf/TSFileConfig.java | 31 +-
.../iotdb/tsfile/common/conf/TSFileDescriptor.java | 216 +-
.../tsfile/common/constant/TsFileConstant.java | 4 +
.../apache/iotdb/tsfile/compress/ICompressor.java | 58 +-
.../iotdb/tsfile/encoding/decoder/Decoder.java | 17 +
.../tsfile/encoding/decoder/DictionaryDecoder.java | 86 +
.../tsfile/encoding/decoder/FloatDecoder.java | 12 +-
.../iotdb/tsfile/encoding/decoder/FreqDecoder.java | 144 +
.../tsfile/encoding/decoder/IntZigzagDecoder.java | 94 +
.../tsfile/encoding/decoder/LongZigzagDecoder.java | 101 +
.../tsfile/encoding/decoder/PlainDecoder.java | 2 +-
.../encoding/encoder/DeltaBinaryEncoder.java | 10 +-
.../tsfile/encoding/encoder/DictionaryEncoder.java | 115 +
.../iotdb/tsfile/encoding/encoder/FreqEncoder.java | 317 +
.../tsfile/encoding/encoder/IntZigzagEncoder.java | 101 +
.../tsfile/encoding/encoder/LongZigzagEncoder.java | 111 +
.../tsfile/encoding/encoder/TSEncodingBuilder.java | 105 +-
.../TsFileStatisticsMistakesException.java | 26 +
.../compress/GZIPCompressOverflowException.java | 26 +
.../write/UnSupportedDataTypeException.java | 2 +-
.../org/apache/iotdb/tsfile/file/MetaMarker.java | 18 +
.../iotdb/tsfile/file/header/ChunkHeader.java | 22 +-
.../iotdb/tsfile/file/header/PageHeader.java | 27 +-
.../tsfile/file/metadata/AlignedChunkMetadata.java | 198 +
.../file/metadata/AlignedTimeSeriesMetadata.java | 146 +
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 82 +-
.../iotdb/tsfile/file/metadata/IChunkMetadata.java | 77 +
.../tsfile/file/metadata/ITimeSeriesMetadata.java | 43 +
.../file/metadata/MetadataIndexConstructor.java | 12 +-
.../tsfile/file/metadata/MetadataIndexNode.java | 2 +-
.../tsfile/file/metadata/TimeseriesMetadata.java | 50 +-
.../tsfile/file/metadata/enums/TSDataType.java | 26 +-
.../tsfile/file/metadata/enums/TSEncoding.java | 12 +-
.../file/metadata/statistics/BinaryStatistics.java | 88 +-
.../metadata/statistics/BooleanStatistics.java | 86 +-
.../file/metadata/statistics/DoubleStatistics.java | 86 +-
.../file/metadata/statistics/FloatStatistics.java | 86 +-
.../metadata/statistics/IntegerStatistics.java | 85 +-
.../file/metadata/statistics/LongStatistics.java | 85 +-
.../file/metadata/statistics/Statistics.java | 149 +-
.../file/metadata/statistics/TimeStatistics.java | 111 +
.../fileOutputFactory/LocalFSOutputFactory.java | 7 +-
.../apache/iotdb/tsfile/read/ReadOnlyTsFile.java | 60 -
.../read/TsFileAlignedSeriesReaderIterator.java | 86 +
.../iotdb/tsfile/read/TsFileCheckStatus.java | 7 +-
.../iotdb/tsfile/read/TsFileDeviceIterator.java | 73 +
.../org/apache/iotdb/tsfile/read/TsFileReader.java | 60 +
.../iotdb/tsfile/read/TsFileSequenceReader.java | 924 +-
.../apache/iotdb/tsfile/read/common/BatchData.java | 308 +-
.../org/apache/iotdb/tsfile/read/common/Chunk.java | 20 +-
.../tsfile/read/common/DescReadBatchData.java | 5 +-
.../tsfile/read/common/DescReadWriteBatchData.java | 132 +
.../tsfile/read/common/ExceptionBatchData.java | 10 +-
.../org/apache/iotdb/tsfile/read/common/Field.java | 26 +
.../tsfile/read/common/IBatchDataIterator.java | 37 +
.../org/apache/iotdb/tsfile/read/common/Path.java | 34 +-
.../apache/iotdb/tsfile/read/common/RowRecord.java | 71 +-
.../apache/iotdb/tsfile/read/common/TimeRange.java | 24 +-
.../iotdb/tsfile/read/common/block/TsBlock.java | 483 +
.../tsfile/read/common/block/TsBlockBuilder.java | 313 +
.../read/common/block/TsBlockBuilderStatus.java | 75 +
.../tsfile/read/common/block/TsBlockMetadata.java | 41 +
.../block/column/BinaryArrayColumnEncoder.java | 85 +
.../read/common/block/column/BinaryColumn.java | 156 +
.../common/block/column/BinaryColumnBuilder.java | 154 +
.../read/common/block/column/BooleanColumn.java | 155 +
.../common/block/column/BooleanColumnBuilder.java | 156 +
.../block/column/ByteArrayColumnEncoder.java | 68 +
.../tsfile/read/common/block/column/Column.java | 114 +
.../read/common/block/column/ColumnBuilder.java | 103 +
.../common/block/column/ColumnBuilderStatus.java | 91 +
.../read/common/block/column/ColumnEncoder.java | 120 +
.../common/block/column/ColumnEncoderFactory.java | 42 +
.../read/common/block/column/ColumnEncoding.java | 64 +
.../read/common/block/column/ColumnUtil.java | 97 +
.../read/common/block/column/DoubleColumn.java | 155 +
.../common/block/column/DoubleColumnBuilder.java | 156 +
.../read/common/block/column/FloatColumn.java | 153 +
.../common/block/column/FloatColumnBuilder.java | 156 +
.../block/column/Int32ArrayColumnEncoder.java | 87 +
.../block/column/Int64ArrayColumnEncoder.java | 87 +
.../tsfile/read/common/block/column/IntColumn.java | 153 +
.../read/common/block/column/IntColumnBuilder.java | 156 +
.../read/common/block/column/LongColumn.java | 153 +
.../common/block/column/LongColumnBuilder.java | 156 +
.../read/common/block/column/NullColumn.java | 50 +
.../block/column/RunLengthEncodedColumn.java | 168 +
.../read/common/block/column/TimeColumn.java | 137 +
.../common/block/column/TimeColumnBuilder.java | 148 +
.../read/common/block/column/TsBlockSerde.java | 125 +
.../read/controller/CachedChunkLoaderImpl.java | 82 +-
.../iotdb/tsfile/read/controller/IChunkLoader.java | 5 +
.../read/controller/IChunkMetadataLoader.java | 6 +-
.../tsfile/read/controller/IMetadataQuerier.java | 6 +-
.../read/controller/MetadataQuerierByFileImpl.java | 91 +-
.../iotdb/tsfile/read/expression/IExpression.java | 3 +
.../read/expression/impl/BinaryExpression.java | 55 +
.../read/expression/impl/GlobalTimeExpression.java | 33 +
.../expression/impl/SingleSeriesExpression.java | 33 +
.../read/expression/util/ExpressionOptimizer.java | 34 +-
.../iotdb/tsfile/read/filter/GroupByFilter.java | 20 +-
.../tsfile/read/filter/GroupByMonthFilter.java | 237 +-
.../iotdb/tsfile/read/filter/TimeFilter.java | 11 +
.../iotdb/tsfile/read/filter/ValueFilter.java | 160 +
.../tsfile/read/filter/basic/BinaryFilter.java | 8 +
.../iotdb/tsfile/read/filter/basic/Filter.java | 8 +
.../tsfile/read/filter/factory/FilterFactory.java | 12 +
.../read/filter/factory/FilterSerializeId.java | 5 +-
.../iotdb/tsfile/read/filter/operator/In.java | 21 +-
.../iotdb/tsfile/read/filter/operator/Like.java | 166 +
.../iotdb/tsfile/read/filter/operator/Regexp.java | 127 +
.../query/dataset/DataSetWithTimeGenerator.java | 15 +-
.../query/dataset/DataSetWithoutTimeGenerator.java | 18 +-
.../tsfile/read/query/dataset/QueryDataSet.java | 94 +-
.../query/executor/ExecutorWithTimeGenerator.java | 4 +-
.../tsfile/read/query/executor/TsFileExecutor.java | 4 +-
.../read/query/timegenerator/TimeGenerator.java | 3 +
.../query/timegenerator/TsFileTimeGenerator.java | 10 +-
.../read/query/timegenerator/node/LeafNode.java | 2 +-
.../tsfile/read/reader/BatchDataIterator.java | 54 -
.../tsfile/read/reader/IAlignedPageReader.java | 28 +
.../iotdb/tsfile/read/reader/IPageReader.java | 3 +
.../iotdb/tsfile/read/reader/LocalTsFileInput.java | 5 +
.../iotdb/tsfile/read/reader/TsFileInput.java | 2 +
.../read/reader/chunk/AlignedChunkReader.java | 339 +
.../tsfile/read/reader/chunk/ChunkReader.java | 32 +-
.../read/reader/chunk/ChunkReaderByTimestamp.java | 44 -
.../tsfile/read/reader/page/AlignedPageReader.java | 188 +
.../iotdb/tsfile/read/reader/page/PageReader.java | 129 +-
.../tsfile/read/reader/page/TimePageReader.java | 117 +
.../tsfile/read/reader/page/ValuePageReader.java | 274 +
.../reader/series/AbstractFileSeriesReader.java | 18 +-
.../read/reader/series/EmptyFileSeriesReader.java | 6 +-
.../read/reader/series/FileSeriesReader.java | 25 +-
.../reader/series/FileSeriesReaderByTimestamp.java | 34 +-
.../java/org/apache/iotdb/tsfile/utils/Binary.java | 2 +
.../apache/iotdb/tsfile/utils/BitConstructor.java | 94 +
.../java/org/apache/iotdb/tsfile/utils/BitMap.java | 188 +
.../org/apache/iotdb/tsfile/utils/BitReader.java | 70 +
.../org/apache/iotdb/tsfile/utils/BloomFilter.java | 46 +-
.../apache/iotdb/tsfile/utils/ByteArrayList.java | 135 +
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 131 +-
.../apache/iotdb/tsfile/utils/FilePathUtils.java | 159 +
.../iotdb/tsfile/utils/MeasurementGroup.java | 65 +
.../java/org/apache/iotdb/tsfile/utils/Pair.java | 8 +
.../org/apache/iotdb/tsfile/utils/PublicBAOS.java | 5 +
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 130 +-
.../apache/iotdb/tsfile/utils/StringContainer.java | 12 +-
.../iotdb/tsfile/utils/TsFileGeneratorUtils.java | 285 +
.../org/apache/iotdb/tsfile/utils/TsFileUtils.java | 58 +
.../apache/iotdb/tsfile/utils/TsPrimitiveType.java | 234 +-
.../iotdb/tsfile/v2/file/header/PageHeaderV2.java | 5 +-
.../tsfile/v2/file/metadata/ChunkMetadataV2.java | 3 +-
.../v2/file/metadata/MetadataIndexNodeV2.java | 2 +-
.../tsfile/v2/file/metadata/TsFileMetadataV2.java | 9 +-
.../v2/file/metadata/statistics/StatisticsV2.java | 14 +-
.../tsfile/v2/read/TsFileSequenceReaderForV2.java | 41 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 410 +-
.../write/chunk/AlignedChunkGroupWriterImpl.java | 306 +
.../tsfile/write/chunk/AlignedChunkWriterImpl.java | 239 +
.../tsfile/write/chunk/ChunkGroupWriterImpl.java | 168 -
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 72 +-
.../tsfile/write/chunk/IChunkGroupWriter.java | 17 +-
.../iotdb/tsfile/write/chunk/IChunkWriter.java | 44 +-
.../chunk/NonAlignedChunkGroupWriterImpl.java | 195 +
.../iotdb/tsfile/write/chunk/TimeChunkWriter.java | 260 +
.../iotdb/tsfile/write/chunk/ValueChunkWriter.java | 335 +
.../apache/iotdb/tsfile/write/page/PageWriter.java | 15 +-
.../iotdb/tsfile/write/page/TimePageWriter.java | 181 +
.../iotdb/tsfile/write/page/ValuePageWriter.java | 319 +
.../apache/iotdb/tsfile/write/record/Tablet.java | 228 +-
.../write/record/datapoint/BooleanDataPoint.java | 4 +-
.../tsfile/write/record/datapoint/DataPoint.java | 19 +-
.../write/record/datapoint/DoubleDataPoint.java | 4 +-
.../write/record/datapoint/FloatDataPoint.java | 4 +-
.../write/record/datapoint/IntDataPoint.java | 4 +-
.../write/record/datapoint/LongDataPoint.java | 4 +-
.../write/record/datapoint/StringDataPoint.java | 4 +-
.../tsfile/write/schema/IMeasurementSchema.java | 86 +
.../tsfile/write/schema/MeasurementSchema.java | 125 +-
.../apache/iotdb/tsfile/write/schema/Schema.java | 80 +-
.../tsfile/write/schema/TimeseriesSchema.java | 3 +-
.../write/schema/VectorMeasurementSchema.java | 415 +
.../tsfile/write/writer/LocalTsFileOutput.java | 41 +-
.../write/writer/RestorableTsFileIOWriter.java | 61 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 134 +-
.../common/block/BinaryArrayColumnEncoderTest.java | 82 +
.../common/block/ByteArrayColumnEncoderTest.java | 78 +
.../tsfile/common/block/ColumnEncoderTest.java | 144 +
.../common/block/Int32ArrayColumnEncoderTest.java | 120 +
.../common/block/Int64ArrayColumnEncoderTest.java | 121 +
.../tsfile/common/block/NullColumnUnitTest.java | 120 +
.../tsfile/common/block/TsBlockSerdeTest.java | 112 +
.../iotdb/tsfile/common/block/TsBlockTest.java | 374 +
.../tsfile/common/conf/TSFileDescriptorTest.java | 85 +
.../org/apache/iotdb/tsfile/compress/GZIPTest.java | 17 +-
.../org/apache/iotdb/tsfile/compress/LZ4Test.java | 17 +-
.../apache/iotdb/tsfile/compress/SnappyTest.java | 17 +-
.../apache/iotdb/tsfile/constant/TestConstant.java | 4 +
.../encoding/decoder/DictionaryDecoderTest.java | 85 +
.../tsfile/encoding/decoder/FreqDecoderTest.java | 161 +
.../tsfile/encoding/decoder/IntRleDecoderTest.java | 7 +-
.../encoding/decoder/IntZigzagDecoderTest.java | 99 +
.../encoding/decoder/LongZigzagDecoderTest.java | 94 +
.../regular/RegularDataEncoderLongTest.java | 4 +-
.../file/metadata/TimeSeriesMetadataTest.java | 110 -
.../file/metadata/TimeseriesMetadataTest.java | 110 +
.../tsfile/file/metadata/utils/TestHelper.java | 8 +-
.../iotdb/tsfile/file/metadata/utils/Utils.java | 73 -
.../iotdb/tsfile/read/GetAllDevicesTest.java | 2 +-
...easurementChunkMetadataListMapIteratorTest.java | 18 +-
.../iotdb/tsfile/read/ReadInPartitionTest.java | 4 +-
.../iotdb/tsfile/read/ReadOnlyTsFileTest.java | 168 -
.../org/apache/iotdb/tsfile/read/ReadTest.java | 7 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 7 +-
.../tsfile/read/TimeSeriesMetadataReadTest.java | 7 +-
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 517 +
.../tsfile/read/TsFileSequenceReaderTest.java | 51 +-
.../iotdb/tsfile/read/common/BatchDataTest.java | 4 +-
.../iotdb/tsfile/read/common/ColumnTest.java | 322 +
.../apache/iotdb/tsfile/read/common/PathTest.java | 10 +-
.../tsfile/read/controller/ChunkLoaderTest.java | 7 +-
.../tsfile/read/filter/FilterSerializeTest.java | 26 +-
.../tsfile/read/filter/GroupByMonthFilterTest.java | 46 +-
.../read/query/timegenerator/ReadWriteTest.java | 14 +-
.../query/timegenerator/ReaderByTimestampTest.java | 4 +-
.../timegenerator/TimeGeneratorReadEmptyTest.java | 13 +-
.../timegenerator/TimeGeneratorReadWriteTest.java | 13 +-
.../TsFileGeneratorForSeriesReaderByTimestamp.java | 43 +-
.../iotdb/tsfile/read/reader/ChunkReaderTest.java | 109 +
.../tsfile/read/reader/FakedTimeGenerator.java | 6 +
.../iotdb/tsfile/read/reader/ReaderTest.java | 6 +-
.../org/apache/iotdb/tsfile/utils/BitMapTest.java | 67 +
.../apache/iotdb/tsfile/utils/FileGenerator.java | 110 +-
.../iotdb/tsfile/utils/FilePathUtilsTest.java | 100 +
.../iotdb/tsfile/utils/ReadWriteIOUtilsTest.java | 30 +-
.../org/apache/iotdb/tsfile/utils/RecordUtils.java | 21 +-
.../apache/iotdb/tsfile/utils/RecordUtilsTest.java | 12 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 127 +-
.../apache/iotdb/tsfile/utils/TsFileUtilsTest.java | 72 +
.../tsfile/write/DefaultDeviceTemplateTest.java | 109 -
.../tsfile/write/DefaultSchemaTemplateTest.java | 113 +
.../tsfile/write/MetadataIndexConstructorTest.java | 494 +
.../org/apache/iotdb/tsfile/write/PerfTest.java | 16 +-
.../iotdb/tsfile/write/ReadPageInMemTest.java | 16 +-
...SameMeasurementsWithDifferentDataTypesTest.java | 13 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 170 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 23 +-
.../iotdb/tsfile/write/TsFileWriteApiTest.java | 426 +
.../iotdb/tsfile/write/TsFileWriterTest.java | 126 +-
.../org/apache/iotdb/tsfile/write/WriteTest.java | 10 +-
.../write/schema/converter/SchemaBuilderTest.java | 48 +-
.../write/writer/AlignedChunkWriterImplTest.java | 181 +
.../write/writer/ForceAppendTsFileWriterTest.java | 24 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 142 +-
.../tsfile/write/writer/TestTsFileOutput.java | 70 +
.../tsfile/write/writer/TimeChunkWriterTest.java | 110 +
.../tsfile/write/writer/TimePageWriterTest.java | 171 +
.../tsfile/write/writer/ValueChunkWriterTest.java | 109 +
.../tsfile/write/writer/ValuePageWriterTest.java | 291 +
.../write/writer/VectorMeasurementSchemaStub.java | 138 +
zeppelin-interpreter/pom.xml | 11 +-
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 42 +-
4093 files changed, 523778 insertions(+), 151918 deletions(-)
diff --cc integration/src/test/java/org/apache/iotdb/db/integration/IoTDBDatetimeFormatIT.java
index 0000000000,aa97f90309..07993ff40b
mode 000000,100644..100644
--- a/integration/src/test/java/org/apache/iotdb/db/integration/IoTDBDatetimeFormatIT.java
+++ b/integration/src/test/java/org/apache/iotdb/db/integration/IoTDBDatetimeFormatIT.java
@@@ -1,0 -1,112 +1,133 @@@
+ /*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements. See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership. The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License. You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied. See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+ package org.apache.iotdb.db.integration;
+
++import java.sql.Connection;
++import java.sql.DriverManager;
+ import org.apache.iotdb.integration.env.EnvFactory;
+ import org.apache.iotdb.itbase.category.ClusterTest;
+ import org.apache.iotdb.itbase.category.LocalStandaloneTest;
+ import org.apache.iotdb.itbase.category.RemoteTest;
++import org.apache.iotdb.jdbc.Config;
+ import org.apache.iotdb.jdbc.IoTDBConnection;
+
+ import org.apache.thrift.TException;
+ import org.junit.After;
+ import org.junit.Assert;
+ import org.junit.Before;
+ import org.junit.Test;
+ import org.junit.experimental.categories.Category;
+
+ import java.sql.ResultSet;
+ import java.sql.SQLException;
+ import java.sql.Statement;
+
+ import static org.junit.Assert.fail;
+
+ @Category({LocalStandaloneTest.class, ClusterTest.class, RemoteTest.class})
+ public class IoTDBDatetimeFormatIT {
+
+ @Before
+ public void setUp() throws Exception {
+ EnvFactory.getEnv().initBeforeTest();
+ }
+
+ @After
+ public void tearDown() throws Exception {
+ EnvFactory.getEnv().cleanAfterTest();
+ }
+
+ @Test
+ public void testDatetimeInputFormat() {
+ String[] datetimeStrings = {
+ "2022-01-01 01:02:03", // yyyy-MM-dd HH:mm:ss
+ "2022/01/02 01:02:03", // yyyy/MM/dd HH:mm:ss
+ "2022.01.03 01:02:03", // yyyy.MM.dd HH:mm:ss
+ "2022-01-04 01:02:03+01:00", // yyyy-MM-dd HH:mm:ssZZ
+ "2022/01/05 01:02:03+01:00", // yyyy/MM/dd HH:mm:ssZZ
+ "2022.01.06 01:02:03+01:00", // yyyy.MM.dd HH:mm:ssZZ
+ "2022-01-07 01:02:03.400", // yyyy-MM-dd HH:mm:ss.SSS
+ "2022/01/08 01:02:03.400", // yyyy/MM/dd HH:mm:ss.SSS
+ "2022.01.09 01:02:03.400", // yyyy.MM.dd HH:mm:ss.SSS
+ "2022-01-10 01:02:03.400+01:00", // yyyy-MM-dd HH:mm:ss.SSSZZ
+ "2022-01-11 01:02:03.400+01:00", // yyyy/MM/dd HH:mm:ss.SSSZZ
+ "2022-01-12 01:02:03.400+01:00", // yyyy.MM.dd HH:mm:ss.SSSZZ
+ "2022-01-13T01:02:03.400+01:00" // ISO8601 standard time format
+ };
+ long[] timestamps = {
+ 1640970123000L,
+ 1641056523000L,
+ 1641142923000L,
+ 1641254523000L,
+ 1641340923000L,
+ 1641427323000L,
+ 1641488523400L,
+ 1641574923400L,
+ 1641661323400L,
+ 1641772923400L,
+ 1641859323400L,
+ 1641945723400L,
+ 1642032123400L
+ };
+ try (IoTDBConnection connection = (IoTDBConnection) EnvFactory.getEnv().getConnection();
+ Statement statement = connection.createStatement()) {
+
+ connection.setTimeZone("+08:00");
+
+ for (int i = 0; i < datetimeStrings.length; i++) {
+ String insertSql =
+ String.format(
+ "INSERT INTO root.sg1.d1(time, s1) values (%s, %d)", datetimeStrings[i], i);
+ statement.execute(insertSql);
+ }
+
+ boolean hasResult = statement.execute("SELECT s1 FROM root.sg1.d1");
+ Assert.assertTrue(hasResult);
+
+ int cnt = 0;
+ ResultSet resultSet = statement.getResultSet();
+ while (resultSet.next()) {
+ Assert.assertEquals(timestamps[cnt], resultSet.getLong(1));
+ cnt++;
+ }
+ Assert.assertEquals(timestamps.length, cnt);
+ } catch (SQLException | TException e) {
+ e.printStackTrace();
+ fail();
+ }
+ }
++
++ @Test
++ public void testBigDateTime() {
++ try (IoTDBConnection connection = (IoTDBConnection) EnvFactory.getEnv().getConnection();
++ Statement statement = connection.createStatement()) {
++ statement.setFetchSize(5);
++ statement.execute("SET STORAGE GROUP TO root.sg");
++
++ statement.execute("CREATE TIMESERIES root.sg.d1.s2 WITH DATATYPE=DOUBLE, ENCODING=PLAIN;");
++
++ statement.execute("insert into root.sg.d1(time,s2) values (1618283005586000, 8.76);");
++ statement.execute("select * from root.sg.d1;");
++ statement.execute("select * from root.sg.d1 where time=53251-05-07T17:06:26.000+08:00");
++ } catch (SQLException e) {
++ e.printStackTrace();
++ fail();
++ }
++ }
+ }
diff --cc service-rpc/src/main/java/org/apache/iotdb/rpc/RpcUtils.java
index bdebb1d40f,437b724d4f..8d915a0fe8
--- a/service-rpc/src/main/java/org/apache/iotdb/rpc/RpcUtils.java
+++ b/service-rpc/src/main/java/org/apache/iotdb/rpc/RpcUtils.java
@@@ -245,11 -266,11 +279,11 @@@ public class RpcUtils
@SuppressWarnings("squid:S3776") // Suppress high Cognitive Complexity warning
public static String parseLongToDateWithPrecision(
DateTimeFormatter formatter, long timestamp, ZoneId zoneid, String timestampPrecision) {
- if (timestampPrecision.equals("ms")) {
- long integerofDate = timestamp / 1000;
+ if ("ms".equals(timestampPrecision)) {
- long integerofDate = timestamp / 1000;
++ long integerOfDate = timestamp / 1000;
StringBuilder digits = new StringBuilder(Long.toString(timestamp % 1000));
ZonedDateTime dateTime =
-- ZonedDateTime.ofInstant(Instant.ofEpochSecond(integerofDate), zoneid);
++ ZonedDateTime.ofInstant(Instant.ofEpochSecond(integerOfDate), zoneid);
String datetime = dateTime.format(formatter);
int length = digits.length();
if (length != 3) {
@@@ -257,12 -278,12 +291,12 @@@
digits.insert(0, "0");
}
}
- return datetime.substring(0, 19) + "." + digits + datetime.substring(19);
+ return formateDatetimeStr(datetime, digits);
- } else if (timestampPrecision.equals("us")) {
- long integerofDate = timestamp / 1000_000;
+ } else if ("us".equals(timestampPrecision)) {
- long integerofDate = timestamp / 1000_000;
++ long integerOfDate = timestamp / 1000_000;
StringBuilder digits = new StringBuilder(Long.toString(timestamp % 1000_000));
ZonedDateTime dateTime =
-- ZonedDateTime.ofInstant(Instant.ofEpochSecond(integerofDate), zoneid);
++ ZonedDateTime.ofInstant(Instant.ofEpochSecond(integerOfDate), zoneid);
String datetime = dateTime.format(formatter);
int length = digits.length();
if (length != 6) {
@@@ -270,12 -291,12 +304,12 @@@
digits.insert(0, "0");
}
}
- return datetime.substring(0, 19) + "." + digits + datetime.substring(19);
+ return formateDatetimeStr(datetime, digits);
} else {
-- long integerofDate = timestamp / 1000_000_000L;
++ long integerOfDate = timestamp / 1000_000_000L;
StringBuilder digits = new StringBuilder(Long.toString(timestamp % 1000_000_000L));
ZonedDateTime dateTime =
-- ZonedDateTime.ofInstant(Instant.ofEpochSecond(integerofDate), zoneid);
++ ZonedDateTime.ofInstant(Instant.ofEpochSecond(integerOfDate), zoneid);
String datetime = dateTime.format(formatter);
int length = digits.length();
if (length != 9) {