This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch cluster_premerge
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 0e884f7 fix sonar issues
add 65f3d72 change the way to calculate chunkmetadata cache
add d705694 OOM
add da145fa [IOTDB-657] Update MQTT example document (#1180)
add 212ceac optimize contruct dataset values array logic
add 9465b89 add a judge null interface
add 004c25f change comments
add bd4b22e decrease cache size in query
add eb5e759 Add more JMX MBean
add 4d27c93 [IOTDB-667] add retry in session and jdbc.execute (#1194)
add e5ae854 Fix #1197
add 17502a5 show devices bug
add 298e9ad [IOTDB-664]Win -e option (#1195)
add 7385db7 print cache size log only when cache enabled
add b8da4ad Add SessionPoolExample
add b4f698d fix a class name error in flink (#1202)
add 1d5d893 Move MetadataIndexNodeType from entry to node
add 4e2ce58 add sessionpool example
add 76acdd5 Merge branch 'master' into cluster_premerge
No new revisions were added by this update.
Summary of changes:
cli/src/assembly/resources/sbin/start-cli.bat | 3 -
.../java/org/apache/iotdb/cli/AbstractCli.java | 43 +++---
cli/src/main/java/org/apache/iotdb/cli/WinCli.java | 19 ++-
.../org/apache/iotdb/cli/StartClientScriptIT.java | 3 +-
.../UserGuide/4-Client/1-Command Line Interface.md | 11 +-
.../4-Client/2-Programming - Native API.md | 4 +-
.../UserGuide/4-Client/1-Command Line Interface.md | 11 +-
.../4-Client/2-Programming - Native API.md | 4 +-
.../apache/iotdb/flink/FlinkTsFileBatchSink.java | 2 +-
.../apache/iotdb/flink/FlinkTsFileBatchSource.java | 2 +-
.../apache/iotdb/flink/FlinkTsFileStreamSink.java | 2 +-
.../iotdb/flink/FlinkTsFileStreamSource.java | 2 +-
.../java/org/apache/iotdb/flink/TsFileUtils.java | 103 +++++++++++++
.../java/org/apache/iotdb/flink/TsFlieUtils.java | 98 ------------
example/mqtt/README.md | 3 +-
.../main/java/org/apache/iotdb/SessionExample.java | 35 ++++-
.../java/org/apache/iotdb/SessionPoolExample.java | 114 ++++++++++++++
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 1 +
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 14 +-
.../resources/conf/iotdb-engine.properties | 2 +-
.../db/engine/cache/CacheHitRatioMonitor.java | 65 +++++++-
.../engine/cache/CacheHitRatioMonitorMXBean.java | 27 ++++
.../apache/iotdb/db/engine/cache/ChunkCache.java | 25 ++-
.../iotdb/db/engine/cache/ChunkMetadataCache.java | 43 ++++--
.../iotdb/db/engine/cache/LRULinkedHashMap.java | 31 +++-
.../db/engine/cache/TimeSeriesMetadataCache.java | 22 ++-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 92 ++++++-----
.../java/org/apache/iotdb/session/Session.java | 169 +++++++++++++++++++--
.../org/apache/iotdb/session/SessionDataSet.java | 25 ++-
.../iotdb/session/pool/SessionDataSetWrapper.java | 5 +
.../org/apache/iotdb/session/pool/SessionPool.java | 4 +-
.../iotdb/session/IoTDBSessionIteratorIT.java | 55 ++++++-
.../apache/iotdb/session/pool/SessionPoolTest.java | 44 +++---
.../file/metadata/MetadataIndexConstructor.java | 31 ++--
.../tsfile/file/metadata/MetadataIndexEntry.java | 32 +---
.../tsfile/file/metadata/MetadataIndexNode.java | 21 ++-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 48 +++---
.../file/metadata/MetadataIndexNodeTest.java | 14 +-
.../tsfile/file/metadata/utils/TestHelper.java | 5 +-
39 files changed, 901 insertions(+), 333 deletions(-)
create mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/TsFileUtils.java
delete mode 100644
example/flink/src/main/java/org/apache/iotdb/flink/TsFlieUtils.java
create mode 100644
example/session/src/main/java/org/apache/iotdb/SessionPoolExample.java
