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 2021/03/27 01:18:23 UTC
[iotdb] branch NewDoc updated (1469929 -> 3098f0a)
This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch NewDoc
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 1469929 Update Administration.md (#2923)
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 b9b6c49 merge master
add 3098f0a Merge branch 'NewDoc' of https://github.com/apache/iotdb into NewDoc
No new revisions were added by this update.
Summary of changes:
.gitignore | 2 +-
client-py/pypi/README.md | 21 +-
client-py/src/iotdb/Session.py | 13 +-
client-py/src/iotdb/TestContainer.py | 49 ++++
.../resources/conf/iotdb-cluster.properties | 2 +
.../apache/iotdb/cluster/config/ClusterConfig.java | 10 +
.../iotdb/cluster/config/ClusterDescriptor.java | 5 +
.../apache/iotdb/cluster/metadata/CMManager.java | 5 +-
.../cluster/query/ClusterDataQueryExecutor.java | 213 +++++++++++++-
.../iotdb/cluster/query/LocalQueryExecutor.java | 143 +++++++++
.../query/aggregate/ClusterAggregateExecutor.java | 2 +-
.../groupby/ClusterGroupByVFilterDataSet.java | 2 +-
.../cluster/query/reader/ClusterReaderFactory.java | 321 ++++++++++++++++++++-
.../cluster/query/reader/ClusterTimeGenerator.java | 145 +++++++++-
.../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 ++++++++++++++
.../iotdb/cluster/server/DataClusterServer.java | 37 +++
.../cluster/server/service/DataAsyncService.java | 108 +++++--
.../cluster/server/service/DataSyncService.java | 117 +++++---
.../iotdb/cluster/common/TestAsyncDataClient.java | 35 +++
.../query/ClusterDataQueryExecutorTest.java | 83 ++++++
.../query/reader/ClusterTimeGeneratorTest.java | 2 +-
.../mult/AssignPathManagedMergeReaderTest.java | 190 ++++++++++++
.../mult/MultSeriesRawDataPointReaderTest.java | 67 +++++
.../reader/mult/RemoteMultSeriesReaderTest.java | 286 ++++++++++++++++++
.../cluster/server/member/DataGroupMemberTest.java | 64 +++-
docs/SystemDesign/TsFile/Format.md | 2 +-
docs/UserGuide/System Tools/CSV Tool.md | 96 ++++--
docs/zh/SystemDesign/StorageEngine/FileLists.md | 2 +-
docs/zh/SystemDesign/TsFile/Format.md | 2 +-
.../{Flink Tsfile.md => Flink TsFile.md} | 0
docs/zh/UserGuide/System Tools/CSV Tool.md | 91 ++++--
.../main/java/org/apache/iotdb/SessionExample.java | 102 ++++++-
pom.xml | 2 +-
.../apache/iotdb/db/cost/statistic/Operation.java | 1 +
.../iotdb/db/qp/physical/crud/QueryPlan.java | 10 +
.../db/query/dataset/AlignByDeviceDataSet.java | 11 +
.../dataset/RawQueryDataSetWithoutValueFilter.java | 11 +
.../db/query/executor/RawDataQueryExecutor.java | 25 ++
.../universal/CachedPriorityMergeReader.java | 3 +-
.../reader/universal/DescPriorityMergeReader.java | 4 +-
.../iotdb/db/query/reader/universal/Element.java | 72 +++++
.../reader/universal/PriorityMergeReader.java | 39 +--
.../apache/iotdb/db/query/udf/api/access/Row.java | 7 +
.../iotdb/db/query/udf/core/access/RowImpl.java | 5 +
.../org/apache/iotdb/db/service/TSServiceImpl.java | 202 ++++++++++++-
.../iotdb/db/integration/IoTDBCheckConfigIT.java | 1 +
.../iotdb/db/integration/IoTDBExecuteBatchIT.java | 118 ++++++++
.../db/integration/IoTDBRemovePartitionIT.java | 10 +
server/src/test/resources/logback.xml | 8 +-
.../org/apache/iotdb/rpc/RedirectException.java | 3 +-
.../java/org/apache/iotdb/session/Session.java | 103 ++++++-
.../apache/iotdb/session/SessionConnection.java | 32 +-
site/src/main/.vuepress/config.js | 4 +-
thrift/src/main/thrift/cluster.thrift | 27 ++
thrift/src/main/thrift/rpc.thrift | 3 +
.../tsfile/read/query/dataset/QueryDataSet.java | 48 +++
64 files changed, 3313 insertions(+), 306 deletions(-)
create mode 100644 client-py/src/iotdb/TestContainer.py
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
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 docs/zh/UserGuide/Ecosystem Integration/{Flink Tsfile.md => Flink TsFile.md} (100%)
create mode 100644 server/src/main/java/org/apache/iotdb/db/query/reader/universal/Element.java