You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ja...@apache.org on 2021/11/19 09:29:05 UTC
[iotdb] branch ty_new_vector updated (636b1f6 -> 005bdd7)
This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty_new_vector
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 636b1f6 add value filter IT
add 7ff968c [IOTDB-2027] Rollback invalid entry after wal writing failure (#4424)
add fc31d50 [IOTDB-1926]TsFile API supports query on aligned timeseries (#4390)
add 005bdd7 Merge remote-tracking branch 'origin/master' into ty_new_vector
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/iotdb/flink/TsFileUtils.java | 4 +-
.../java/org/apache/iotdb/tsfile/TsFileRead.java | 8 +-
.../apache/iotdb/tsfile/TsFileSequenceRead.java | 2 +-
.../apache/iotdb/tsfile/TsFileWriteWithTablet.java | 2 +-
.../iotdb/flink/tsfile/TsFileInputFormat.java | 6 +-
.../tsfile/RowTsFileOutputFormatTestBase.java | 4 +-
.../iotdb/hadoop/tsfile/TSFRecordReader.java | 4 +-
.../iotdb/db/engine/cache/AccountableString.java | 64 ---
.../org/apache/iotdb/db/mqtt/PublishHandler.java | 16 +-
.../apache/iotdb/db/qp/physical/PhysicalPlan.java | 22 +-
.../iotdb/db/qp/physical/crud/DeletePlan.java | 2 +-
.../db/qp/physical/crud/InsertMultiTabletPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/InsertRowPlan.java | 2 +-
.../physical/crud/InsertRowsOfOneDevicePlan.java | 2 +-
.../iotdb/db/qp/physical/crud/InsertRowsPlan.java | 2 +-
.../db/qp/physical/crud/InsertTabletPlan.java | 2 +-
.../iotdb/db/qp/physical/crud/SelectIntoPlan.java | 2 +-
.../db/qp/physical/sys/ActivateTemplatePlan.java | 2 +-
.../db/qp/physical/sys/AppendTemplatePlan.java | 2 +-
.../iotdb/db/qp/physical/sys/AuthorPlan.java | 2 +-
.../qp/physical/sys/AutoCreateDeviceMNodePlan.java | 2 +-
.../iotdb/db/qp/physical/sys/ChangeAliasPlan.java | 2 +-
.../db/qp/physical/sys/ChangeTagOffsetPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/ClearCachePlan.java | 2 +-
.../physical/sys/CreateAlignedTimeSeriesPlan.java | 2 +-
.../qp/physical/sys/CreateContinuousQueryPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/CreateIndexPlan.java | 2 +-
.../qp/physical/sys/CreateMultiTimeSeriesPlan.java | 2 +-
.../db/qp/physical/sys/CreateSnapshotPlan.java | 2 +-
.../db/qp/physical/sys/CreateTemplatePlan.java | 2 +-
.../db/qp/physical/sys/CreateTimeSeriesPlan.java | 2 +-
.../db/qp/physical/sys/CreateTriggerPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/DataAuthPlan.java | 2 +-
.../db/qp/physical/sys/DeleteStorageGroupPlan.java | 2 +-
.../db/qp/physical/sys/DeleteTimeSeriesPlan.java | 2 +-
.../qp/physical/sys/DropContinuousQueryPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/DropIndexPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/DropTriggerPlan.java | 2 +-
.../apache/iotdb/db/qp/physical/sys/FlushPlan.java | 2 +-
.../apache/iotdb/db/qp/physical/sys/MNodePlan.java | 2 +-
.../db/qp/physical/sys/MeasurementMNodePlan.java | 2 +-
.../apache/iotdb/db/qp/physical/sys/MergePlan.java | 2 +-
.../db/qp/physical/sys/PruneTemplatePlan.java | 2 +-
.../db/qp/physical/sys/SetStorageGroupPlan.java | 2 +-
.../db/qp/physical/sys/SetSystemModePlan.java | 2 +-
.../iotdb/db/qp/physical/sys/SetTTLPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/SetTemplatePlan.java | 2 +-
.../iotdb/db/qp/physical/sys/StartTriggerPlan.java | 2 +-
.../iotdb/db/qp/physical/sys/StopTriggerPlan.java | 2 +-
.../db/qp/physical/sys/StorageGroupMNodePlan.java | 2 +-
.../db/qp/physical/sys/UnsetTemplatePlan.java | 2 +-
.../db/writelog/node/ExclusiveWriteLogNode.java | 2 -
.../engine/compaction/cross/MergeOverLapTest.java | 2 +
.../inner/InnerSpaceCompactionUtilsTest.java | 4 +-
.../iotdb/db/qp/physical/PhysicalPlanTest.java | 61 +--
.../iotdb/db/utils/TsFileRewriteToolTest.java | 6 +-
.../db/writelog/recover/SeqTsFileRecoverTest.java | 18 +-
.../org/apache/iotdb/spark/tsfile/qp/Executor.java | 4 +-
.../apache/iotdb/spark/tsfile/DefaultSource.scala | 6 +-
.../iotdb/tsfile/common/cache/Accountable.java | 26 --
.../iotdb/tsfile/file/metadata/ChunkMetadata.java | 14 +-
.../tsfile/file/metadata/TimeseriesMetadata.java | 13 +-
.../{ReadOnlyTsFile.java => TsFileReader.java} | 4 +-
.../iotdb/tsfile/read/TsFileSequenceReader.java | 190 ++++++--
.../org/apache/iotdb/tsfile/read/common/Chunk.java | 13 +-
.../org/apache/iotdb/tsfile/read/common/Field.java | 26 ++
.../read/controller/MetadataQuerierByFileImpl.java | 87 ++--
.../query/dataset/DataSetWithTimeGenerator.java | 15 +-
.../query/dataset/DataSetWithoutTimeGenerator.java | 24 +-
.../read/reader/chunk/AlignedChunkReader.java | 6 +-
...amp.java => AlignedChunkReaderByTimestamp.java} | 15 +-
.../reader/series/AbstractFileSeriesReader.java | 4 +-
.../read/reader/series/FileSeriesReader.java | 18 +-
.../reader/series/FileSeriesReaderByTimestamp.java | 28 +-
.../tsfile/v2/read/TsFileSequenceReaderForV2.java | 21 +-
.../apache/iotdb/tsfile/write/TsFileWriter.java | 84 +++-
.../write/chunk/AlignedChunkGroupWriterImpl.java | 44 +-
.../chunk/NonAlignedChunkGroupWriterImpl.java | 40 +-
.../iotdb/tsfile/write/writer/TsFileIOWriter.java | 16 +-
.../iotdb/tsfile/read/ReadInPartitionTest.java | 4 +-
.../iotdb/tsfile/read/ReadOnlyTsFileTest.java | 241 -----------
.../org/apache/iotdb/tsfile/read/ReadTest.java | 4 +-
.../iotdb/tsfile/read/TimePlainEncodeReadTest.java | 4 +-
.../apache/iotdb/tsfile/read/TsFileReaderTest.java | 477 +++++++++++++++++++++
.../tsfile/read/TsFileSequenceReaderTest.java | 4 +-
.../read/query/timegenerator/ReadWriteTest.java | 6 +-
.../timegenerator/TimeGeneratorReadEmptyTest.java | 6 +-
.../timegenerator/TimeGeneratorReadWriteTest.java | 6 +-
.../iotdb/tsfile/utils/TsFileGeneratorForTest.java | 122 ++++++
.../tsfile/write/DefaultSchemaTemplateTest.java | 4 +-
...SameMeasurementsWithDifferentDataTypesTest.java | 6 +-
.../iotdb/tsfile/write/TsFileReadWriteTest.java | 6 +-
.../iotdb/tsfile/write/TsFileWriteApiTest.java | 266 +++++++-----
.../iotdb/tsfile/write/TsFileWriterTest.java | 14 +-
.../write/writer/ForceAppendTsFileWriterTest.java | 8 +-
.../write/writer/RestorableTsFileIOWriterTest.java | 15 +-
96 files changed, 1372 insertions(+), 826 deletions(-)
delete mode 100644 server/src/main/java/org/apache/iotdb/db/engine/cache/AccountableString.java
delete mode 100644 tsfile/src/main/java/org/apache/iotdb/tsfile/common/cache/Accountable.java
rename tsfile/src/main/java/org/apache/iotdb/tsfile/read/{ReadOnlyTsFile.java => TsFileReader.java} (94%)
copy tsfile/src/main/java/org/apache/iotdb/tsfile/read/reader/chunk/{ChunkReaderByTimestamp.java => AlignedChunkReaderByTimestamp.java} (71%)
delete mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/read/ReadOnlyTsFileTest.java
create mode 100644 tsfile/src/test/java/org/apache/iotdb/tsfile/read/TsFileReaderTest.java