This is an automated email from the ASF dual-hosted git repository.
lta pushed a change to branch cluster
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 9cb1236 Readjust task class and modify some cluster config
new 9df9cd6 modify IoTDB config
new 5309448 [IOTDB-39]Refactor auto repair for TsFile reader and TsFile
writer (#100)
new 306a681 set SQL parse error as debug level log; fix some sonar issues
new f205900 Merge pull request #112 from apache/fix_jira_62
new bd3a798 [IOTDB-63] Use TsFileInput instead of FileChannel as the
parameter passed to methods (#110)
new e3f9728 call valueDecoder reset() when reading data from a new Page
new a92c7b3 Merge pull request #113 from
apache/fix_jira_67_valueDecoder_reset
new d637989 add check SG for MManager, MGraph and MTree (#114)
new abc189c fix channel close bug in merge process (#103)
new a709721 Merge branch 'master' into cluster
new 1f626c4 add metadata plan codec
new 6e2dcea add author and loaddata plan codec
new 20d5513 add property plan codec
new 614f85e add physical codec unit test
new 29911bb fix a bug of spelling
new fe29969 Merge branch 'serialize-physicalplan' into cluster
new 2e8e594 add methods of raft utils
new 37fc8be fix a bug of codec physical plan
The 1573 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:
.../org/apache/iotdb/cluster/entity/Server.java | 20 +-
.../cluster/entity/data/DataPartitionHolder.java | 4 +
.../iotdb/cluster/entity/raft/RaftService.java | 4 +
.../cluster/qp/executor/NonQueryExecutor.java | 7 +-
.../org/apache/iotdb/cluster/utils/RaftUtils.java | 28 +-
iotdb/iotdb/bin/start-cluster.sh | 2 +-
iotdb/iotdb/conf/iotdb-cluster.properties | 10 +-
.../db/engine/filenode/FileNodeProcessor.java | 36 +-
.../db/engine/overflow/io/OverflowProcessor.java | 2 +
.../db/engine/overflow/io/OverflowResource.java | 1 +
.../java/org/apache/iotdb/db/metadata/MGraph.java | 9 +
.../org/apache/iotdb/db/metadata/MManager.java | 12 +
.../java/org/apache/iotdb/db/metadata/MTree.java | 28 ++
.../iotdb/db/qp/logical/sys/AuthorOperator.java | 95 ++++-
.../iotdb/db/qp/logical/sys/MetadataOperator.java | 38 +-
.../iotdb/db/qp/logical/sys/PropertyOperator.java | 47 ++-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 30 ++
.../iotdb/db/qp/physical/sys/LoadDataPlan.java | 19 +
.../iotdb/db/qp/physical/sys/MetadataPlan.java | 26 ++
.../iotdb/db/qp/physical/sys/PropertyPlan.java | 20 +
.../iotdb/db/query/control/FileReaderManager.java | 2 +-
.../db/query/control/OpenedFilePathsManager.java | 4 +-
.../db/query/factory/SeriesReaderFactory.java | 1 +
.../org/apache/iotdb/db/service/TSServiceImpl.java | 13 +-
.../org/apache/iotdb/db/utils/ByteBufferUtils.java | 59 +++
.../apache/iotdb/db/writelog/transfer/Codec.java | 1 +
.../iotdb/db/writelog/transfer/CodecInstances.java | 452 +++++++++++++++++++++
.../db/writelog/transfer/PhysicalPlanCodec.java | 186 +--------
.../writelog/transfer/PhysicalPlanLogTransfer.java | 41 +-
.../db/writelog/transfer/SystemLogOperator.java | 8 +-
.../version/SysTimeVersionControllerTest.java | 14 +-
.../db/integration/IoTDBFlushQueryMergeTest.java | 130 ++++++
.../iotdb/db/metadata/MManagerBasicTest.java | 26 ++
.../org/apache/iotdb/db/metadata/MTreeTest.java | 24 ++
.../transfer/PhysicalPlanLogTransferTest.java | 157 +++++++
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 1 +
.../iotdb/tsfile/file/footer/ChunkGroupFooter.java | 10 +-
.../iotdb/tsfile/file/header/ChunkHeader.java | 12 +-
.../iotdb/tsfile/file/header/PageHeader.java | 14 +-
.../file/metadata/statistics/BinaryStatistics.java | 6 +-
.../file/metadata/statistics/Statistics.java | 16 +-
.../{IDataReader.java => TsFileCheckStatus.java} | 12 +-
.../iotdb/tsfile/read/TsFileRestorableReader.java | 70 ++++
.../iotdb/tsfile/read/TsFileSequenceReader.java | 265 ++++++++++--
.../iotdb/tsfile/utils/ReadWriteIOUtils.java | 34 +-
.../write/writer/NativeRestorableIOWriter.java | 193 ++-------
.../iotdb/tsfile/file/header/PageHeaderTest.java | 7 +-
.../tsfile/read/TsFileRestorableReaderTest.java | 59 +++
.../tsfile/read/TsFileSequenceReaderTest.java | 23 --
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 66 ++-
.../write/writer/NativeRestorableIOWriterTest.java | 41 +-
51 files changed, 1793 insertions(+), 592 deletions(-)
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/utils/ByteBufferUtils.java
create mode 100644
iotdb/src/main/java/org/apache/iotdb/db/writelog/transfer/CodecInstances.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/integration/IoTDBFlushQueryMergeTest.java
create mode 100644
iotdb/src/test/java/org/apache/iotdb/db/writelog/transfer/PhysicalPlanLogTransferTest.java
copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/{IDataReader.java =>
TsFileCheckStatus.java} (77%)
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/TsFileRestorableReader.java
create mode 100644
tsfile/src/test/java/org/apache/iotdb/tsfile/read/TsFileRestorableReaderTest.java
