You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by da...@apache.org on 2022/03/10 08:46:55 UTC
[hudi] branch master updated (034adda -> ec24407)
This is an automated email from the ASF dual-hosted git repository.
danny0405 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git.
from 034adda [HUDI-3396] Make sure `BaseFileOnlyViewRelation` only reads projected columns (#4818)
add ec24407 [HUDI-3581] Reorganize some clazz for hudi flink (#4983)
No new revisions were added by this update.
Summary of changes:
.../main/java/org/apache/hudi/async/HoodieAsyncService.java | 1 +
.../java/org/apache/hudi/client/BaseHoodieWriteClient.java | 11 +++++++++--
.../org/apache/hudi/sink/StreamWriteOperatorCoordinator.java | 2 +-
.../apache/hudi/table/format/cow/CopyOnWriteInputFormat.java | 1 +
.../apache/hudi/table/format/cow/ParquetSplitReaderUtil.java | 4 ++++
.../table/format/cow/{ => vector}/ParquetDecimalVector.java | 2 +-
.../format/cow/{ => vector/reader}/AbstractColumnReader.java | 2 +-
.../table/format/cow/vector/reader/ArrayColumnReader.java | 2 +-
.../cow/{ => vector/reader}/FixedLenBytesColumnReader.java | 3 +--
.../cow/{ => vector/reader}/Int64TimestampColumnReader.java | 2 +-
.../{ => vector/reader}/ParquetColumnarRowSplitReader.java | 4 +++-
.../format/cow/{ => vector/reader}/RunLengthDecoder.java | 2 +-
.../apache/hudi/table/format/mor/MergeOnReadInputFormat.java | 2 +-
.../{StreamWriteITCase.java => ITTestDataStreamWrite.java} | 2 +-
...oodieDataSourceITCase.java => ITTestHoodieDataSource.java} | 2 +-
15 files changed, 28 insertions(+), 14 deletions(-)
rename hudi-flink/src/main/java/org/apache/hudi/table/format/cow/{ => vector}/ParquetDecimalVector.java (97%)
rename hudi-flink/src/main/java/org/apache/hudi/table/format/cow/{ => vector/reader}/AbstractColumnReader.java (99%)
rename hudi-flink/src/main/java/org/apache/hudi/table/format/cow/{ => vector/reader}/FixedLenBytesColumnReader.java (98%)
rename hudi-flink/src/main/java/org/apache/hudi/table/format/cow/{ => vector/reader}/Int64TimestampColumnReader.java (98%)
rename hudi-flink/src/main/java/org/apache/hudi/table/format/cow/{ => vector/reader}/ParquetColumnarRowSplitReader.java (99%)
rename hudi-flink/src/main/java/org/apache/hudi/table/format/cow/{ => vector/reader}/RunLengthDecoder.java (99%)
rename hudi-flink/src/test/java/org/apache/hudi/sink/{StreamWriteITCase.java => ITTestDataStreamWrite.java} (99%)
rename hudi-flink/src/test/java/org/apache/hudi/table/{HoodieDataSourceITCase.java => ITTestHoodieDataSource.java} (99%)