-
Notifications
You must be signed in to change notification settings - Fork 4k
ARROW-6265: [Java] Avro adapter implement Array/Map/Fixed type #5099
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
|
cc @emkornfield |
java/adapter/avro/src/main/java/org/apache/arrow/AvroToArrowUtils.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/AvroToArrowUtils.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/consumers/AvroArraysConsumer.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/consumers/AvroArraysConsumer.java
Outdated
Show resolved
Hide resolved
Codecov Report
@@ Coverage Diff @@
## master #5099 +/- ##
==========================================
+ Coverage 87.64% 89.76% +2.12%
==========================================
Files 1014 685 -329
Lines 145922 102521 -43401
Branches 1437 0 -1437
==========================================
- Hits 127887 92027 -35860
+ Misses 17673 10494 -7179
+ Partials 362 0 -362
Continue to review full report at Codecov.
|
java/adapter/avro/src/main/java/org/apache/arrow/consumers/AvroArraysConsumer.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/consumers/AvroArraysConsumer.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/consumers/AvroFixedConsumer.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/consumers/AvroMapConsumer.java
Outdated
Show resolved
Hide resolved
|
sorry haven't gotten all the way through the review, will try to so later. |
|
@emkornfield Hi, Micah, I updated this PR according to your suggestion, please see if we could get it merged? I think I could provide a iterator API after then. thanks! |
|
@emkornfield Micah, when you have time, remember to take a look at this one, thanks :) |
java/adapter/avro/src/main/java/org/apache/arrow/AvroToArrowUtils.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/AvroToArrowUtils.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/consumers/AvroArraysConsumer.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/consumers/AvroFixedConsumer.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/AvroToArrowUtils.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/consumers/AvroMapConsumer.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/consumers/AvroMapConsumer.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/consumers/AvroMapConsumer.java
Outdated
Show resolved
Hide resolved
java/vector/src/main/java/org/apache/arrow/vector/complex/AbstractStructVector.java
Outdated
Show resolved
Hide resolved
|
just did.
…On Thu, Aug 22, 2019 at 8:55 PM tianchen92 ***@***.***> wrote:
@emkornfield <https://github.com/emkornfield> Micah, when you have time,
remember to take a look at this one, thanks :)
—
You are receiving this because you were mentioned.
Reply to this email directly, view it on GitHub
<#5099?email_source=notifications&email_token=AEIKYDTS2NM2JYUWEIVHXRLQF5NRPA5CNFSM4IMEFTJKYY3PNVWWK3TUL52HS4DFVREXG43VMVBW63LNMVXHJKTDN5WW2ZLOORPWSZGOD47BN2A#issuecomment-524162792>,
or mute the thread
<https://github.com/notifications/unsubscribe-auth/AEIKYDTO2VWP4KCNS2XF2ALQF5NRPANCNFSM4IMEFTJA>
.
|
|
@emkornfield Hi Micah, I did a refactor, please take another look |
|
@emkornfield Micah, please help take a look when you have a time :) |
java/adapter/avro/src/main/java/org/apache/arrow/consumers/AvroMapConsumer.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/consumers/AvroStructConsumer.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/consumers/AvroStructConsumer.java
Outdated
Show resolved
Hide resolved
java/adapter/avro/src/main/java/org/apache/arrow/AvroToArrowUtils.java
Outdated
Show resolved
Hide resolved
|
@tianchen92 looking better, but still have some comments.. Thank you for the quick turn arounds. In general, while try to review every night I don't necessarily always have time. Please, only ping me if you haven't heard anything on a review for 5 business days (also once you've updated and something is ready for review, you can use the github request re-review feature). |
|
@emkornfield Thanks for your careful review, revised according to your comments. |
|
@emkornfield PR updated, please help take a look, thanks! |
java/adapter/avro/src/main/java/org/apache/arrow/consumers/AvroStructConsumer.java
Outdated
Show resolved
Hide resolved
emkornfield
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.
One small issue, otherwise I think we can merge this and move on. At some point it might be good to refactor some logic from the primitive consumers into a base class.
Thanks, I fixed now. Also I have a question about Enum type in https://issues.apache.org/jira/browse/ARROW-6356 please take a look~ |
|
@emkornfield build passed, I think we could get it merged and I will submit a follow-up PR today, thanks. |
|
cc @emkornfield |
|
@ursabot build |
|
+1, Please lets make sure to get test coverage directly on StructConsumer in a follow-up PR. |
Related to [ARROW-6225](https://issues.apache.org/jira/browse/ARROW-6265). Closes apache#5099 from tianchen92/ARROW-6265 and squashes the following commits: 456a532 <tianchen> fix ac9540d <tianchen> fix test 788fef1 <tianchen> fix 3639520 <tianchen> refactor a415e93 <tianchen> fix array/map consume logic 54c6662 <tianchen> avoid mem copy bb5346e <tianchen> fix array and map consumer f435f66 <tianchen> add comments and fix array/map consumers 790471f <tianchen> fix style 37789be <tianchen> support fixed type 73edd51 <tianchen> initial support array and map Authored-by: tianchen <[email protected]> Signed-off-by: Micah Kornfield <[email protected]>
Related to ARROW-6225.