This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch fix_force_Append_Writer
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 7ba7ec1 fix code smell
add c200a29 add an example
add bc17dd2 fix docs link number
add 837f058 support bracket "[" "]" in path (#1273)
add 4466180 fix timeseries metadata cache return null bug (#1280)
add 4e7be1c [IOTDB-615] Use binary rather than string in insert plan
(#1229)
add 9b968de [IOTDB-719] add avg_series_point_number_threshold in config
(#1278)
add 14d8b71 Merge branch 'master' of
https://github.com/apache/incubator-iotdb into fix_force_Append_Writer
add 2598e79 add an example
add f2090b2 update docs
No new revisions were added by this update.
Summary of changes:
docs/Blog/Release0_93.md | 4 +-
docs/Development/ContributeGuide.md | 2 +-
docs/UserGuide/Client/Programming - TsFile API.md | 19 ++
docs/UserGuide/Operation Manual/Administration.md | 2 +-
.../DML Data Manipulation Language.md | 14 +-
docs/UserGuide/Server/Config Manual.md | 36 +++
.../UserGuide/System Tools/Load External Tsfile.md | 49 ++--
docs/UserGuide/UserGuideReadme.md | 2 +-
docs/zh/Development/ContributeGuide.md | 2 +-
.../QueryEngine/ResultSetConstruction.md | 2 +-
.../UserGuide/Client/Programming - TsFile API.md | 19 +-
.../UserGuide/Operation Manual/Administration.md | 2 +-
.../DML Data Manipulation Language.md | 8 +-
docs/zh/UserGuide/Server/Config Manual.md | 36 +++
.../UserGuide/System Tools/Load External Tsfile.md | 43 +--
docs/zh/UserGuide/UserGuideReadme.md | 2 +-
.../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 +-
...thTSRecord.java => TsFileForceAppendWrite.java} | 50 +++-
.../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 ++---
.../resources/conf/iotdb-engine.properties | 2 +
.../org/apache/iotdb/db/qp/strategy/SqlBase.g4 | 29 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 13 +
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 8 +-
.../db/engine/cache/TimeSeriesMetadataCache.java | 7 +-
.../iotdb/db/engine/flush/TsFileFlushPolicy.java | 8 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 66 +++--
.../apache/iotdb/db/engine/memtable/IMemTable.java | 10 +
.../db/engine/memtable/IWritableMemChunk.java | 5 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 4 +-
.../db/engine/storagegroup/TsFileProcessor.java | 26 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 75 +++++-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 207 ++++++++++++--
.../iotdb/db/qp/strategy/LogicalGenerator.java | 12 +-
.../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/utils/datastructure/TVList.java | 4 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 32 ++-
.../db/integration/IoTDBLoadExternalTsfileIT.java | 32 +--
.../apache/iotdb/db/qp/plan/PhysicalPlanTest.java | 14 +-
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 11 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 1 +
.../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 +++-
.../write/writer/ForceAppendTsFileWriterTest.java | 1 +
70 files changed, 1863 insertions(+), 804 deletions(-)
copy
example/tsfile/src/main/java/org/apache/iotdb/tsfile/{TsFileWriteWithTSRecord.java
=> TsFileForceAppendWrite.java} (61%)