This is an automated email from the ASF dual-hosted git repository.
hxd pushed a change to branch seperate_thrift
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from f932511 modify readme of the whole project
add 2ef1b2c add logback and slf4j in root/pom
add 19ad435 [IOTDB-1204] set parameter in iotdb-cluster.properties (#2797)
add 1f54e62 Update cpp client build doc (#2796)
add 7d5329f [IOTDB-1192] Fix sql end with semicolon (#2798)
add a857820 Update UDF User Defined Function.md
add aad1bcd [IOTDB-1193] Remove redundant sync meta leader in CManager
for cluster module (#2787)
add 02a4ecf [IOTDB-1208] revise the cluster setup docs (#2807)
add ff3a0f9 Fix compaction with cluster snapshot deletion (#2811)
add 1f98174 [IOTDB-1221] Compaction module: chunk metadata lists returned
by the getMeasurementChunkMetadataListMapIterator method are not
lexicographically ordered by the measurement names (#2817)
add bccb441 check and persist the system properties of the cluster
version (#2816)
add 251c979 Rename timeout parameter (#2824)
add 653841b download calcite-core's dependency penhato from
public.nexus.pentaho.org rather than spring.io
add b692da0 Skip code coverage and sonar reports in a forked pull request
add 743f57d fix test executor error (#2829)
add 4f60e92 [IOTDB-1187] Fix unseq compaction loss data bug after delete
operation (#2785)
add e35a3e4 Fix refactor query code, reduce complexity in
PhysicalGenerator (#2820)
add daa50d7 optimize the doc that WAL has three ways to be flashed to
disk (#2822)
add 5540272 [ISSUE-2827] add an overrided addChild() method in MNode.
(#2828)
add a735202 Optimize the code structure of deduplicate() (#2856)
add adc61e2 Optimize the code structure of deduplicate() - PART2 (#2863)
add a8b01f1 [IOTDB-1234] fix ImportCsv tool cannot parse empty string
(#2857)
add c9026e2 Optimize cluster query (#2859)
add 32eaa9e simplify the Avg formula on removing redundant operations
(#2868)
add 6ffd095 [IOTDB-1274] fix the insert blocked caused the bugs in mem
control module
add 9e886df Use switch case in enums class (#2882)
add c351b32 fix add "-" in thread name (#2884)
add ec70703 [IOTDB-1214] Add Flink-IoTDB documents to the website (#2813)
add b214511 [IOTDB-1251] optimize route intervals (#2886)
add 155df75 [IOTDB-1207]Open time partition causes stackoverflow in
Cluster Module (#2809)
add 77cdc38 [IOTDB-1240]support show node command in cluster version
(#2866)
add ee4f073 Fix_IoTDBNewTsFileCompactionIT_problem (#2890)
add 3781cc2 fix spelling mistake (#2889)
add 64c11bc [IOTDB-1255] refactor cluster package and jar name (#2892)
add 5455d3b [IOTDB-1252] optimize test mult-times perform (#2887)
add 4f4ee90 Update cluster setup example after changing artifactId in
cluster module (#2899)
add 85604b4 [IOTDB-1250] fix pull schema bug that the
pullTimeSeriesSchema and pullMeasurementSchema is misused(#2894)
add 8fc8de3 [IOTDB-854] Limit the memory foorprint of the committed log
cache (#2879)
add ec5b756 fix Flink TsFile doc url error caused by PR2813 (#2893)
add 9b22439 IOTDB-1241 support redirect query for cluster (#2867)
add 3bdde72 Open IoTDBRemovePartitionIT ci log for diagnosis; fix
System.out is closed in IoTDBCheckConfigIT (#2812)
add 4377d18 [IOTDB-1256] upgrade Jackson to 2.11.0 because of loopholes
CVE-2020-25649 (#2896)
add 952a180 Add the method size() to Row in UDF (#2897)
add 910b184 [IOTDB-1117][Distributed]Batched creation and fetch of
RemoteSeriesReader(#2875)
add be1d6a6 Fix alter context for max_degree_of_index_node default-value.
(#2910)
add 1c66316 fix Chinese Flink TsFile doc name
add e67b770 [IOTDB-1236] Improve jdbc performance for creating timeseries
in cluster module (#2872)
add c5be711 Improve Python Client (#2898)
add 876a576 Fix Add Operation bug introduced by #2872 (#2918)
add 1fd2e19 [IOTDB-1248] forward the pull schema request to the leader
(#2902)
add d2c1030 Make CSV Tool doc more readable (#2926)
add b28fa65 [ISSUE-2905] Fix Files.deleteIfExists() doesn't work for HDFS
file (#2912)
add e3d0e8e [IOTDB-1258] jcl-over-slf4j have security vulnerabilities
CVE-2018-8088 (#2906)
add 4b533ff [IOTDB-1260] optimize time_range query because syncMetaLeader
(#2929)
add a453b2f [ISSUE-2790] Fix greetings.yml workflow (#2936)
add c8f6d0f [Distributed] Fix stackoverflow bug caused by
InsertMultiTabletPlan or InsertRowsPlan (#2938)
add abdb580 [Distributed] Fix show remote timeseries serialization bug
(#2940)
add 170d679 [IOTDB-1260] optimize time_range query because syncMetaLeader
(#2943)
add 52a7251 fix spelling mistake in TsFile's readme doc (#2947)
add 92e4755 [IOTDB-1265] fix bug: correct cluster to iotdb-cluster (#2949)
add 43c4981 [ISSUE-2730] Add the number of unseq merge times in TsFile
name. (#2939)
add 9a05be4 [IOTDB-1257] Make a little bit improvement of config and fix
some bugs for setting logic (#2904)
add 8c38f6d Fix unseq compaction file selector conflicts with time
partition bug (#2920)
add 2e7a32e [IOTDB-1262] The test fails to be executed independently
add ee908fb bug fix:correct cluster to iotdb-cluster when pacakging zip
files (#2954)
add 453d95d [IOTDB-1194]Fix a bug of checking time partition in
DeviceTimeIndex (#2800)
add 5a752b0 [IOTDB-1267] optimize ServerTimeGenerator IExpression
parameter (#2955)
add 5b73c1d [ISSUE-2730] Change the upgraded TsFile names (#2952)
add 48c5488 [ISSUE-2919] Fix C++ client memory leak bug (#2937)
add 70e451e Throw exception when device to be queried is not in
TsFileMetaData (#2944)
add 1d7386d [IOTDB-1273]Feature/restrucutre python module as well as
supporting pandas dataframe (#2922)
add fa86482 Fix monitor bug caused by virtual storage group name (#2852)
add fa5aafa [IOTDB-1197] add iotdb-client-go as a git submodule of IoTDB
repo (#2792)
add b2986cc [Distributed]fix stackoverflow when parse plan failed (#2953)
add d726fb3 [IOTDB-1180] Reset the system log file names and maximal
disk-space size (#2765)
add 3f739bf [IOTDB-1276]Add explain sql support and remove debug_state
parameter (#2848)
add 4afda52 Fix incompatible max_degree_of_index_node (#2962)
add b9b3ea7 [ISSUE-2911]Fix The write stream is not closed when executing
the command 'tracing off' (#2961)
add 276d8ea Merge remote-tracking branch 'origin/master' into
seperate_thrift
No new revisions were added by this update.
Summary of changes:
.github/workflows/{main-unix.yml => client-go.yml} | 23 +-
.github/workflows/greetings.yml | 2 +-
.github/workflows/sonar-coveralls.yml | 14 +-
.gitignore | 3 +
.gitmodules | 3 +
LICENSE-binary | 4 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 7 +-
client-cpp/README.md | 6 +-
client-cpp/src/main/Session.cpp | 30 +-
client-cpp/src/main/Session.h | 27 +-
client-go | 1 +
.asf.yaml => client-py/.flake8 | 29 +-
client-py/.gitignore | 5 +
client-py/README.md | 193 +++++++++
client-py/SessionExample.py | 177 ++++++++
client-py/SessionTest.py | 243 +++++++++++
client-py/iotdb/IoTDBContainer.py | 51 +++
client-py/{src => }/iotdb/Session.py | 343 +++++++++++----
client-py/{src => }/iotdb/__init__.py | 1 -
client-py/{src => }/iotdb/utils/Field.py | 10 +-
client-py/{src => }/iotdb/utils/IoTDBConstants.py | 0
client-py/{src => }/iotdb/utils/IoTDBRpcDataSet.py | 90 ++--
client-py/{src => }/iotdb/utils/RowRecord.py | 5 +-
client-py/{src => }/iotdb/utils/SessionDataSet.py | 109 ++++-
client-py/{src => }/iotdb/utils/Tablet.py | 16 +-
client-py/{src => }/iotdb/utils/__init__.py | 1 -
client-py/pom.xml | 77 ++--
client-py/pypi/README.md | 73 ----
.../sbin/stop-node.sh => client-py/pyproject.toml | 46 +-
client-py/readme.md | 80 ----
.../requirements.txt | 6 +-
.../requirements_dev.txt | 8 +-
client-py/{pypi => }/setup.py | 18 +-
client-py/src/SessionExample.py | 115 -----
client-py/src/SessionTest.py | 158 -------
client-py/{src/iotdb => tests}/__init__.py | 1 -
.../tests/test_dataframe.py | 39 +-
cluster/pom.xml | 2 +-
.../resources/conf/iotdb-cluster.properties | 17 +-
.../java/org/apache/iotdb/cluster/ClusterMain.java | 7 +
.../cluster/client/async/AsyncClientPool.java | 10 +-
.../cluster/client/sync/SyncClientAdaptor.java | 17 +
.../iotdb/cluster/client/sync/SyncClientPool.java | 10 +-
.../apache/iotdb/cluster/config/ClusterConfig.java | 36 ++
.../iotdb/cluster/config/ClusterDescriptor.java | 22 +
.../iotdb/cluster/coordinator/Coordinator.java | 28 +-
.../java/org/apache/iotdb/cluster/log/Log.java | 10 +
.../apache/iotdb/cluster/log/LogDispatcher.java | 8 +-
.../cluster/log/manage/CommittedEntryManager.java | 34 ++
.../iotdb/cluster/log/manage/RaftLogManager.java | 37 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 69 +--
.../apache/iotdb/cluster/metadata/MetaPuller.java | 3 +-
.../cluster/query/ClusterDataQueryExecutor.java | 215 ++++++++-
.../cluster/query/ClusterPhysicalGenerator.java | 20 +-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 90 ++++
.../iotdb/cluster/query/LocalQueryExecutor.java | 158 ++++++-
.../iotdb/cluster/query/RemoteQueryContext.java | 4 +
.../query/aggregate/ClusterAggregateExecutor.java | 2 +-
.../groupby/ClusterGroupByVFilterDataSet.java | 6 +-
.../cluster/query/reader/ClusterReaderFactory.java | 329 +++++++++++++-
.../cluster/query/reader/ClusterTimeGenerator.java | 147 ++++++-
.../iotdb/cluster/query/reader/EmptyReader.java | 3 +-
.../cluster/query/reader/MergedReaderByTime.java | 8 +-
.../reader/RemoteSeriesReaderByTimestamp.java | 40 +-
.../query/reader/mult/AbstractMultPointReader.java | 70 +++
.../AssignPathManagedMergeReader.java} | 12 +-
.../reader/mult/AssignPathPriorityMergeReader.java | 66 +++
.../query/reader/mult/IMultBatchReader.java | 11 +-
.../cluster/query/reader/mult/MultBatchReader.java | 73 ++++
.../MultDataSourceInfo.java} | 114 ++---
.../cluster/query/reader/mult/MultEmptyReader.java | 30 +-
.../reader/mult/MultSeriesRawDataPointReader.java | 55 +++
.../query/reader/mult/RemoteMultSeriesReader.java | 222 ++++++++++
.../apache/iotdb/cluster/server/ClientServer.java | 6 +-
.../iotdb/cluster/server/DataClusterServer.java | 63 ++-
...dler.java => GetChildNodeNextLevelHandler.java} | 9 +-
.../cluster/server/member/MetaGroupMember.java | 53 ++-
.../iotdb/cluster/server/member/RaftMember.java | 11 +-
.../cluster/server/service/DataAsyncService.java | 129 ++++--
.../cluster/server/service/DataSyncService.java | 138 ++++--
.../cluster/client/DataClientProviderTest.java | 48 ++-
.../cluster/client/sync/SyncClientAdaptorTest.java | 9 +
.../iotdb/cluster/common/TestAsyncDataClient.java | 48 ++-
.../cluster/common/TestManagedSeriesReader.java | 23 +-
.../org/apache/iotdb/cluster/common/TestUtils.java | 1 +
.../cluster/log/manage/RaftLogManagerTest.java | 35 ++
.../apache/iotdb/cluster/query/BaseQueryTest.java | 4 +-
.../query/ClusterDataQueryExecutorTest.java | 83 ++++
.../query/groupby/RemoteGroupByExecutorTest.java | 4 +-
.../query/manage/ClusterQueryManagerTest.java | 2 +-
.../query/reader/ClusterTimeGeneratorTest.java | 2 +-
.../reader/RemoteSeriesReaderByTimestampTest.java | 68 +--
.../mult/AssignPathManagedMergeReaderTest.java | 190 ++++++++
.../mult/MultSeriesRawDataPointReaderTest.java | 67 +++
.../reader/mult/RemoteMultSeriesReaderTest.java | 286 ++++++++++++
.../member/{MemberTest.java => BaseMember.java} | 210 +--------
.../cluster/server/member/DataGroupMemberTest.java | 96 ++++-
.../cluster/server/member/MetaGroupMemberTest.java | 43 +-
.../cluster/server/member/RaftMemberTest.java | 244 +++++++++++
.../tests/tools/importCsv/AbstractScript.java | 4 +-
.../tests/tools/importCsv/ExportCsvTestIT.java | 36 +-
.../tests/tools/importCsv/ImportCsvTestIT.java | 79 ++--
distribution/pom.xml | 2 +-
distribution/src/assembly/all.xml | 2 +-
distribution/src/assembly/cluster.xml | 2 +-
docs/SystemDesign/StorageEngine/WAL.md | 6 +-
docs/SystemDesign/TsFile/Format.md | 2 +-
.../UserGuide/Ecosystem Integration/Flink IoTDB.md | 67 ++-
.../Ecosystem Integration/Flink TsFile.md | 17 +-
docs/UserGuide/Operation Manual/Kill Query.md | 2 +-
.../Operation Manual/UDF User Defined Function.md | 2 +-
docs/UserGuide/Server/Cluster Setup.md | 8 +-
docs/UserGuide/Server/Config Manual.md | 2 +-
docs/UserGuide/System Tools/CSV Tool.md | 98 ++++-
docs/zh/SystemDesign/StorageEngine/FileLists.md | 2 +-
docs/zh/SystemDesign/StorageEngine/WAL.md | 7 +-
docs/zh/SystemDesign/TsFile/Format.md | 2 +-
docs/zh/SystemDesign/TsFile/Read.md | 10 +-
.../UserGuide/Ecosystem Integration/Flink IoTDB.md | 122 ++++++
.../Ecosystem Integration/Flink TsFile.md | 38 +-
docs/zh/UserGuide/Operation Manual/Kill Query.md | 2 +-
.../Operation Manual/UDF User Defined Function.md | 2 +-
docs/zh/UserGuide/Server/Cluster Setup.md | 8 +-
docs/zh/UserGuide/Server/Config Manual.md | 2 +-
docs/zh/UserGuide/System Tools/CSV Tool.md | 96 ++++-
example/client-cpp-example/README.md | 2 +-
example/client-cpp-example/src/SessionExample.cpp | 329 +++++++-------
.../main/java/org/apache/iotdb/SessionExample.java | 102 ++++-
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 3 +-
hive-connector/pom.xml | 12 +-
.../main/java/org/apache/iotdb/jdbc/Config.java | 12 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 4 +-
.../apache/iotdb/jdbc/IoTDBConnectionParams.java | 22 +-
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 11 +-
pom.xml | 24 +-
server/file-changelists/conf-changelist.md | 7 +
.../resources/conf/iotdb-engine.properties | 5 +-
server/src/assembly/resources/conf/logback.xml | 144 +++----
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 38 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 8 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 14 +-
.../apache/iotdb/db/cost/statistic/Operation.java | 1 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 4 +-
.../apache/iotdb/db/engine/cache/ChunkCache.java | 6 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 15 +-
.../db/engine/compaction/TsFileManagement.java | 36 +-
.../level/LevelCompactionTsFileManagement.java | 95 +++-
.../no/NoCompactionTsFileManagement.java | 180 ++++++--
.../engine/compaction/utils/CompactionUtils.java | 5 +-
.../apache/iotdb/db/engine/flush/FlushManager.java | 5 +-
.../db/engine/merge/manage/MergeResource.java | 27 ++
.../iotdb/db/engine/merge/task/MergeFileTask.java | 59 ++-
.../db/engine/merge/task/MergeMultiChunkTask.java | 5 +-
.../iotdb/db/engine/modification/Deletion.java | 16 +
.../engine/storagegroup/StorageGroupProcessor.java | 26 +-
.../db/engine/storagegroup/TsFileProcessor.java | 10 +
.../db/engine/storagegroup/TsFileResource.java | 160 ++++++-
.../storagegroup/timeindex/DeviceTimeIndex.java | 29 +-
.../storagegroup/timeindex/FileTimeIndex.java | 12 +
.../engine/storagegroup/timeindex/ITimeIndex.java | 16 +
.../org/apache/iotdb/db/metadata/mnode/MNode.java | 31 ++
.../org/apache/iotdb/db/monitor/StatMonitor.java | 2 +
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 9 +
.../org/apache/iotdb/db/qp/logical/Operator.java | 11 +
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 10 +
.../iotdb/db/qp/physical/crud/AggregationPlan.java | 32 ++
.../iotdb/db/qp/physical/crud/FillQueryPlan.java | 9 +
.../db/qp/physical/crud/InsertMultiTabletPlan.java | 3 +
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 3 +
.../db/qp/physical/crud/InsertTabletPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/QueryPlan.java | 28 +-
.../apache/iotdb/db/qp/physical/crud/UDTFPlan.java | 8 +
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 20 +
.../apache/iotdb/db/qp/sql/IoTDBSqlVisitor.java | 6 +-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 480 ++++++++++-----------
.../db/query/aggregation/AggregateResult.java | 4 +
.../db/query/aggregation/impl/AvgAggrResult.java | 25 +-
.../db/query/aggregation/impl/CountAggrResult.java | 18 +-
.../aggregation/impl/FirstValueAggrResult.java | 26 +-
.../aggregation/impl/FirstValueDescAggrResult.java | 20 +-
.../aggregation/impl/LastValueAggrResult.java | 26 +-
.../aggregation/impl/LastValueDescAggrResult.java | 37 +-
.../query/aggregation/impl/MaxTimeAggrResult.java | 20 +-
.../aggregation/impl/MaxTimeDescAggrResult.java | 31 +-
.../query/aggregation/impl/MaxValueAggrResult.java | 18 +-
.../query/aggregation/impl/MinTimeAggrResult.java | 24 +-
.../aggregation/impl/MinTimeDescAggrResult.java | 17 +-
.../query/aggregation/impl/MinValueAggrResult.java | 18 +-
.../db/query/aggregation/impl/SumAggrResult.java | 15 +-
.../iotdb/db/query/context/QueryContext.java | 11 +
.../db/query/control/QueryResourceManager.java | 9 +
.../iotdb/db/query/control/QueryTimeManager.java | 2 +-
.../iotdb/db/query/control/TracingManager.java | 27 +-
.../db/query/dataset/AlignByDeviceDataSet.java | 11 +
.../dataset/RawQueryDataSetWithValueFilter.java | 172 +++++---
.../dataset/RawQueryDataSetWithoutValueFilter.java | 11 +
.../db/query/dataset/ShowTimeSeriesResult.java | 2 +-
.../groupby/GroupByWithValueFilterDataSet.java | 9 +-
.../db/query/executor/AggregationExecutor.java | 89 ++--
.../iotdb/db/query/executor/LastQueryExecutor.java | 16 +
.../db/query/executor/RawDataQueryExecutor.java | 34 +-
.../iotdb/db/query/executor/UDTFQueryExecutor.java | 6 +-
.../adapter/ByTimestampReaderAdapter.java | 48 ++-
.../db/query/reader/chunk/DiskChunkLoader.java | 9 +-
.../reader/chunk/DiskChunkReaderByTimestamp.java | 55 +--
.../chunk/metadata/DiskChunkMetadataLoader.java | 27 +-
.../db/query/reader/series/IReaderByTimestamp.java | 2 +-
.../reader/series/SeriesReaderByTimestamp.java | 17 +-
.../universal/CachedPriorityMergeReader.java | 3 +-
.../reader/universal/DescPriorityMergeReader.java | 4 +-
.../iotdb/db/query/reader/universal/Element.java | 72 ++++
.../reader/universal/PriorityMergeReader.java | 39 +-
.../query/timegenerator/ServerTimeGenerator.java | 5 +-
.../apache/iotdb/db/query/udf/api/access/Row.java | 7 +
.../iotdb/db/query/udf/core/access/RowImpl.java | 5 +
.../org/apache/iotdb/db/rescon/SystemInfo.java | 56 +--
.../org/apache/iotdb/db/service/TSServiceImpl.java | 327 +++++++++++---
.../iotdb/db/sync/sender/transfer/SyncClient.java | 4 +-
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 15 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 3 +-
.../org/apache/iotdb/db/utils/FilePathUtils.java | 2 +-
.../db/engine/compaction/CompactionChunkTest.java | 4 +
.../compaction/LevelCompactionMoreDataTest.java | 6 +
.../compaction/LevelCompactionRecoverTest.java | 12 +
.../db/engine/compaction/LevelCompactionTest.java | 10 +-
.../LevelCompactionTsFileManagementTest.java | 8 +
.../NoCompactionTsFileManagementTest.java | 8 +
.../engine/merge/MaxFileMergeFileSelectorTest.java | 53 ++-
.../iotdb/db/engine/merge/MergeOverLapTest.java | 6 +
.../iotdb/db/engine/merge/MergeTaskTest.java | 56 +++
.../apache/iotdb/db/engine/merge/MergeTest.java | 8 +
.../integration/IOTDBGroupByInnerIntervalIT.java | 135 +++---
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 3 +-
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 24 +-
.../iotdb/db/integration/IoTDBExecuteBatchIT.java | 118 +++++
...IoTDBLoadExternalTsfileWithTimePartitionIT.java | 192 +++++++++
.../db/integration/IoTDBNewTsFileCompactionIT.java | 2 +-
.../iotdb/db/integration/IoTDBQueryDemoIT.java | 8 +-
.../db/integration/IoTDBRemovePartitionIT.java | 11 +
.../aggregation/IoTDBAggregationIT.java | 137 +++---
.../apache/iotdb/db/metadata/mnode/MNodeTest.java | 27 ++
.../iotdb/db/monitor/IoTDBStatMonitorTest.java | 6 +-
.../iotdb/db/query/control/TracingManagerTest.java | 3 +
.../reader/series/SeriesReaderByTimestampTest.java | 12 +-
server/src/test/resources/logback.xml | 8 +-
.../org/apache/iotdb/rpc/RedirectException.java | 3 +-
.../org/apache/iotdb/rpc/RpcTransportFactory.java | 14 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 10 +-
.../rpc/TCompressedElasticFramedTransport.java | 12 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 71 ++-
.../iotdb/rpc/TSnappyElasticFramedTransport.java | 21 +-
.../rpc/TimeoutChangeableTFastFramedTransport.java | 13 +-
.../java/org/apache/iotdb/session/Session.java | 115 ++++-
.../apache/iotdb/session/SessionConnection.java | 36 +-
site/src/main/.vuepress/config.js | 8 +-
thrift-cluster/src/main/thrift/cluster.thrift | 36 +-
thrift/src/main/thrift/rpc.thrift | 3 +
.../iotdb/tsfile/common/conf/TSFileConfig.java | 2 +-
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 4 +-
.../tsfile/file/metadata/TimeseriesMetadata.java | 25 ++
.../file/metadata/enums/CompressionType.java | 24 +-
.../file/metadata/enums/MetadataIndexNodeType.java | 17 +-
.../tsfile/file/metadata/enums/TSDataType.java | 21 +-
.../tsfile/file/metadata/enums/TSEncoding.java | 27 +-
.../tsfile/fileSystem/fsFactory/FSFactory.java | 8 +
.../tsfile/fileSystem/fsFactory/HDFSFactory.java | 5 +
.../fileSystem/fsFactory/LocalFSFactory.java | 6 +
.../iotdb/tsfile/read/TsFileSequenceReader.java | 17 +-
.../query/dataset/DataSetWithTimeGenerator.java | 2 +-
.../tsfile/read/query/dataset/QueryDataSet.java | 53 +++
.../read/query/timegenerator/TimeGenerator.java | 52 ++-
.../read/query/timegenerator/node/AndNode.java | 18 +-
.../read/query/timegenerator/node/OrNode.java | 42 +-
.../apache/iotdb/tsfile/write/schema/Schema.java | 2 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 4 +-
...easurementChunkMetadataListMapIteratorTest.java | 65 ++-
.../tsfile/read/reader/FakedTimeGenerator.java | 15 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 5 +-
.../zeppelin/iotdb/IoTDBInterpreterTest.java | 2 +-
279 files changed, 8621 insertions(+), 2981 deletions(-)
copy .github/workflows/{main-unix.yml => client-go.yml} (57%)
create mode 100644 .gitmodules
create mode 160000 client-go
copy .asf.yaml => client-py/.flake8 (72%)
create mode 100644 client-py/.gitignore
create mode 100644 client-py/README.md
create mode 100644 client-py/SessionExample.py
create mode 100644 client-py/SessionTest.py
create mode 100644 client-py/iotdb/IoTDBContainer.py
rename client-py/{src => }/iotdb/Session.py (69%)
copy client-py/{src => }/iotdb/__init__.py (99%)
rename client-py/{src => }/iotdb/utils/Field.py (96%)
rename client-py/{src => }/iotdb/utils/IoTDBConstants.py (100%)
rename client-py/{src => }/iotdb/utils/IoTDBRpcDataSet.py (78%)
rename client-py/{src => }/iotdb/utils/RowRecord.py (95%)
rename client-py/{src => }/iotdb/utils/SessionDataSet.py (56%)
rename client-py/{src => }/iotdb/utils/Tablet.py (95%)
rename client-py/{src => }/iotdb/utils/__init__.py (99%)
delete mode 100644 client-py/pypi/README.md
copy cluster/src/assembly/resources/sbin/stop-node.sh =>
client-py/pyproject.toml (61%)
delete mode 100644 client-py/readme.md
copy
server/src/main/resources/META-INF/services/org.apache.iotdb.db.mqtt.PayloadFormatter
=> client-py/requirements.txt (92%)
copy
server/src/main/resources/META-INF/services/org.apache.iotdb.db.mqtt.PayloadFormatter
=> client-py/requirements_dev.txt (88%)
rename client-py/{pypi => }/setup.py (82%)
delete mode 100644 client-py/src/SessionExample.py
delete mode 100644 client-py/src/SessionTest.py
rename client-py/{src/iotdb => tests}/__init__.py (99%)
copy cluster/src/assembly/resources/sbin/nodetool.sh =>
client-py/tests/test_dataframe.py (52%)
mode change 100755 => 100644
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/AbstractMultPointReader.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/{ManagedMergeReader.java
=> mult/AssignPathManagedMergeReader.java} (88%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathPriorityMergeReader.java
copy
tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/IBatchReader.java =>
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/IMultBatchReader.java
(75%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultBatchReader.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/{DataSourceInfo.java
=> mult/MultDataSourceInfo.java} (70%)
copy
server/src/main/java/org/apache/iotdb/db/query/externalsort/serialize/IExternalSortFileDeserializer.java
=>
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultEmptyReader.java
(60%)
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/MultSeriesRawDataPointReader.java
create mode 100644
cluster/src/main/java/org/apache/iotdb/cluster/query/reader/mult/RemoteMultSeriesReader.java
copy
cluster/src/main/java/org/apache/iotdb/cluster/server/handlers/caller/{GetChildNodeNextLevelPathHandler.java
=> GetChildNodeNextLevelHandler.java} (80%)
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/AssignPathManagedMergeReaderTest.java
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/MultSeriesRawDataPointReaderTest.java
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/query/reader/mult/RemoteMultSeriesReaderTest.java
rename
cluster/src/test/java/org/apache/iotdb/cluster/server/member/{MemberTest.java
=> BaseMember.java} (59%)
create mode 100644
cluster/src/test/java/org/apache/iotdb/cluster/server/member/RaftMemberTest.java
copy example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSink.java =>
docs/UserGuide/Ecosystem Integration/Flink IoTDB.md (59%)
copy flink-tsfile-connector/README.md => docs/UserGuide/Ecosystem
Integration/Flink TsFile.md (97%)
create mode 100644 docs/zh/UserGuide/Ecosystem Integration/Flink IoTDB.md
copy flink-tsfile-connector/README.md => docs/zh/UserGuide/Ecosystem
Integration/Flink TsFile.md (86%)
create mode 100644
server/src/main/java/org/apache/iotdb/db/query/reader/universal/Element.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBLoadExternalTsfileWithTimePartitionIT.java
