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 064cbe6 Merge branch 'cluster_new' of
https://github.com/apache/incubator-iotdb into cluster_new
add 24476a9 add pulications
add 713f6fa add link for IoTDB distributed framework
add 40ae1e9 Cheery pick changes from cluster_new (#901)
add 91daeab Merge remote-tracking branch 'origin/master'
add 1cb650f add text support for grafana (#906)
add f9fd91f [IOTDB-538]add a simple connection pool for session api (#880)
add 8681bb2 fix execute flush command while inserting bug (#916)
add a3646a3 [IOTDB-500] Let timeColumn and batchData store time in the
same struct (#913)
add 94d95f4 Fix Write Image (#915)
add a92b80c Fix bugs of add duplicated metadata (#918)
add 5a9b84f Fix empty ChunkMetadata in LAST query gives wrong answer bug
(#920)
add f94d326 Fix bugs of deleting sg and initing from mlog (#921)
add 9d90f79 add checkout a released branch in readme
add 7dcef6f fix recover deadlock (#927)
add a5cfb37 avoid flushing empty memtable (#926)
add 03fbb9e add write process error code (#928)
add 99310d4 add merge doc (#852)
add 3040a4d Merge branch 'master' into cluster_new
No new revisions were added by this update.
Summary of changes:
README.md | 7 +
.../SystemDesign/1-TsFile/3-Write.md | 4 +-
.../SystemDesign/4-StorageEngine/4-MergeManager.md | 88 ++-
.../UserGuide/0-Get Started/3-Publication.md | 3 +-
.../4-Client/2-Programming - Native API.md | 19 +-
.../UserGuide/0-Get Started/3-Publication.md | 2 +
.../4-Client/2-Programming - Native API.md | 25 +-
.../main/java/org/apache/iotdb/SessionExample.java | 1 +
.../apache/iotdb/web/grafana/bean/TimeValues.java | 6 +-
.../controller/DatabaseConnectController.java | 2 +-
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 17 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 23 +-
.../iotdb/db/engine/flush/TsFileFlushPolicy.java | 2 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 13 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 5 +-
.../engine/storagegroup/StorageGroupProcessor.java | 145 +++--
.../db/engine/storagegroup/TsFileProcessor.java | 53 +-
.../apache/iotdb/db/exception/IoTDBException.java | 5 +
.../iotdb/db/exception/StorageEngineException.java | 4 +
.../iotdb/db/exception/WriteProcessException.java | 12 +-
.../db/exception/query/OutOfTTLException.java | 3 +-
.../org/apache/iotdb/db/metadata/MManager.java | 53 +-
.../java/org/apache/iotdb/db/metadata/MTree.java | 3 +
.../org/apache/iotdb/db/monitor/StatMonitor.java | 3 +-
.../groupby/GroupByWithoutValueFilterDataSet.java | 1 -
.../iotdb/db/query/executor/LastQueryExecutor.java | 21 +-
.../db/sync/receiver/transfer/SyncServiceImpl.java | 16 +-
.../db/sync/sender/manage/SyncFileManager.java | 10 -
.../iotdb/db/sync/sender/transfer/SyncClient.java | 9 +-
.../org/apache/iotdb/db/utils/FileLoaderUtils.java | 1 +
.../iotdb/db/writelog/recover/LogReplayer.java | 8 +-
.../db/engine/cache/DeviceMetaDataCacheTest.java | 12 +-
.../storagegroup/FileNodeManagerBenchmark.java | 3 +-
.../storagegroup/StorageGroupProcessorTest.java | 37 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 21 +-
.../engine/storagegroup/TsFileProcessorTest.java | 10 +-
.../apache/iotdb/db/integration/IoTDBLastIT.java | 56 ++
.../apache/iotdb/db/integration/IoTDBTtlIT.java | 2 +-
.../org/apache/iotdb/db/metadata/MTreeTest.java | 2 +-
.../iotdb/db/query/reader/ReaderTestHelper.java | 7 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 9 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
service-rpc/src/main/thrift/sync.thrift | 23 +-
.../org/apache/iotdb/session/SessionDataSet.java | 10 +-
.../iotdb/session/pool/SessionDataSetWrapper.java | 81 +++
.../org/apache/iotdb/session/pool/SessionPool.java | 669 +++++++++++++++++++++
.../apache/iotdb/session/pool/SessionPoolTest.java | 236 ++++++++
.../iotdb/tsfile/common/conf/TSFileConfig.java | 4 +-
.../apache/iotdb/tsfile/read/common/BatchData.java | 139 +++--
.../iotdb/tsfile/read/common/TimeColumn.java | 89 ++-
.../read/query/timegenerator/node/AndNode.java | 2 +-
.../read/query/timegenerator/node/OrNode.java | 2 +-
52 files changed, 1618 insertions(+), 361 deletions(-)
create mode 100644
session/src/main/java/org/apache/iotdb/session/pool/SessionDataSetWrapper.java
create mode 100644
session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java
create mode 100644
session/src/test/java/org/apache/iotdb/session/pool/SessionPoolTest.java
