You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ji...@apache.org on 2022/01/06 07:05:32 UTC
[iotdb] branch client_manager_add_close updated (bd829b5 -> 48ba7a3)
This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch client_manager_add_close
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from bd829b5 add e2e log prefix
add 4fd2229 [IOTDB-2259] Fix Error information is incorrect when aligned timeseries Data type mismatch (#4706)
add cbecb86 update CMakeLists.txt (#4707)
add fe5d591 [IOTDB-2265] rename UnaryMeasurementSchema to MeasurementSchema (#4710)
add f061b28 [IOTDB-1802] Add aligned timeseries APIs for C++ client (#4711)
add 48ba7a3 Merge branch 'master' into client_manager_add_close
No new revisions were added by this update.
Summary of changes:
client-cpp/src/main/CMakeLists.txt | 2 +-
client-cpp/src/main/Session.cpp | 265 ++++++++++++++++++++-
client-cpp/src/main/Session.h | 53 ++++-
client-cpp/src/test/CMakeLists.txt | 2 +-
.../java/org/apache/iotdb/cluster/ClientMain.java | 4 +-
.../apache/iotdb/cluster/metadata/MetaPuller.java | 4 +-
.../caller/PullMeasurementSchemaHandler.java | 4 +-
.../iotdb/cluster/utils/ClusterQueryUtils.java | 5 +-
.../cluster/client/sync/SyncClientAdaptorTest.java | 4 +-
.../org/apache/iotdb/cluster/common/IoTDBTest.java | 5 +-
.../org/apache/iotdb/cluster/common/TestUtils.java | 8 +-
.../query/ClusterDataQueryExecutorTest.java | 8 +-
example/client-cpp-example/pom.xml | 4 +
.../src/AlignedTimeseriesSessionExample.cpp | 217 +++++++++++++++++
example/client-cpp-example/src/CMakeLists.txt | 8 +-
example/client-cpp-example/src/SessionExample.cpp | 30 ++-
.../apache/iotdb/flink/FlinkTsFileBatchSink.java | 11 +-
.../apache/iotdb/flink/FlinkTsFileStreamSink.java | 11 +-
.../java/org/apache/iotdb/flink/TsFileUtils.java | 9 +-
.../iotdb/hadoop/tsfile/TSMRWriteExample.java | 6 +-
.../apache/iotdb/hadoop/tsfile/TsFileHelper.java | 13 +-
.../iotdb/hadoop/tsfile/TsFileWriteToHDFS.java | 8 +-
.../iotdb/AlignedTimeseriesSessionExample.java | 39 ++-
.../org/apache/iotdb/DataMigrationExample.java | 7 +-
.../iotdb/HybridTimeseriesSessionExample.java | 9 +-
.../org/apache/iotdb/SessionConcurrentExample.java | 11 +-
.../main/java/org/apache/iotdb/SessionExample.java | 27 +--
.../main/java/org/apache/iotdb/TabletExample.java | 7 +-
.../iotdb/tsfile/TsFileForceAppendWrite.java | 14 +-
.../tsfile/TsFileWriteAlignedWithTSRecord.java | 10 +-
.../iotdb/tsfile/TsFileWriteAlignedWithTablet.java | 25 +-
.../iotdb/tsfile/TsFileWriteWithTSRecord.java | 10 +-
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 15 +-
.../tsfile/RowTsFileOutputFormatTestBase.java | 10 +-
.../apache/iotdb/flink/util/TsFileWriteUtil.java | 18 +-
.../iotdb/hadoop/tsfile/TsFileTestHelper.java | 9 +-
.../org/apache/iotdb/hive/TsFileTestHelper.java | 9 +-
...IoTDBLoadExternalTsFileWithTimePartitionIT.java | 4 +-
.../{ => aligned}/IOTDBInsertAlignedValuesIT.java | 57 +++--
.../iotdb/session/IoTDBSessionComplexIT.java | 27 +--
.../apache/iotdb/session/IoTDBSessionSimpleIT.java | 59 +++--
.../idtable/entry/InsertMeasurementMNode.java | 4 +-
.../iotdb/db/metadata/logfile/MLogWriter.java | 4 +-
.../org/apache/iotdb/db/metadata/mtree/MTree.java | 6 +-
.../iotdb/db/metadata/path/MeasurementPath.java | 4 +-
.../iotdb/db/metadata/template/Template.java | 13 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 4 +-
.../db/qp/physical/sys/MeasurementMNodePlan.java | 4 +-
.../apache/iotdb/db/tools/TsFileRewriteTool.java | 18 +-
.../db/tools/upgrade/TsFileOnlineUpgradeTool.java | 10 +-
.../org/apache/iotdb/db/utils/SchemaUtils.java | 4 +-
.../db/utils/datastructure/AlignedTVList.java | 14 +-
.../db/engine/cache/BloomFilterCacheTest.java | 13 +-
.../iotdb/db/engine/cache/ChunkCacheTest.java | 12 +-
.../engine/compaction/cross/MergeOverLapTest.java | 4 +-
.../db/engine/compaction/cross/MergeTaskTest.java | 4 +-
.../db/engine/compaction/cross/MergeTest.java | 12 +-
.../engine/compaction/cross/MergeUpgradeTest.java | 11 +-
.../inner/AbstractInnerSpaceCompactionTest.java | 12 +-
.../inner/InnerCompactionMoreDataTest.java | 10 +-
.../compaction/inner/InnerCompactionTest.java | 12 +-
.../inner/sizetiered/SizeTieredCompactionTest.java | 12 +-
.../utils/CompactionFileGeneratorUtils.java | 6 +-
.../db/engine/memtable/MemTableTestUtils.java | 13 +-
.../db/engine/memtable/MemtableBenchmark.java | 4 +-
.../db/engine/memtable/PrimitiveMemTableTest.java | 50 ++--
.../storagegroup/StorageGroupProcessorTest.java | 20 +-
.../iotdb/db/engine/storagegroup/TTLTest.java | 12 +-
.../engine/storagegroup/TsFileProcessorTest.java | 10 +-
.../iotdb/db/metadata/MManagerBasicTest.java | 6 +-
.../org/apache/iotdb/db/metadata/TemplateTest.java | 6 +-
.../reader/series/SeriesAggregateReaderTest.java | 4 +-
.../reader/series/SeriesReaderByTimestampTest.java | 4 +-
.../db/query/reader/series/SeriesReaderTest.java | 4 +-
.../query/reader/series/SeriesReaderTestUtil.java | 21 +-
.../iotdb/db/rescon/ResourceManagerTest.java | 12 +-
.../iotdb/db/tools/TsFileAndModSettleToolTest.java | 5 +-
.../iotdb/db/tools/TsFileSketchToolTest.java | 13 +-
.../iotdb/db/utils/TsFileRewriteToolTest.java | 10 +-
.../db/writelog/recover/DeviceStringTest.java | 8 +-
.../iotdb/db/writelog/recover/LogReplayerTest.java | 6 +-
.../recover/RecoverResourceFromReaderTest.java | 12 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 12 +-
.../writelog/recover/UnseqTsFileRecoverTest.java | 12 +-
.../java/org/apache/iotdb/session/Session.java | 4 +-
.../apache/iotdb/session/util/SessionUtils.java | 4 +-
.../session/IoTDBSessionDisableMemControlIT.java | 19 +-
.../session/IoTDBSessionVectorAggregationIT.java | 9 +-
.../iotdb/session/IoTDBSessionVectorInsertIT.java | 17 +-
.../apache/iotdb/session/SessionCacheLeaderUT.java | 27 +--
.../java/org/apache/iotdb/session/SessionTest.java | 17 +-
.../iotdb/spark/tsfile/NarrowConverter.scala | 6 +-
.../apache/iotdb/spark/tsfile/WideConverter.scala | 6 +-
.../org/apache/iotdb/spark/tool/TsFileExample.java | 10 +-
.../apache/iotdb/spark/tool/TsFileWriteTool.java | 22 +-
.../test/java/org/apache/iotdb/db/sql/Cases.java | 57 +++--
.../iotdb/tsfile/read/TsFileSequenceReader.java | 4 +-
.../iotdb/tsfile/utils/MeasurementGroup.java | 15 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 30 ++-
.../write/chunk/AlignedChunkGroupWriterImpl.java | 10 +-
.../tsfile/write/chunk/IChunkGroupWriter.java | 6 +-
.../chunk/NonAlignedChunkGroupWriterImpl.java | 7 +-
.../apache/iotdb/tsfile/write/record/Tablet.java | 20 +-
...asurementSchema.java => MeasurementSchema.java} | 32 +--
.../apache/iotdb/tsfile/write/schema/Schema.java | 6 +-
.../tsfile/file/metadata/utils/TestHelper.java | 6 +-
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 4 +-
.../read/query/timegenerator/ReadWriteTest.java | 8 +-
.../timegenerator/TimeGeneratorReadEmptyTest.java | 6 +-
.../timegenerator/TimeGeneratorReadWriteTest.java | 6 +-
.../TsFileGeneratorForSeriesReaderByTimestamp.java | 26 +-
.../apache/iotdb/tsfile/utils/FileGenerator.java | 28 +--
.../apache/iotdb/tsfile/utils/RecordUtilsTest.java | 18 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 55 ++---
.../tsfile/write/DefaultSchemaTemplateTest.java | 13 +-
.../tsfile/write/MetadataIndexConstructorTest.java | 13 +-
.../org/apache/iotdb/tsfile/write/PerfTest.java | 24 +-
.../iotdb/tsfile/write/ReadPageInMemTest.java | 26 +-
...SameMeasurementsWithDifferentDataTypesTest.java | 12 +-
.../iotdb/tsfile/write/TsFileIOWriterTest.java | 12 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 8 +-
.../iotdb/tsfile/write/TsFileWriteApiTest.java | 40 ++--
.../iotdb/tsfile/write/TsFileWriterTest.java | 44 ++--
.../org/apache/iotdb/tsfile/write/WriteTest.java | 16 +-
.../write/schema/converter/SchemaBuilderTest.java | 20 +-
.../write/writer/ForceAppendTsFileWriterTest.java | 10 +-
.../writer/MeasurementSchemaSerializeTest.java | 14 +-
.../iotdb/tsfile/write/writer/PageWriterTest.java | 14 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 52 ++--
129 files changed, 1365 insertions(+), 923 deletions(-)
create mode 100644 example/client-cpp-example/src/AlignedTimeseriesSessionExample.cpp
rename integration/src/test/java/org/apache/iotdb/db/integration/{ => aligned}/IOTDBInsertAlignedValuesIT.java (73%)
rename tsfile/src/main/java/org/apache/iotdb/tsfile/write/schema/{UnaryMeasurementSchema.java => MeasurementSchema.java} (91%)