This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch cluster_new
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 7fb11de fix sonar issues
add 5a5e36f add status code in exception (#1266)
add 74e644b [IOTDB-710] delete failed while load is too heavy (#1270)
add b4ed539 fix recover (#1271)
add 991d530 fix group by fill grammar and some logic..
add 554bf69 fix it
add a71db8b update docs
add 865cb2d fix bug
add d674312 use default time interval
add a358047 fix doc
add b3b2b1a [IOTDB-715] Support previous time range in previousuntillast
(#1272)
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 f2d4b35 fix group by doc, remove as
add 4c09acd Fix ForceAppendTsFileWriter (#1275)
add 29adcf6 [IOTDB-615] fix infer type from session (#1282)
add 1193fca [IOTDB-692] Fix merge update bug (#1262)
add 7557e5d add infer type test in SessionIT
add 31d2c8f Merge branch 'master' into cluster_new
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iotdb/cluster/ClientMain.java | 33 ++-
.../iotdb/cluster/query/ClusterPlanExecutor.java | 27 +-
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 6 +-
.../org/apache/iotdb/cluster/common/TestUtils.java | 18 +-
.../cluster/log/applier/DataLogApplierTest.java | 9 +-
.../cluster/log/logtypes/SerializeLogTest.java | 15 +-
.../cluster/server/member/DataGroupMemberTest.java | 32 ++-
.../cluster/server/member/MetaGroupMemberTest.java | 25 +-
docs/Blog/Release0_93.md | 4 +-
docs/Development/ContributeGuide.md | 2 +-
docs/UserGuide/Client/Programming - TsFile API.md | 19 ++
docs/UserGuide/Client/Status Codes.md | 4 +-
docs/UserGuide/Operation Manual/Administration.md | 2 +-
.../DML Data Manipulation Language.md | 22 +-
docs/UserGuide/Operation Manual/SQL Reference.md | 2 +
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 +-
docs/zh/UserGuide/Client/Status Codes.md | 4 +-
.../UserGuide/Operation Manual/Administration.md | 2 +-
.../DML Data Manipulation Language.md | 21 +-
.../zh/UserGuide/Operation Manual/SQL Reference.md | 2 +
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 | 53 +++-
.../java/org/apache/iotdb/SessionPoolExample.java | 17 +-
...thTSRecord.java => TsFileForceAppendWrite.java} | 68 +++--
.../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/merge/task/MergeMultiChunkTask.java | 87 +++---
.../db/engine/storagegroup/TsFileProcessor.java | 26 +-
.../db/exception/metadata/MetadataException.java | 3 +-
.../metadata/StorageGroupAlreadySetException.java | 5 +-
.../org/apache/iotdb/db/metadata/MManager.java | 10 +-
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 74 ++++-
.../iotdb/db/qp/physical/crud/InsertPlan.java | 213 +++++++++++++--
.../iotdb/db/qp/strategy/LogicalGenerator.java | 30 ++-
.../iotdb/db/qp/strategy/PhysicalGenerator.java | 1 +
.../query/dataset/groupby/GroupByFillDataSet.java | 37 ++-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 44 +--
.../org/apache/iotdb/db/utils/CommonUtils.java | 41 ++-
.../apache/iotdb/db/utils/TypeInferenceUtils.java | 8 +-
.../iotdb/db/utils/datastructure/TVList.java | 4 +-
.../iotdb/db/writelog/io/SingleFileLogReader.java | 2 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 2 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 36 ++-
.../integration/IoTDBGroupByFillWithRangeIT.java | 161 +++++++++++
.../db/integration/IoTDBLoadExternalTsfileIT.java | 32 +--
.../iotdb/db/integration/IoTDBSensorUpdateIT.java | 87 ++++++
.../apache/iotdb/db/qp/plan/PhysicalPlanTest.java | 34 ++-
.../org/apache/iotdb/db/tools/WalCheckerTest.java | 11 +-
.../apache/iotdb/db/utils/EnvironmentUtils.java | 1 +
.../iotdb/db/utils/TypeInferenceUtilsTest.java | 19 +-
.../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 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 3 +-
.../iotdb/rpc/StatementExecutionException.java | 13 +
service-rpc/src/main/thrift/rpc.thrift | 6 +-
.../java/org/apache/iotdb/session/Session.java | 299 ++++++++++++++++-----
.../org/apache/iotdb/session/SessionDataSet.java | 10 +-
.../org/apache/iotdb/session/pool/SessionPool.java | 48 ++--
.../org/apache/iotdb/session/IoTDBSessionIT.java | 275 ++++++++++++++++++-
.../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 +++-
.../tsfile/write/schema/MeasurementSchema.java | 3 +
.../write/writer/ForceAppendTsFileWriter.java | 19 ++
.../write/writer/ForceAppendTsFileWriterTest.java | 42 +++
98 files changed, 2575 insertions(+), 966 deletions(-)
copy
example/tsfile/src/main/java/org/apache/iotdb/tsfile/{TsFileWriteWithTSRecord.java
=> TsFileForceAppendWrite.java} (54%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBGroupByFillWithRangeIT.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBSensorUpdateIT.java
