This is an automated email from the ASF dual-hosted git repository.
akudinkin pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git
from 96032b9b768 [HUDI-5557]Avoid converting columns that are not indexed
in CSI (#7672)
add 25fc4f2ab52 [MINOR] De-duplicating Iterator implementations (#7752)
No new revisions were added by this update.
Summary of changes:
.../hudi/cli/commands/ArchivedCommitsCommand.java | 2 +-
.../apache/hudi/cli/commands/ExportCommand.java | 2 +-
.../hudi/cli/commands/HoodieLogFileCommand.java | 2 +-
.../table/action/commit/HoodieMergeHelper.java | 2 +-
.../MultipleSparkJobExecutionStrategy.java | 6 +--
.../strategy/SingleSparkJobExecutionStrategy.java | 6 +--
.../hudi/io/storage/HoodieSparkParquetReader.java | 6 +--
.../functional/TestHoodieBackedMetadata.java | 2 +-
.../functional/TestHoodieBackedTableMetadata.java | 2 +-
.../table/log/AbstractHoodieLogRecordReader.java | 29 +++++++-----
.../table/log/HoodieCDCLogRecordIterator.java | 6 +--
.../table/log/block/HoodieAvroDataBlock.java | 9 ++--
.../common/table/log/block/HoodieDataBlock.java | 2 +-
.../table/log/block/HoodieHFileDataBlock.java | 6 +--
.../table/log/block/HoodieParquetDataBlock.java | 2 +-
.../table/timeline/HoodieArchivedTimeline.java | 2 +-
.../org/apache/hudi/common/util/BaseFileUtils.java | 1 +
.../common/util/ClosableIteratorWithSchema.java | 55 ----------------------
.../apache/hudi/common/util/IdentityIterator.java | 44 -----------------
.../apache/hudi/common/util/MappingIterator.java | 47 ------------------
.../apache/hudi/common/util/OrcReaderIterator.java | 1 +
.../java/org/apache/hudi/common/util/OrcUtils.java | 1 +
.../hudi/common/util/ParquetReaderIterator.java | 1 +
.../org/apache/hudi/common/util/ParquetUtils.java | 1 +
.../common/util/collection/BitCaskDiskMap.java | 1 -
.../util/{ => collection}/ClosableIterator.java | 23 ++++++++-
.../util/collection/CloseableMappingIterator.java | 9 ++--
.../common/util/collection/LazyFileIterable.java | 1 -
.../util/queue/IteratorBasedQueueProducer.java | 2 +-
.../hudi/io/storage/HoodieAvroFileReaderBase.java | 6 +--
.../hudi/io/storage/HoodieAvroHFileReader.java | 8 ++--
.../hudi/io/storage/HoodieAvroOrcReader.java | 2 +-
.../hudi/io/storage/HoodieAvroParquetReader.java | 6 +--
.../apache/hudi/io/storage/HoodieFileReader.java | 2 +-
.../hudi/io/storage/HoodieSeekingFileReader.java | 2 +-
.../hudi/metadata/HoodieBackedTableMetadata.java | 2 +-
.../common/functional/TestHoodieLogFormat.java | 2 +-
.../hudi/sink/bootstrap/BootstrapOperator.java | 2 +-
.../hudi/sink/clustering/ClusteringOperator.java | 4 +-
.../table/format/ParquetSplitRecordIterator.java | 2 +-
.../apache/hudi/table/format/RecordIterators.java | 2 +-
.../table/format/SchemaEvolvedRecordIterator.java | 2 +-
.../hudi/table/format/cdc/CdcInputFormat.java | 2 +-
.../table/format/cow/CopyOnWriteInputFormat.java | 2 +-
.../table/format/mor/MergeOnReadInputFormat.java | 2 +-
.../reader/DFSHoodieDatasetInputReader.java | 4 +-
.../hudi/utilities/deltastreamer/DeltaSync.java | 6 +--
47 files changed, 105 insertions(+), 226 deletions(-)
delete mode 100644
hudi-common/src/main/java/org/apache/hudi/common/util/ClosableIteratorWithSchema.java
delete mode 100644
hudi-common/src/main/java/org/apache/hudi/common/util/IdentityIterator.java
delete mode 100644
hudi-common/src/main/java/org/apache/hudi/common/util/MappingIterator.java
rename hudi-common/src/main/java/org/apache/hudi/common/util/{ =>
collection}/ClosableIterator.java (70%)
