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%)
