This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch active_flush
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from d8347ab fix insertTabletPlan count
add 4466180 fix timeseries metadata cache return null bug (#1280)
add 4e7be1c [IOTDB-615] Use binary rather than string in insert plan
(#1229)
add 6b36fd5 fix infer type test
No new revisions were added by this update.
Summary of changes:
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 1 +
.../java/org/apache/iotdb/rocketmq/Constant.java | 40 +--
.../apache/iotdb/rocketmq/RocketMQConsumer.java | 79 ++++--
.../main/java/org/apache/iotdb/SessionExample.java | 43 ++-
.../java/org/apache/iotdb/SessionPoolExample.java | 17 +-
.../iotdb/flink/DefaultIoTSerializationSchema.java | 144 ++++++----
.../main/java/org/apache/iotdb/flink/Event.java | 67 +++--
.../java/org/apache/iotdb/flink/IoTDBSink.java | 282 +++++++++----------
.../flink/DefaultIoTSerializationSchemaTest.java | 11 +-
.../iotdb/flink/IoTDBSinkBatchInsertTest.java | 157 ++++++-----
.../iotdb/flink/IoTDBSinkBatchTimerTest.java | 80 +++---
.../apache/iotdb/flink/IoTDBSinkInsertTest.java | 68 ++---
.../db/engine/cache/TimeSeriesMetadataCache.java | 7 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 39 ++-
.../db/engine/storagegroup/TsFileProcessor.java | 2 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 75 +++++-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 207 ++++++++++++--
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 1 +
.../org/apache/iotdb/db/service/TSServiceImpl.java | 42 +--
.../org/apache/iotdb/db/utils/CommonUtils.java | 44 ++-
.../iotdb/db/engine/storagegroup/TTLTest.java | 32 ++-
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 11 +-
.../apache/iotdb/db/writelog/PerformanceTest.java | 5 +-
.../iotdb/db/writelog/WriteLogNodeManagerTest.java | 2 +
.../apache/iotdb/db/writelog/WriteLogNodeTest.java | 6 +
.../iotdb/db/writelog/io/LogWriterReaderTest.java | 5 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 19 +-
.../recover/RecoverResourceFromReaderTest.java | 19 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 7 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 26 +-
service-rpc/rpc-changelist.md | 5 +-
service-rpc/src/main/thrift/rpc.thrift | 4 +-
.../java/org/apache/iotdb/session/Session.java | 297 ++++++++++++++++-----
.../org/apache/iotdb/session/pool/SessionPool.java | 48 ++--
.../org/apache/iotdb/session/IoTDBSessionIT.java | 187 ++++++++++++-
.../iotdb/session/IoTDBSessionIteratorIT.java | 21 +-
.../apache/iotdb/session/pool/SessionPoolTest.java | 18 +-
.../java/org/apache/iotdb/tsfile/utils/Binary.java | 9 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 54 +++-
39 files changed, 1499 insertions(+), 682 deletions(-)
