This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch cluster_extract_application
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 0c3ab92 add log when entry is rejected
add 875817b fix grafana value-time position bug (#2016)
add de4536a Declare the type of result of Future in StorageEngine (#2097)
add 093bd9b Remove the useless `public` keyword due to these methods in
interface are (#2140)
add 7ebdf9a Fix compaction add list bug when last level exceeds max file
num (#2141)
add 66d86b3 fix typo in userguide
add ff104e9 add MAX_POINT_NUMBER format check (#2148)
add 8657b13 Add Apache Pulsar to IoTDB example (#2122)
add d242932 Update compaction level list delete (#2152)
add 18bb46a [IOTDB-890] SDT implementation (#2087)
add 467897e add charset UTF-8 (#2155)
add f6cd1f9 [IOTDB-1035] Fix bug in getDeviceTimeseriesMetadata when
querying non-exist device (#2150)
add 8e8384f Fix File Not Found when serializing TsFileResources (#2161)
add e95cebc Fix flink-iotdb set storage group bug (#2165)
add ccd6fab [IOTDB-1032]Refactor site/pom.xml and move v0.11 to 0.12 in
all pom files (#2139)
add df22109 [IOTDB-1011] Memtable sort in query (#2144)
add 7dbc215 doc: fix dead links in the README (#2174)
add d951e82 [Mem control] Move one of the insert check out from the sg
lock (#2154)
add 8aa9fef Remove duplicated static resps(column header) (#2164)
add bf0fb06 fix insert partial tablet with binary NullPointer bug (#2180)
add 7a088ff Merge branch 'master' into cluster_new
add b3c2ce3 update cluster denpendency
add 9e33a73 fix tests
add f409921 fix code smells
add 19d57cf fix maybeTerm
add 39cb51a fix isFileAlreadyExist fix maybeTerm
new 0a972b6 Merge branch 'cluster_new' into cluster_extract_application
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 | 2 +-
README_ZH.md | 2 +-
antlr/pom.xml | 2 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlBase.g4 | 5 -
cli/pom.xml | 4 +-
client-cpp/client-cpp-example/pom.xml | 4 +-
client-cpp/pom.xml | 4 +-
client-py/pom.xml | 2 +-
client-py/pypi/setup.py | 2 +-
cluster/pom.xml | 10 +-
.../iotdb/cluster/log/catchup/CatchUpTask.java | 27 +-
.../log/manage/UnCommittedEntryManager.java | 45 +-
.../apache/iotdb/cluster/metadata/CMManager.java | 15 +-
.../cluster/partition/slot/SlotPartitionTable.java | 53 +-
.../groupby/ClusterGroupByNoVFilterDataSet.java | 17 +-
.../groupby/ClusterGroupByVFilterDataSet.java | 18 +-
.../handlers/caller/AppendNodeEntryHandler.java | 1 -
.../iotdb/cluster/server/member/RaftMember.java | 7 +-
.../cluster/server/service/DataSyncService.java | 2 +-
.../caller/AppendNodeEntryHandlerTest.java | 78 +--
compile-tools/boost/pom.xml | 2 +-
compile-tools/pom.xml | 4 +-
compile-tools/thrift/pom.xml | 2 +-
cross-tests/pom.xml | 2 +-
distribution/pom.xml | 2 +-
docker/src/main/Dockerfile | 4 +-
docs/Download/README.md | 47 +-
docs/SystemDesign/TsFile/Format.md | 2 +-
docs/UserGuide/Client/Command Line Interface.md | 1 +
docs/UserGuide/Concept/SDT.md | 45 ++
docs/UserGuide/Operation Manual/SQL Reference.md | 10 +-
docs/zh/Download/README.md | 47 +-
docs/zh/SystemDesign/TsFile/Format.md | 2 +-
docs/zh/UserGuide/Client/Command Line Interface.md | 2 +-
docs/zh/UserGuide/Concept/Data Type.md | 2 +-
.../zh/UserGuide/Concept/SDT.md | 24 +-
.../UserGuide/Ecosystem Integration/Hive TsFile.md | 6 +-
.../zh/UserGuide/Operation Manual/SQL Reference.md | 10 +-
docs/zh/UserGuide/Server/Download.md | 14 +-
example/flink/pom.xml | 2 +-
example/hadoop/pom.xml | 6 +-
example/jdbc/pom.xml | 2 +-
example/kafka/pom.xml | 2 +-
.../main/java/org/apache/iotdb/kafka/Constant.java | 2 +
example/mqtt/pom.xml | 2 +-
example/pom.xml | 3 +-
example/{tsfile => pulsar}/pom.xml | 18 +-
.../java/org/apache/iotdb/pulsar}/Constant.java | 19 +-
.../org/apache/iotdb/pulsar/PulsarConsumer.java | 108 ++++
.../apache/iotdb/pulsar/PulsarConsumerThread.java | 70 +++
.../org/apache/iotdb/pulsar/PulsarProducer.java | 82 +++
example/rocketmq/pom.xml | 2 +-
example/session/pom.xml | 2 +-
.../main/java/org/apache/iotdb/SessionExample.java | 14 +
example/tsfile/pom.xml | 2 +-
flink-iotdb-connector/pom.xml | 2 +-
.../java/org/apache/iotdb/flink/IoTDBSink.java | 25 +-
flink-tsfile-connector/pom.xml | 2 +-
grafana/pom.xml | 2 +-
.../controller/DatabaseConnectController.java | 4 +-
.../iotdb/web/grafana/dao/impl/BasicDaoImpl.java | 29 +-
.../web/grafana/dao/impl/BasicDaoImplTest.java | 55 ++
hadoop/pom.xml | 4 +-
hive-connector/pom.xml | 6 +-
jdbc/pom.xml | 2 +-
pom.xml | 2 +-
server/pom.xml | 2 +-
.../resources/conf/iotdb-engine.properties | 10 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 14 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 6 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 27 +-
.../db/engine/compaction/TsFileManagement.java | 21 +
.../level/LevelCompactionTsFileManagement.java | 42 +-
.../no/NoCompactionTsFileManagement.java | 22 +-
.../engine/compaction/utils/CompactionUtils.java | 2 +-
.../iotdb/db/engine/flush/FlushManagerMBean.java | 8 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 2 +-
.../iotdb/db/engine/memtable/AbstractMemTable.java | 52 +-
.../db/engine/memtable/IWritableMemChunk.java | 24 +-
.../iotdb/db/engine/memtable/WritableMemChunk.java | 35 +-
.../db/engine/querycontext/ReadOnlyMemChunk.java | 37 +-
.../engine/storagegroup/StorageGroupProcessor.java | 80 ++-
.../db/engine/storagegroup/TsFileProcessor.java | 163 +++---
.../db/engine/storagegroup/TsFileResource.java | 75 +--
.../iotdb/db/exception/BatchProcessException.java | 9 +-
.../org/apache/iotdb/db/metadata/MManager.java | 193 +++----
.../org/apache/iotdb/db/metrics/sink/Sink.java | 6 +-
.../org/apache/iotdb/db/metrics/source/Source.java | 2 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 1 -
.../apache/iotdb/db/qp/executor/PlanExecutor.java | 213 ++++----
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 21 +
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 87 ++--
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 6 +-
.../dataset/groupby/GroupByEngineDataSet.java | 7 +-
.../groupby/GroupByWithValueFilterDataSet.java | 2 +
.../org/apache/iotdb/db/service/StaticResps.java | 98 +---
.../org/apache/iotdb/db/service/TSServiceImpl.java | 108 +---
.../org/apache/iotdb/db/utils/SchemaUtils.java | 1 -
.../org/apache/iotdb/db/utils/SerializeUtils.java | 233 +++++----
.../iotdb/db/utils/datastructure/TVList.java | 128 ++---
.../db/writelog/node/ExclusiveWriteLogNode.java | 1 -
.../db/engine/memtable/PrimitiveMemTableTest.java | 2 +-
.../engine/storagegroup/TsFileProcessorTest.java | 8 +-
.../iotdb/db/integration/IoTDBCompactionIT.java | 99 ++++
.../db/integration/IoTDBInsertWithQueryIT.java | 503 ++++++++++++++++++
.../iotdb/db/integration/IoTDBRestartIT.java | 61 ++-
.../iotdb/db/integration/IoTDBSimpleQueryIT.java | 422 ++++++++++++++-
service-rpc/pom.xml | 2 +-
.../iotdb/rpc/AutoScalingBufferReadTransport.java | 14 +-
.../iotdb/rpc/AutoScalingBufferWriteTransport.java | 19 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 7 +-
...ngeableTransport.java => NonOpenTransport.java} | 20 +-
.../org/apache/iotdb/rpc/RpcTransportFactory.java | 3 +-
.../rpc/TCompressedElasticFramedTransport.java | 56 +-
.../apache/iotdb/rpc/TElasticFramedTransport.java | 18 +-
.../iotdb/rpc/TSnappyElasticFramedTransport.java | 9 +-
.../rpc/TimeoutChangeableTFastFramedTransport.java | 12 +-
.../TimeoutChangeableTSnappyFramedTransport.java | 11 +-
session/pom.xml | 2 +-
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 47 ++
site/README-zh.md | 8 +-
site/README.md | 15 +-
site/pom.xml | 568 +++++++++++++++++----
site/src/main/.vuepress/config.js | 198 ++++++-
site/src/main/package.json | 6 +-
spark-iotdb-connector/pom.xml | 2 +-
spark-tsfile/pom.xml | 4 +-
thrift/pom.xml | 2 +-
tsfile/pom.xml | 2 +-
.../iotdb/tsfile/compress/IUnCompressor.java | 2 +-
.../iotdb/tsfile/encoding/encoder/SDTEncoder.java | 448 ++++++++++++++++
.../tsfile/encoding/encoder/TSEncodingBuilder.java | 14 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 18 +-
.../tsfile/read/query/dataset/QueryDataSet.java | 14 +-
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 114 +----
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 121 ++++-
.../apache/iotdb/tsfile/write/record/Tablet.java | 5 +-
.../iotdb/tsfile/encoding/SDTEncoderTest.java | 176 +++++++
138 files changed, 4217 insertions(+), 1550 deletions(-)
create mode 100644 docs/UserGuide/Concept/SDT.md
copy server/file-changelists/role-changelist.md =>
docs/zh/UserGuide/Concept/SDT.md (53%)
copy example/{tsfile => pulsar}/pom.xml (79%)
copy example/{hadoop/src/main/java/org/apache/iotdb/hadoop/tsfile =>
pulsar/src/main/java/org/apache/iotdb/pulsar}/Constant.java (66%)
create mode 100644
example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarConsumer.java
create mode 100644
example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarConsumerThread.java
create mode 100644
example/pulsar/src/main/java/org/apache/iotdb/pulsar/PulsarProducer.java
create mode 100644
grafana/src/test/java/org/apache/iotdb/web/grafana/dao/impl/BasicDaoImplTest.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBCompactionIT.java
create mode 100644
server/src/test/java/org/apache/iotdb/db/integration/IoTDBInsertWithQueryIT.java
copy
service-rpc/src/main/java/org/apache/iotdb/rpc/{TimeoutChangeableTransport.java
=> NonOpenTransport.java} (71%)
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/encoding/encoder/SDTEncoder.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/encoding/SDTEncoderTest.java
