[IOTDB-615] Use binary rather than string in insert plan (#1229)
authorSilverNarcissus <151250176@smail.nju.edu.cn>
Thu, 28 May 2020 05:56:23 +0000 (13:56 +0800)
committerGitHub <noreply@github.com>
Thu, 28 May 2020 05:56:23 +0000 (13:56 +0800)
commit4e7be1c204acc47b362fe74b84f7e7b6d742e0b8
tree92f89bd0217823dcc94a1920ca862fe74f982bdd
parent4466180b15285c8950bb700ddea76ecc5efa9a02
[IOTDB-615] Use binary rather than string in insert plan (#1229)

* add insert object interface in session
38 files changed:
example/flink/src/main/java/org/apache/iotdb/flink/FlinkIoTDBSink.java
example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/Constant.java
example/rocketmq/src/main/java/org/apache/iotdb/rocketmq/RocketMQConsumer.java
example/session/src/main/java/org/apache/iotdb/SessionExample.java
example/session/src/main/java/org/apache/iotdb/SessionPoolExample.java
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/DefaultIoTSerializationSchema.java
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/Event.java
flink-iotdb-connector/src/main/java/org/apache/iotdb/flink/IoTDBSink.java
flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/DefaultIoTSerializationSchemaTest.java
flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchInsertTest.java
flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkBatchTimerTest.java
flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/IoTDBSinkInsertTest.java
server/src/main/java/org/apache/iotdb/db/engine/memtable/AbstractMemTable.java
server/src/main/java/org/apache/iotdb/db/engine/storagegroup/TsFileProcessor.java
server/src/main/java/org/apache/iotdb/db/qp/executor/PlanExecutor.java
server/src/main/java/org/apache/iotdb/db/qp/physical/crud/InsertPlan.java
server/src/main/java/org/apache/iotdb/db/qp/strategy/PhysicalGenerator.java
server/src/main/java/org/apache/iotdb/db/service/TSServiceImpl.java
server/src/main/java/org/apache/iotdb/db/utils/CommonUtils.java
server/src/test/java/org/apache/iotdb/db/engine/storagegroup/TTLTest.java
server/src/test/java/org/apache/iotdb/db/tools/WalCheckerTest.java
server/src/test/java/org/apache/iotdb/db/writelog/PerformanceTest.java
server/src/test/java/org/apache/iotdb/db/writelog/WriteLogNodeManagerTest.java
server/src/test/java/org/apache/iotdb/db/writelog/WriteLogNodeTest.java
server/src/test/java/org/apache/iotdb/db/writelog/io/LogWriterReaderTest.java
server/src/test/java/org/apache/iotdb/db/writelog/recover/LogReplayerTest.java
server/src/test/java/org/apache/iotdb/db/writelog/recover/RecoverResourceFromReaderTest.java
server/src/test/java/org/apache/iotdb/db/writelog/recover/SeqTsFileRecoverTest.java
server/src/test/java/org/apache/iotdb/db/writelog/recover/UnseqTsFileRecoverTest.java
service-rpc/rpc-changelist.md
service-rpc/src/main/thrift/rpc.thrift
session/src/main/java/org/apache/iotdb/session/Session.java
session/src/main/java/org/apache/iotdb/session/pool/SessionPool.java
session/src/test/java/org/apache/iotdb/session/IoTDBSessionIT.java
session/src/test/java/org/apache/iotdb/session/IoTDBSessionIteratorIT.java
session/src/test/java/org/apache/iotdb/session/pool/SessionPoolTest.java
tsfile/src/main/java/org/apache/iotdb/tsfile/utils/Binary.java
tsfile/src/main/java/org/apache/iotdb/tsfile/utils/ReadWriteIOUtils.java