This is an automated email from the ASF dual-hosted git repository.
lta pushed a change to branch reimpl_sync
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git.
from 10e861c fix issues according to pr reviews
add 7d07bae [IOTDB-191] Enrich Session interfaces (#375)
add a09f08b add log for session (#394)
add 0a4df04 [IOTDB-219] Add config of tsfile_storage_fs in
iotdb-engine.properties (#395)
add 18da903 fix a bug in DirectoryManager (#393)
add 6849f79 fix ignoreTimeStamp IOTDB-214; simplify some jdbc interfaces
(#392)
add efe249b using String.getBytes(utf-9).length to replace
string.length() in ChunkGroupMetadata for supporting Chinese (#396)
add 0c57d25 [IOTDB-222] Fix changing to read-only mode when flushing
Tsfile on HDFS (#397)
add 978338a fix rpc error (#401)
add c566bf5 [IOTDB-223]Add a TsFile sketch tool (#398)
add 62f8f2f [IOTDB-224] fix buffer size and remove cache (#400)
add 2b5da1a Rename some varaible names and struct names in RPC (#404)
add 8ea1fc6 Remove static, add getter and setter. (#403)
add 1769a7c Update document affected by renaming RPC (#405)
add 6301fbb merge master and fix conflicts
add 1b05d7f replace assert with org.JUnit.asssert
No new revisions were added by this update.
Summary of changes:
.gitignore | 2 +
.../org/apache/iotdb/client/AbstractClient.java | 12 +-
.../4-Deployment and Management/2-Configuration.md | 27 ++
.../UserGuide/6-JDBC API/2-Status Code.md | 2 +-
.../UserGuide/7-Session API/1-Session API.md | 7 +
.../4-Deployment and Management/2-Configuration.md | 27 ++
.../UserGuide/6-JDBC API/2-Status Code.md | 2 +-
.../UserGuide/7-Session API/1-Session API.md | 7 +
.../UserGuide/8-TsFile/3-Hierarchy.md | 86 ++++-
.../main/java/org/apache/iotdb/SessionExample.java | 11 +-
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 2 +-
.../org/apache/iotdb/tsfile/TsFileSketchTool.java | 220 +++++++++++++
.../main/java/org/apache/iotdb/jdbc/Constant.java | 2 +
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 4 +-
.../jdbc/IoTDBPreparedInsertionStatement.java | 4 +-
.../org/apache/iotdb/jdbc/IoTDBQueryResultSet.java | 357 +++++++++++----------
.../org/apache/iotdb/jdbc/IoTDBResultMetadata.java | 62 ++--
.../java/org/apache/iotdb/jdbc/IoTDBStatement.java | 39 +--
.../test/java/org/apache/iotdb/jdbc/BatchTest.java | 10 +-
.../org/apache/iotdb/jdbc/IoTDBConnectionTest.java | 8 +-
.../iotdb/jdbc/IoTDBDatabaseMetadataTest.java | 6 +-
.../iotdb/jdbc/IoTDBPreparedStatementTest.java | 9 +-
.../apache/iotdb/jdbc/IoTDBQueryResultSetTest.java | 11 +-
.../apache/iotdb/jdbc/IoTDBResultMetadataTest.java | 24 +-
.../org/apache/iotdb/jdbc/IoTDBStatementTest.java | 6 +-
.../test/java/org/apache/iotdb/jdbc/UtilsTest.java | 15 +-
.../resources/conf/iotdb-engine.properties | 10 +-
.../iotdb/db/auth/role/LocalFileRoleAccessor.java | 19 +-
.../iotdb/db/auth/user/LocalFileUserAccessor.java | 38 +--
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 58 +++-
.../org/apache/iotdb/db/conf/IoTDBConfigCheck.java | 10 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 12 +-
.../iotdb/db/conf/adapter/CompressionRatio.java | 7 +-
.../org/apache/iotdb/db/engine/StorageEngine.java | 3 +-
.../apache/iotdb/db/engine/fileSystem/FSType.java | 24 --
.../{FileFactory.java => SystemFileFactory.java} | 16 +-
.../iotdb/db/engine/flush/MemTableFlushTask.java | 3 +-
.../db/engine/merge/manage/MergeResource.java | 4 +-
.../iotdb/db/engine/merge/recover/LogAnalyzer.java | 8 +-
.../db/engine/querycontext/ReadOnlyMemChunk.java | 3 +-
.../engine/storagegroup/StorageGroupProcessor.java | 12 +-
.../db/engine/storagegroup/TsFileProcessor.java | 4 +-
.../db/engine/storagegroup/TsFileResource.java | 11 +-
.../version/SimpleFileVersionController.java | 9 +-
.../java/org/apache/iotdb/db/metadata/MGraph.java | 3 +-
.../org/apache/iotdb/db/metadata/MManager.java | 12 +-
.../java/org/apache/iotdb/db/metadata/MTree.java | 3 +-
.../org/apache/iotdb/db/monitor/StatMonitor.java | 3 +-
.../iotdb/db/monitor/collector/FileSize.java | 8 +-
.../iotdb/db/qp/physical/crud/DeletePlan.java | 4 +-
.../iotdb/db/qp/strategy/LogicalGenerator.java | 3 +-
.../java/org/apache/iotdb/db/service/Monitor.java | 5 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 289 ++++++++++-------
.../apache/iotdb/db/tools/MemEst/MemEstTool.java | 5 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 6 +-
.../java/org/apache/iotdb/db/tools/WalChecker.java | 6 +-
.../java/org/apache/iotdb/db/utils/MathUtils.java | 13 +-
.../org/apache/iotdb/db/writelog/io/LogWriter.java | 3 +-
.../db/writelog/node/ExclusiveWriteLogNode.java | 12 +-
.../iotdb/db/writelog/recover/LogReplayer.java | 5 +-
.../writelog/recover/TsFileRecoverPerformer.java | 4 +-
.../iotdb/db/engine/MetadataManagerHelper.java | 6 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 3 +-
.../engine/modification/DeletionFileNodeTest.java | 3 +-
.../db/engine/modification/DeletionQueryTest.java | 3 +-
.../engine/storagegroup/TsFileProcessorTest.java | 12 +-
.../db/integration/IoTDBEngineTimeGeneratorIT.java | 18 +-
.../iotdb/db/integration/IoTDBLargeDataIT.java | 18 +-
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 18 +-
.../db/integration/IoTDBSequenceDataQueryIT.java | 18 +-
.../iotdb/db/integration/IoTDBSeriesReaderIT.java | 18 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 3 +-
.../org/apache/iotdb/db/qp/QueryProcessorTest.java | 5 +-
.../db/query/control/FileReaderManagerTest.java | 8 +-
.../db/sync/receiver/load/FileLoaderTest.java | 84 ++---
.../recover/SyncReceiverLogAnalyzerTest.java | 25 +-
.../receiver/recover/SyncReceiverLoggerTest.java | 13 +-
.../db/sync/sender/manage/SyncFileManagerTest.java | 47 +--
.../sender/recover/SyncSenderLogAnalyzerTest.java | 35 +-
.../sync/sender/recover/SyncSenderLoggerTest.java | 21 +-
.../sender/transfer/DataTransferManagerTest.java | 30 +-
.../iotdb/db/writelog/IoTDBLogFileSizeTest.java | 7 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 6 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 4 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 4 +-
service-rpc/rpc-changelist.md | 12 +-
.../main/java/org/apache/iotdb/rpc/RpcUtils.java | 6 +-
.../rpc/{TSStatusType.java => TSStatusCode.java} | 4 +-
service-rpc/src/main/thrift/rpc.thrift | 51 ++-
session/pom.xml | 12 +
.../java/org/apache/iotdb/session/Session.java | 49 ++-
.../org/apache/iotdb/session/IoTDBSessionIT.java | 98 +++++-
.../iotdb/session}/utils/EnvironmentUtils.java | 6 +-
.../java/org/apache/iotdb/sparkdb/SQLConstant.java | 1 -
.../scala/org/apache/iotdb/sparkdb/Converter.scala | 13 +-
.../scala/org/apache/iotdb/sparkdb/IoTDBTest.scala | 63 +++-
.../org/apache/iotdb/tool/TsFileWriteTool.java | 2 +-
.../iotdb/tsfile/common/conf/TSFileConfig.java | 203 ++++++++++--
.../iotdb/tsfile/common/conf/TSFileDescriptor.java | 46 ++-
.../tsfile/encoding/encoder/TSEncodingBuilder.java | 16 +-
.../iotdb/tsfile/file/footer/ChunkGroupFooter.java | 2 +-
.../iotdb/tsfile/file/header/ChunkHeader.java | 7 +-
.../tsfile/file/metadata/ChunkGroupMetaData.java | 12 +-
.../iotdb/tsfile/file/metadata/ChunkMetaData.java | 8 +-
.../apache/iotdb/tsfile/fileSystem/HDFSFile.java | 27 +-
.../iotdb/tsfile/fileSystem/TSFileFactory.java | 49 ++-
.../tsfile/read/reader/chunk/ChunkReader.java | 3 +-
.../java/org/apache/iotdb/tsfile/utils/Binary.java | 10 +-
.../org/apache/iotdb/tsfile/utils/BytesUtils.java | 14 +-
.../apache/iotdb/tsfile/utils/StringContainer.java | 1 +
.../apache/iotdb/tsfile/write/TsFileWriter.java | 4 +-
.../iotdb/tsfile/write/chunk/ChunkWriterImpl.java | 3 +-
.../apache/iotdb/tsfile/write/record/RowBatch.java | 6 +-
.../tsfile/write/schema/MeasurementSchema.java | 9 +-
.../iotdb/tsfile/read/ReadOnlyTsFileTest.java | 4 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 2 +-
.../read/query/executor/QueryExecutorTest.java | 2 +-
.../query/timegenerator/ReaderByTimestampTest.java | 2 +-
.../query/timegenerator/TimeGeneratorTest.java | 2 +-
.../TsFileGeneratorForSeriesReaderByTimestamp.java | 18 +-
.../iotdb/tsfile/read/reader/ReaderTest.java | 2 +-
.../apache/iotdb/tsfile/utils/FileGenerator.java | 15 +-
.../apache/iotdb/tsfile/utils/RecordUtilsTest.java | 12 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 10 +-
.../org/apache/iotdb/tsfile/write/PerfTest.java | 9 +-
.../iotdb/tsfile/write/ReadPageInMemTest.java | 36 ++-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 5 +-
.../org/apache/iotdb/tsfile/write/WriteTest.java | 16 +-
128 files changed, 1850 insertions(+), 1028 deletions(-)
create mode 100644
example/tsfile/src/main/java/org/apache/iotdb/tsfile/TsFileSketchTool.java
delete mode 100644
server/src/main/java/org/apache/iotdb/db/engine/fileSystem/FSType.java
rename
server/src/main/java/org/apache/iotdb/db/engine/fileSystem/{FileFactory.java =>
SystemFileFactory.java} (73%)
rename service-rpc/src/main/java/org/apache/iotdb/rpc/{TSStatusType.java =>
TSStatusCode.java} (95%)
copy example/session/src/main/java/org/apache/iotdb/SessionExample.java =>
session/src/test/java/org/apache/iotdb/session/IoTDBSessionIT.java (53%)
copy {server/src/test/java/org/apache/iotdb/db =>
session/src/test/java/org/apache/iotdb/session}/utils/EnvironmentUtils.java
(99%)