You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by qi...@apache.org on 2019/08/26 06:46:37 UTC
[incubator-iotdb] branch master updated (719e87e -> 6ce1f41)
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 719e87e Merge pull request #353 from yx-zhang/configMaxCon
add ceaa9b1 add batch rpc interface
add e31d4f5 fix write too many times bug
add f0fb8c2 merge master to resolve conflict
add 4281082 fix columns to rows
add f9a1ab8 add license and change private to public
add a098310 fix reviews
add 22bab90 add license in BatchInsertPlan
add eb0935f change data value list in rpc to bytes
add 32902bf add array-parametered interfaces
add 9a872e7 Merge remote-tracking branch 'origin/rpc_client' into rpc_client
add 965e72d change time-value in rpc to bytes
add 69f211f fix test bug
add e7ea34d rename Client to Cli and Session to Client
add 895c9ba fix when batch is not full, time serialize overflow buffer size bug
add c9d040c remove IoTDBDataType in rpc, use int32 instead
add 5b1a318 add session module and rename cli to client
add 0777569 fix windows echo cli to client
add ca45800 make session module depend on service-rpc instead of jdbc
add 553055d fix putsInts in IntTVList
add 6320a45 add license
add dd879eb fix IT test, IoTDBRPCException -> IoTDBSQLException, default user/password
add 7714ec4 fix session example caught exception
new 6ce1f41 Merge pull request #351 from apache/rpc_client
The 1 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:
README.md | 8 +-
RELEASE_NOTES.md | 4 +-
client/pom.xml | 1 -
.../src/assembly/resources/sbin/start-client.bat | 2 +-
client/src/assembly/resources/sbin/start-client.sh | 2 +-
client/src/assembly/resources/tools/export-csv.bat | 2 +-
client/src/assembly/resources/tools/export-csv.sh | 2 +-
client/src/assembly/resources/tools/import-csv.bat | 2 +-
client/src/assembly/resources/tools/import-csv.sh | 2 +-
.../iotdb/{cli => }/client/AbstractClient.java | 193 +++++++-------
.../org/apache/iotdb/{cli => }/client/Client.java | 7 +-
.../apache/iotdb/{cli => }/client/WinClient.java | 6 +-
.../{cli => }/exception/ArgsErrorException.java | 2 +-
.../iotdb/{cli => }/tool/AbstractCsvTool.java | 4 +-
.../org/apache/iotdb/{cli => }/tool/ExportCsv.java | 6 +-
.../org/apache/iotdb/{cli => }/tool/ImportCsv.java | 6 +-
.../iotdb/{cli => }/client/AbstractClientIT.java | 62 +++--
.../iotdb/{cli => }/client/AbstractScript.java | 2 +-
.../{cli => }/client/StartClientScriptIT.java | 2 +-
.../iotdb/{cli => }/tool/ExportCsvTestIT.java | 4 +-
.../iotdb/{cli => }/tool/ImportCsvTestIT.java | 4 +-
docs/Development.md | 4 +-
docs/Documentation-CHN/QuickStart.md | 6 +-
.../UserGuide/1-Overview/3-Scenario.md | 4 +-
.../UserGuide/7-Session API/1-Session API.md | 111 +++++++++
.../{7-TsFile => 8-TsFile}/1-Installation.md | 2 +-
.../UserGuide/{7-TsFile => 8-TsFile}/2-Usage.md | 2 +-
.../{7-TsFile => 8-TsFile}/3-Hierarchy.md | 2 +-
.../{8-System Tools => 9-System Tools}/1-Sync.md | 2 +-
.../2-Memory Estimation Tool.md | 2 +-
.../UserGuide/{8-Tools-Cli.md => 9-Tools-Cli.md} | 28 +--
.../{8-Tools-Grafana.md => 9-Tools-Grafana.md} | 0
.../{8-Tools-Hadoop.md => 9-Tools-Hadoop.md} | 0
.../{8-Tools-spark.md => 9-Tools-spark.md} | 0
docs/Documentation/Frequently asked questions.md | 14 +-
docs/Documentation/QuickStart.md | 14 +-
.../UserGuide/1-Overview/3-Scenario.md | 4 +-
.../UserGuide/3-Operation Manual/3-Data Import.md | 2 +-
.../4-Deployment and Management/1-Deployment.md | 4 +-
.../7-Build and use IoTDB by Dockerfile.md | 6 +-
.../UserGuide/6-JDBC API/1-JDBC API.md | 4 +-
.../UserGuide/7-Session API/1-Session API.md | 121 +++++++++
.../{7-TsFile => 8-TsFile}/1-Installation.md | 2 +-
.../UserGuide/{7-TsFile => 8-TsFile}/2-Usage.md | 12 +-
.../{7-TsFile => 8-TsFile}/3-Hierarchy.md | 2 +-
.../{8-System Tools => 9-System Tools}/1-Sync.md | 2 +-
.../2-Memory Estimation Tool.md | 2 +-
.../UserGuide/{8-Tools-Cli.md => 9-Tools-Cli.md} | 22 +-
.../{8-Tools-Grafana.md => 9-Tools-Grafana.md} | 0
.../{8-Tools-Hadoop.md => 9-Tools-Hadoop.md} | 0
.../{8-Tools-spark.md => 9-Tools-spark.md} | 0
example/pom.xml | 1 +
.../iotdb/{example => rocketmq}/Constant.java | 2 +-
.../{example => rocketmq}/RocketMQConsumer.java | 2 +-
.../{example => rocketmq}/RocketMQProducer.java | 2 +-
.../apache/iotdb/{example => rocketmq}/Utils.java | 2 +-
example/{tsfile => session}/pom.xml | 17 +-
.../main/java/org/apache/iotdb/JDBCExample.java | 43 ++--
.../main/java/org/apache/iotdb/SessionExample.java | 88 +++++++
.../iotdb/tsfile/TsFileWriteWithRowBatch.java | 11 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 83 ++-----
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 32 ++-
.../jdbc/IoTDBPreparedInsertionStatement.java | 2 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 1 +
.../org/apache/iotdb/jdbc/IoTDBQueryResultSet.java | 12 +-
.../org/apache/iotdb/jdbc/IoTDBSQLException.java | 4 +
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 24 +-
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 28 +--
.../apache/iotdb/jdbc/IoTDBQueryResultSetTest.java | 4 +-
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 12 +-
pom.xml | 1 +
.../org/apache/iotdb/db/sql/parse/TSParser.g | 2 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 2 +-
.../apache/iotdb/db/cost/statistic/Operation.java | 3 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 22 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 10 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 21 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 7 +-
.../db/engine/memtable/IWritableMemChunk.java | 15 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 86 ++++++-
.../engine/storagegroup/StorageGroupProcessor.java | 154 +++++++++---
.../db/engine/storagegroup/TsFileProcessor.java | 51 +++-
.../java/org/apache/iotdb/db/metadata/MGraph.java | 2 -
.../db/qp/executor/IQueryProcessExecutor.java | 7 +
.../iotdb/db/qp/executor/QueryProcessExecutor.java | 35 ++-
.../org/apache/iotdb/db/qp/logical/Operator.java | 2 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 7 +-
.../iotdb/db/qp/physical/crud/BatchInsertPlan.java | 276 +++++++++++++++++++++
.../iotdb/db/qp/strategy/LogicalGenerator.java | 4 -
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 6 -
.../org/apache/iotdb/db/rescon/MemTablePool.java | 1 +
.../java/org/apache/iotdb/db/service/IoTDB.java | 4 -
.../org/apache/iotdb/db/service/TSServiceImpl.java | 65 ++++-
.../org/apache/iotdb/db/utils/FileSchemaUtils.java | 14 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 30 ++-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 86 +++++++
.../iotdb/db/utils/datastructure/BinaryTVList.java | 31 +++
.../db/utils/datastructure/BooleanTVList.java | 31 +++
.../iotdb/db/utils/datastructure/DoubleTVList.java | 31 +++
.../iotdb/db/utils/datastructure/FloatTVList.java | 31 +++
.../iotdb/db/utils/datastructure/IntTVList.java | 31 +++
.../iotdb/db/utils/datastructure/LongTVList.java | 31 +++
.../iotdb/db/utils/datastructure/TVList.java | 38 +++
.../iotdb/db/writelog/recover/LogReplayer.java | 12 +-
.../writelog/recover/TsFileRecoverPerformer.java | 14 +-
.../db/cost/statistic/PerformanceStatTest.java | 2 +-
.../db/engine/memtable/MemTableFlushTaskTest.java | 2 +-
.../db/engine/memtable/MemTableTestUtils.java | 10 +-
.../storagegroup/StorageGroupProcessorTest.java | 59 ++++-
.../iotdb/db/integration/IoTDBAggregationIT.java | 8 +-
.../apache/iotdb/db/qp/utils/MemIntQpExecutor.java | 6 +
.../iotdb/db/writelog/recover/LogReplayerTest.java | 4 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 6 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 6 +-
.../org/apache/iotdb/rpc/IoTDBRPCException.java | 15 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 35 ++-
.../org/apache/iotdb/rpc/SynchronizedHandler.java | 54 ++++
service-rpc/src/main/thrift/rpc.thrift | 24 +-
{hadoop => session}/pom.xml | 36 ++-
.../main/java/org/apache/iotdb/session/Config.java | 9 +-
.../iotdb/session/IoTDBSessionException.java | 18 +-
.../java/org/apache/iotdb/session/Session.java | 183 ++++++++++++++
.../org/apache/iotdb/session/SessionUtils.java | 90 +++++++
.../apache/iotdb/tsfile/io/TsFileOutputFormat.java | 10 +-
.../apache/iotdb/tsfile/io/TsFileRecordWriter.java | 6 +-
.../scala/org/apache/iotdb/tsfile/Converter.scala | 4 +-
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 14 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 16 +-
.../apache/iotdb/tsfile/write/record/RowBatch.java | 47 ++++
.../apache/iotdb/tsfile/write/record/TSRecord.java | 2 -
.../tsfile/write/schema/MeasurementSchema.java | 2 +-
.../write/schema/{FileSchema.java => Schema.java} | 35 +--
.../iotdb/tsfile/write/schema/SchemaBuilder.java | 18 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 6 +-
.../TsFileGeneratorForSeriesReaderByTimestamp.java | 11 +-
.../apache/iotdb/tsfile/utils/FileGenerator.java | 11 +-
.../org/apache/iotdb/tsfile/utils/RecordUtils.java | 4 +-
.../apache/iotdb/tsfile/utils/RecordUtilsTest.java | 27 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 6 +-
.../org/apache/iotdb/tsfile/write/PerfTest.java | 23 +-
.../iotdb/tsfile/write/ReadPageInMemTest.java | 21 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 8 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 10 +-
.../org/apache/iotdb/tsfile/write/WriteTest.java | 6 +-
.../write/schema/converter/SchemaBuilderTest.java | 6 +-
145 files changed, 2393 insertions(+), 697 deletions(-)
rename client/src/main/java/org/apache/iotdb/{cli => }/client/AbstractClient.java (81%)
rename client/src/main/java/org/apache/iotdb/{cli => }/client/Client.java (97%)
rename client/src/main/java/org/apache/iotdb/{cli => }/client/WinClient.java (97%)
rename client/src/main/java/org/apache/iotdb/{cli => }/exception/ArgsErrorException.java (96%)
rename client/src/main/java/org/apache/iotdb/{cli => }/tool/AbstractCsvTool.java (98%)
rename client/src/main/java/org/apache/iotdb/{cli => }/tool/ExportCsv.java (98%)
rename client/src/main/java/org/apache/iotdb/{cli => }/tool/ImportCsv.java (99%)
rename client/src/test/java/org/apache/iotdb/{cli => }/client/AbstractClientIT.java (74%)
rename client/src/test/java/org/apache/iotdb/{cli => }/client/AbstractScript.java (98%)
rename client/src/test/java/org/apache/iotdb/{cli => }/client/StartClientScriptIT.java (98%)
rename client/src/test/java/org/apache/iotdb/{cli => }/tool/ExportCsvTestIT.java (96%)
rename client/src/test/java/org/apache/iotdb/{cli => }/tool/ImportCsvTestIT.java (96%)
create mode 100644 docs/Documentation-CHN/UserGuide/7-Session API/1-Session API.md
rename docs/Documentation-CHN/UserGuide/{7-TsFile => 8-TsFile}/1-Installation.md (96%)
rename docs/Documentation-CHN/UserGuide/{7-TsFile => 8-TsFile}/2-Usage.md (96%)
rename docs/Documentation-CHN/UserGuide/{7-TsFile => 8-TsFile}/3-Hierarchy.md (96%)
rename docs/Documentation-CHN/UserGuide/{8-System Tools => 9-System Tools}/1-Sync.md (99%)
rename docs/Documentation-CHN/UserGuide/{8-System Tools => 9-System Tools}/2-Memory Estimation Tool.md (99%)
rename docs/Documentation-CHN/UserGuide/{8-Tools-Cli.md => 9-Tools-Cli.md} (76%)
rename docs/Documentation-CHN/UserGuide/{8-Tools-Grafana.md => 9-Tools-Grafana.md} (100%)
rename docs/Documentation-CHN/UserGuide/{8-Tools-Hadoop.md => 9-Tools-Hadoop.md} (100%)
rename docs/Documentation-CHN/UserGuide/{8-Tools-spark.md => 9-Tools-spark.md} (100%)
create mode 100644 docs/Documentation/UserGuide/7-Session API/1-Session API.md
rename docs/Documentation/UserGuide/{7-TsFile => 8-TsFile}/1-Installation.md (99%)
rename docs/Documentation/UserGuide/{7-TsFile => 8-TsFile}/2-Usage.md (98%)
rename docs/Documentation/UserGuide/{7-TsFile => 8-TsFile}/3-Hierarchy.md (99%)
rename docs/Documentation/UserGuide/{8-System Tools => 9-System Tools}/1-Sync.md (99%)
rename docs/Documentation/UserGuide/{8-System Tools => 9-System Tools}/2-Memory Estimation Tool.md (99%)
rename docs/Documentation/UserGuide/{8-Tools-Cli.md => 9-Tools-Cli.md} (80%)
rename docs/Documentation/UserGuide/{8-Tools-Grafana.md => 9-Tools-Grafana.md} (100%)
rename docs/Documentation/UserGuide/{8-Tools-Hadoop.md => 9-Tools-Hadoop.md} (100%)
rename docs/Documentation/UserGuide/{8-Tools-spark.md => 9-Tools-spark.md} (100%)
rename example/rocketmq/src/main/java/org/apache/iotdb/{example => rocketmq}/Constant.java (99%)
rename example/rocketmq/src/main/java/org/apache/iotdb/{example => rocketmq}/RocketMQConsumer.java (99%)
rename example/rocketmq/src/main/java/org/apache/iotdb/{example => rocketmq}/RocketMQProducer.java (98%)
rename example/rocketmq/src/main/java/org/apache/iotdb/{example => rocketmq}/Utils.java (97%)
copy example/{tsfile => session}/pom.xml (80%)
rename jdbc/src/test/java/org/apache/iotdb/jdbc/demo/StatementDemo.java => example/session/src/main/java/org/apache/iotdb/JDBCExample.java (53%)
create mode 100644 example/session/src/main/java/org/apache/iotdb/SessionExample.java
create mode 100644 server/src/main/java/org/apache/iotdb/db/qp/physical/crud/BatchInsertPlan.java
copy server/src/main/java/org/apache/iotdb/db/engine/flush/FlushManagerMBean.java => service-rpc/src/main/java/org/apache/iotdb/rpc/IoTDBRPCException.java (76%)
copy server/src/main/java/org/apache/iotdb/db/engine/memtable/TimeValuePairInMemTable.java => service-rpc/src/main/java/org/apache/iotdb/rpc/RpcUtils.java (52%)
create mode 100644 service-rpc/src/main/java/org/apache/iotdb/rpc/SynchronizedHandler.java
copy {hadoop => session}/pom.xml (65%)
copy server/src/main/java/org/apache/iotdb/db/rescon/TVListAllocatorMBean.java => session/src/main/java/org/apache/iotdb/session/Config.java (77%)
copy tsfile/src/main/java/org/apache/iotdb/tsfile/exception/filter/QueryFilterOptimizationException.java => session/src/main/java/org/apache/iotdb/session/IoTDBSessionException.java (69%)
create mode 100644 session/src/main/java/org/apache/iotdb/session/Session.java
create mode 100644 session/src/main/java/org/apache/iotdb/session/SessionUtils.java
rename tsfile/src/main/java/org/apache/iotdb/tsfile/write/schema/{FileSchema.java => Schema.java} (83%)
[incubator-iotdb] 01/01: Merge pull request #351 from
apache/rpc_client
Posted by qi...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git
commit 6ce1f4133a2c31279ccdd4488c6e670f3ecaaf1b
Merge: 719e87e 7714ec4
Author: Jialin Qiao <qj...@mails.tsinghua.edu.cn>
AuthorDate: Mon Aug 26 14:46:32 2019 +0800
Merge pull request #351 from apache/rpc_client
[IOTDB-173] add batch rpc interface
README.md | 8 +-
RELEASE_NOTES.md | 4 +-
client/pom.xml | 1 -
.../src/assembly/resources/sbin/start-client.bat | 2 +-
client/src/assembly/resources/sbin/start-client.sh | 2 +-
client/src/assembly/resources/tools/export-csv.bat | 2 +-
client/src/assembly/resources/tools/export-csv.sh | 2 +-
client/src/assembly/resources/tools/import-csv.bat | 2 +-
client/src/assembly/resources/tools/import-csv.sh | 2 +-
.../iotdb/{cli => }/client/AbstractClient.java | 193 +++++++-------
.../org/apache/iotdb/{cli => }/client/Client.java | 7 +-
.../apache/iotdb/{cli => }/client/WinClient.java | 6 +-
.../{cli => }/exception/ArgsErrorException.java | 2 +-
.../iotdb/{cli => }/tool/AbstractCsvTool.java | 4 +-
.../org/apache/iotdb/{cli => }/tool/ExportCsv.java | 6 +-
.../org/apache/iotdb/{cli => }/tool/ImportCsv.java | 6 +-
.../iotdb/{cli => }/client/AbstractClientIT.java | 62 +++--
.../iotdb/{cli => }/client/AbstractScript.java | 2 +-
.../{cli => }/client/StartClientScriptIT.java | 2 +-
.../iotdb/{cli => }/tool/ExportCsvTestIT.java | 4 +-
.../iotdb/{cli => }/tool/ImportCsvTestIT.java | 4 +-
docs/Development.md | 4 +-
docs/Documentation-CHN/QuickStart.md | 6 +-
.../UserGuide/1-Overview/3-Scenario.md | 4 +-
.../UserGuide/7-Session API/1-Session API.md | 111 +++++++++
.../{7-TsFile => 8-TsFile}/1-Installation.md | 2 +-
.../UserGuide/{7-TsFile => 8-TsFile}/2-Usage.md | 2 +-
.../{7-TsFile => 8-TsFile}/3-Hierarchy.md | 2 +-
.../{8-System Tools => 9-System Tools}/1-Sync.md | 2 +-
.../2-Memory Estimation Tool.md | 2 +-
.../UserGuide/{8-Tools-Cli.md => 9-Tools-Cli.md} | 28 +--
.../{8-Tools-Grafana.md => 9-Tools-Grafana.md} | 0
.../{8-Tools-Hadoop.md => 9-Tools-Hadoop.md} | 0
.../{8-Tools-spark.md => 9-Tools-spark.md} | 0
docs/Documentation/Frequently asked questions.md | 14 +-
docs/Documentation/QuickStart.md | 14 +-
.../UserGuide/1-Overview/3-Scenario.md | 4 +-
.../UserGuide/3-Operation Manual/3-Data Import.md | 2 +-
.../4-Deployment and Management/1-Deployment.md | 4 +-
.../7-Build and use IoTDB by Dockerfile.md | 6 +-
.../UserGuide/6-JDBC API/1-JDBC API.md | 4 +-
.../UserGuide/7-Session API/1-Session API.md | 121 +++++++++
.../{7-TsFile => 8-TsFile}/1-Installation.md | 2 +-
.../UserGuide/{7-TsFile => 8-TsFile}/2-Usage.md | 12 +-
.../{7-TsFile => 8-TsFile}/3-Hierarchy.md | 2 +-
.../{8-System Tools => 9-System Tools}/1-Sync.md | 2 +-
.../2-Memory Estimation Tool.md | 2 +-
.../UserGuide/{8-Tools-Cli.md => 9-Tools-Cli.md} | 22 +-
.../{8-Tools-Grafana.md => 9-Tools-Grafana.md} | 0
.../{8-Tools-Hadoop.md => 9-Tools-Hadoop.md} | 0
.../{8-Tools-spark.md => 9-Tools-spark.md} | 0
example/pom.xml | 1 +
.../iotdb/{example => rocketmq}/Constant.java | 2 +-
.../{example => rocketmq}/RocketMQConsumer.java | 2 +-
.../{example => rocketmq}/RocketMQProducer.java | 2 +-
.../apache/iotdb/{example => rocketmq}/Utils.java | 2 +-
example/session/pom.xml | 43 ++++
.../main/java/org/apache/iotdb/JDBCExample.java | 43 ++--
.../main/java/org/apache/iotdb/SessionExample.java | 88 +++++++
.../iotdb/tsfile/TsFileWriteWithRowBatch.java | 11 +-
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 83 ++-----
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 32 ++-
.../jdbc/IoTDBPreparedInsertionStatement.java | 2 +-
.../apache/iotdb/jdbc/IoTDBPreparedStatement.java | 1 +
.../org/apache/iotdb/jdbc/IoTDBQueryResultSet.java | 12 +-
.../org/apache/iotdb/jdbc/IoTDBSQLException.java | 4 +
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 24 +-
.../src/main/java/org/apache/iotdb/jdbc/Utils.java | 28 +--
.../apache/iotdb/jdbc/IoTDBQueryResultSetTest.java | 4 +-
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 12 +-
pom.xml | 1 +
.../org/apache/iotdb/db/sql/parse/TSParser.g | 2 +-
.../org/apache/iotdb/db/conf/IoTDBConstant.java | 2 +-
.../apache/iotdb/db/cost/statistic/Operation.java | 3 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 22 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 10 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 21 +-
.../apache/iotdb/db/engine/memtable/IMemTable.java | 7 +-
.../db/engine/memtable/IWritableMemChunk.java | 15 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 86 ++++++-
.../engine/storagegroup/StorageGroupProcessor.java | 154 +++++++++---
.../db/engine/storagegroup/TsFileProcessor.java | 51 +++-
.../java/org/apache/iotdb/db/metadata/MGraph.java | 2 -
.../db/qp/executor/IQueryProcessExecutor.java | 7 +
.../iotdb/db/qp/executor/QueryProcessExecutor.java | 35 ++-
.../org/apache/iotdb/db/qp/logical/Operator.java | 2 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 7 +-
.../iotdb/db/qp/physical/crud/BatchInsertPlan.java | 276 +++++++++++++++++++++
.../iotdb/db/qp/strategy/LogicalGenerator.java | 4 -
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 6 -
.../org/apache/iotdb/db/rescon/MemTablePool.java | 1 +
.../java/org/apache/iotdb/db/service/IoTDB.java | 4 -
.../org/apache/iotdb/db/service/TSServiceImpl.java | 65 ++++-
.../org/apache/iotdb/db/utils/FileSchemaUtils.java | 14 +-
.../java/org/apache/iotdb/db/utils/MemUtils.java | 30 ++-
.../apache/iotdb/db/utils/QueryDataSetUtils.java | 86 +++++++
.../iotdb/db/utils/datastructure/BinaryTVList.java | 31 +++
.../db/utils/datastructure/BooleanTVList.java | 31 +++
.../iotdb/db/utils/datastructure/DoubleTVList.java | 31 +++
.../iotdb/db/utils/datastructure/FloatTVList.java | 31 +++
.../iotdb/db/utils/datastructure/IntTVList.java | 31 +++
.../iotdb/db/utils/datastructure/LongTVList.java | 31 +++
.../iotdb/db/utils/datastructure/TVList.java | 38 +++
.../iotdb/db/writelog/recover/LogReplayer.java | 12 +-
.../writelog/recover/TsFileRecoverPerformer.java | 14 +-
.../db/cost/statistic/PerformanceStatTest.java | 2 +-
.../db/engine/memtable/MemTableFlushTaskTest.java | 2 +-
.../db/engine/memtable/MemTableTestUtils.java | 10 +-
.../storagegroup/StorageGroupProcessorTest.java | 59 ++++-
.../iotdb/db/integration/IoTDBAggregationIT.java | 8 +-
.../apache/iotdb/db/qp/utils/MemIntQpExecutor.java | 6 +
.../iotdb/db/writelog/recover/LogReplayerTest.java | 4 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 6 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 6 +-
.../org/apache/iotdb/rpc/IoTDBRPCException.java | 12 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 44 ++++
.../org/apache/iotdb/rpc/SynchronizedHandler.java | 54 ++++
service-rpc/src/main/thrift/rpc.thrift | 24 +-
session/pom.xml | 60 +++++
.../main/java/org/apache/iotdb/session/Config.java | 13 +-
.../iotdb/session/IoTDBSessionException.java | 17 +-
.../java/org/apache/iotdb/session/Session.java | 183 ++++++++++++++
.../org/apache/iotdb/session/SessionUtils.java | 90 +++++++
.../apache/iotdb/tsfile/io/TsFileOutputFormat.java | 10 +-
.../apache/iotdb/tsfile/io/TsFileRecordWriter.java | 6 +-
.../scala/org/apache/iotdb/tsfile/Converter.scala | 4 +-
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 14 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 16 +-
.../apache/iotdb/tsfile/write/record/RowBatch.java | 47 ++++
.../apache/iotdb/tsfile/write/record/TSRecord.java | 2 -
.../tsfile/write/schema/MeasurementSchema.java | 2 +-
.../write/schema/{FileSchema.java => Schema.java} | 35 +--
.../iotdb/tsfile/write/schema/SchemaBuilder.java | 18 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 6 +-
.../TsFileGeneratorForSeriesReaderByTimestamp.java | 11 +-
.../apache/iotdb/tsfile/utils/FileGenerator.java | 11 +-
.../org/apache/iotdb/tsfile/utils/RecordUtils.java | 4 +-
.../apache/iotdb/tsfile/utils/RecordUtilsTest.java | 27 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 6 +-
.../org/apache/iotdb/tsfile/write/PerfTest.java | 23 +-
.../iotdb/tsfile/write/ReadPageInMemTest.java | 21 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 8 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 10 +-
.../org/apache/iotdb/tsfile/write/WriteTest.java | 6 +-
.../write/schema/converter/SchemaBuilderTest.java | 6 +-
145 files changed, 2490 insertions(+), 659 deletions(-)