Inline hudi code and remove hadoop dependencies#17392
Inline hudi code and remove hadoop dependencies#17392electrum merged 3 commits intotrinodb:masterfrom
Conversation
5f0ac6c to
0c86328
Compare
anusudarsan
left a comment
There was a problem hiding this comment.
I reviewed half of it. In general I think we should stick with trino coding standards (including formatting style) in the commits. I have commented on some of the classes (like access modifiers of variables, requireNonNull checks etc), lets make sure the entire PR follows the same.
plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/HudiUtil.java
Outdated
Show resolved
Hide resolved
plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/compaction/CompactionOperation.java
Outdated
Show resolved
Hide resolved
plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/compaction/CompactionOperation.java
Outdated
Show resolved
Hide resolved
plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/compaction/CompactionOperation.java
Outdated
Show resolved
Hide resolved
There was a problem hiding this comment.
can we just use Location.appendSuffix here?
There was a problem hiding this comment.
actually we can't, it doesn't add '/' and was causing test failure that i was debugging for few hours ;)
There was a problem hiding this comment.
reformat the set calls to be in new line and more readable
There was a problem hiding this comment.
can you reformat this class ?
There was a problem hiding this comment.
What do you mean by reformat? I did use intellij reformat action, if you meant refactor then sure, I can try to simplify it a little
There was a problem hiding this comment.
Ok I did some manual reformatting of very ugly parts
c1d516d to
27c2d99
Compare
|
Nit: fix capitalization in commit title
|
27c2d99 to
785db54
Compare
plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/HudiUtil.java
Outdated
Show resolved
Hide resolved
plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/HudiUtil.java
Outdated
Show resolved
Hide resolved
plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/config/HoodieTableConfig.java
Outdated
Show resolved
Hide resolved
plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/config/HoodieTableConfig.java
Outdated
Show resolved
Hide resolved
plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/config/HoodieTableConfig.java
Outdated
Show resolved
Hide resolved
plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/files/FSUtils.java
Outdated
Show resolved
Hide resolved
plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/model/HoodieWriteStat.java
Outdated
Show resolved
Hide resolved
plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/model/HoodieTableType.java
Outdated
Show resolved
Hide resolved
plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/table/HoodieTableFileSystemView.java
Outdated
Show resolved
Hide resolved
plugin/trino-hudi/src/main/java/io/trino/plugin/hudi/table/HoodieTableFileSystemView.java
Outdated
Show resolved
Hide resolved
|
Is everything imported from Hudi needed? We only need to pass the existing tests. |
785db54 to
9ad58a1
Compare
49e7f35 to
282eb7d
Compare
Co-Authored-By: Konrad Dziedzic <konraddziedzic@gmail.com>
282eb7d to
64bc4da
Compare
Yes I think so, I tried to remove as much code as possible |
Description
This PR migrates hudi connector away from hudi libraries.
It is splitted into a general preparatory commit and 3 commits that migrates specific parts of hudi connector.
Because all of these classes were very interconnected it was not possible to split them into smaller, closer parts without breaking the functionality.
Big parts of the code was directly inlined from hudi libraries.
I didn't do refactoring that was not crucial to make the code work.
If you believe that this should be done please point it out.
Additional context and related issues
Release notes
( ) This is not user-visible or docs only and no release notes are required.
( ) Release notes are required, please propose a release note for me.
( ) Release notes are required, with the following suggested text: