-
Notifications
You must be signed in to change notification settings - Fork 2.5k
[HUDI-7350] Make Hudi reader and writer factory APIs Hadoop-independent #11163
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
…Utils#getFSDataInputStream part
1a3d7a8 to
5bf8143
Compare
hudi-common/src/main/java/org/apache/hudi/common/table/log/block/HoodieParquetDataBlock.java
Outdated
Show resolved
Hide resolved
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieAvroFileReader.java
Outdated
Show resolved
Hide resolved
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieFileReaderFactory.java
Outdated
Show resolved
Hide resolved
hudi-common/src/main/java/org/apache/hudi/io/storage/HoodieFileWriterFactory.java
Outdated
Show resolved
Hide resolved
hudi-common/src/test/java/org/apache/hudi/common/testutils/reader/HoodieTestReaderContext.java
Outdated
Show resolved
Hide resolved
...doop-common/src/main/java/org/apache/hudi/io/storage/hadoop/HoodieAvroFileReaderFactory.java
Outdated
Show resolved
Hide resolved
hudi-hadoop-common/src/main/java/org/apache/hudi/io/storage/hadoop/HoodieBaseParquetWriter.java
Outdated
Show resolved
Hide resolved
| baseInstantTime, | ||
| new LocalTaskContextSupplier(), | ||
| true)) { | ||
| HoodieConfig cfg = new HoodieConfig(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Should this test class be moved to hudi-hadoop-common module? HoodieAvroWriteSupport<IndexedRecord> needs to be tested.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
not sure what you are suggesting here
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Basically, making sure that the bloom filter writing is tested with HoodieAvroWriteSupport.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
yihua
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Also, rename the PR to "Make Hudi reader and writer factory APIs Hadoop-independent"?
yihua
left a comment
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
LGTM
…nt (#11163) Abstract io reader and writer to de-hadoop --------- Co-authored-by: Jonathan Vexler <=>
…nt (#11163) Abstract io reader and writer to de-hadoop --------- Co-authored-by: Jonathan Vexler <=>


Change Logs
Abstract io reader and writer to de-hadoop
Impact
de-hadooping for trino
Risk level (write none, low medium or high below)
low
Documentation Update
N/A
Contributor's checklist