You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2019/12/10 12:58:20 UTC
[incubator-iotdb] branch cluster_new updated (0beeb42 -> 6353d14)
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch cluster_new
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 0beeb42 fix apache header; add comments
add 5a7e57a add interfaces of querying single series
add 6353d14 Merge branch 'cluster_new' of github.com:apache/incubator-iotdb into cluster_new
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iotdb/cluster/ClientMain.java | 108 ++++++++++++++++++++-
...Exception.java => ReaderNotFoundException.java} | 8 +-
.../cluster/exception/RequestTimeOutException.java | 6 +-
.../cluster/query/ClusterDataQueryExecutor.java | 2 +-
.../iotdb/cluster/query/ClusterQueryExecutor.java | 2 +-
.../iotdb/cluster/query/ClusterQueryManager.java | 58 +++++++++++
.../iotdb/cluster/query/ClusterQueryParser.java | 1 +
.../iotdb/cluster/query/ClusterQueryRouter.java | 8 +-
.../iotdb/cluster/query/RemoteQueryContext.java | 25 +++--
.../cluster/query/RemoteSimpleSeriesReader.java | 101 +++++++++++++++++++
.../apache/iotdb/cluster/server/ClientServer.java | 9 ++
.../iotdb/cluster/server/DataClusterServer.java | 29 ++++++
.../server/handlers/caller/GenericHandler.java | 14 ++-
.../cluster/server/member/DataGroupMember.java | 94 ++++++++++++++++++
.../cluster/server/member/MetaGroupMember.java | 76 +++++++++++++++
.../apache/iotdb/cluster/utils/SerializeUtils.java | 106 ++++++++++++++++++++
.../org/apache/iotdb/db/service/TSServiceImpl.java | 6 +-
.../org/apache/iotdb/db/utils/TimeValuePair.java | 2 +
service-rpc/src/main/thrift/cluster.thrift | 25 +++++
.../iotdb/tsfile/read/filter/basic/Filter.java | 9 ++
.../reader/series/FileSeriesReaderWithFilter.java | 2 +-
21 files changed, 663 insertions(+), 28 deletions(-)
copy cluster/src/main/java/org/apache/iotdb/cluster/exception/{UnsupportedPlanException.java => ReaderNotFoundException.java} (78%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/ClusterQueryManager.java
copy server/src/main/java/org/apache/iotdb/db/query/executor/DataQueryExecutor.java => cluster/src/main/java/org/apache/iotdb/cluster/query/RemoteQueryContext.java (58%)
create mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/RemoteSimpleSeriesReader.java