[incubator-iotdb] branch cluster_read updated (b01ef72 -> 4fb3ef4)

[lt...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

lta pushed a change to branch cluster_read
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.


    from b01ef72  add reader processor
     new 5ce29a0  add task id
     new 2018529  add cached batch data
     new 38147ac  fix the future instance is replaced when the flush frequency is high (#145)
     new 3702c4c  add a log appender: put info, warn, error log into one file; disable log_info by default (#147)
     new 8e89b5d  small refactors in memcontrol (#144)
     new 4456629  FileNodeManager:  call the `Future#get()` returned from the merge thread  (#146)
     new 0fa0749  fix an unproperly initialized var (#148)
     new 4d5082b  update import/export script (#150)
     new 9c24e01  Merge branch 'master' into cluster_read
     new 5ca4849  remove rpc batch reader
     new b2bb8ea  fix sync thread bug (#151)
     new 80a7883  merge master
     new 4fb3ef4  complete code of no filter reader

The 1763 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../iotdb/cluster/config/ClusterConstant.java      |   8 +
 .../ClusterExecutorWithoutTimeGenerator.java       |   2 +-
 .../coordinatornode/ClusterRpcQueryManager.java    |  50 +++++-
 .../ClusterRpcSingleQueryManager.java              | 190 ++++++++++++++++-----
 .../IClusterRpcSingleQueryManager.java             |   8 +-
 .../querynode/ClusterLocalQueryManager.java        |  23 ++-
 .../querynode/ClusterLocalSingleQueryManager.java  |  95 +++++++++--
 .../query/reader/ClusterRpcBatchDataReader.java    |  99 -----------
 .../cluster/query/reader/ClusterSeriesReader.java  | 119 +++++++++++--
 .../querydata/QuerySeriesDataSyncProcessor.java    |  23 ++-
 .../request/querydata/QuerySeriesDataRequest.java  |  98 ++++++-----
 .../querydata/QuerySeriesDataResponse.java         |  44 ++---
 .../cluster/service/TSServiceClusterImpl.java      |   4 +-
 .../cluster/utils/query/ClusterRpcReaderUtils.java |  69 ++++----
 .../org/apache/iotdb/cli/tool/AbstractCsvTool.java |   3 +-
 .../java/org/apache/iotdb/cli/tool/ExportCsv.java  |   5 +-
 .../java/org/apache/iotdb/cli/tool/ImportCsv.java  |   7 +-
 iotdb/iotdb/conf/logback.xml                       |  22 ++-
 .../engine/bufferwrite/BufferWriteProcessor.java   |  49 ++++--
 .../iotdb/db/engine/filenode/FileNodeManager.java  |  23 ++-
 .../db/engine/filenode/FileNodeProcessor.java      |  16 ++
 .../iotdb/db/engine/filenode/TsFileResource.java   |   4 +
 .../db/engine/memcontrol/BasicMemController.java   |  24 ++-
 .../db/engine/memcontrol/JVMMemController.java     |   4 +-
 .../db/engine/memcontrol/RecordMemController.java  |  59 +++----
 .../db/engine/overflow/io/OverflowProcessor.java   |  65 ++++---
 .../java/org/apache/iotdb/db/service/IoTDB.java    |   7 +-
 .../IoTDBShutdownHook.java}                        |  19 ++-
 .../org/apache/iotdb/db/service/JDBCService.java   |   4 +-
 .../iotdb/db/service/JDBCServiceEventHandler.java  |   2 +-
 .../org/apache/iotdb/db/service/TSServiceImpl.java |   4 +-
 .../receiver/SyncServiceEventHandler.java}         |  39 ++---
 ...cServerManager.java => SyncServiceManager.java} |  69 ++++++--
 .../db/engine/memcontrol/MemControllerTest.java    |  18 +-
 34 files changed, 823 insertions(+), 452 deletions(-)
 delete mode 100644 cluster/src/main/java/org/apache/iotdb/cluster/query/reader/ClusterRpcBatchDataReader.java
 copy iotdb/src/main/java/org/apache/iotdb/db/{engine/memcontrol/NoActPolicy.java => service/IoTDBShutdownHook.java} (62%)
 copy iotdb/src/main/java/org/apache/iotdb/db/{service/JDBCServiceEventHandler.java => sync/receiver/SyncServiceEventHandler.java} (55%)
 rename iotdb/src/main/java/org/apache/iotdb/db/sync/receiver/{SyncServerManager.java => SyncServiceManager.java} (63%)