Skip to content
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

Jump to bottom

Add reader and writer for Puffin, indexes and stats file format #4537

Merged
merged 1 commit into from Jun 15, 2022
Merged

Add reader and writer for Puffin, indexes and stats file format #4537

merged 1 commit into from Jun 15, 2022

Conversation

findepi
Copy link
Collaborator

@findepi findepi commented Apr 11, 2022 •
edited

Format documentation: #4944

@findepi findepi mentioned this pull request Apr 11, 2022
Merged
@findepi findepi mentioned this pull request Apr 11, 2022
Closed
rdblue
rdblue reviewed Apr 11, 2022
View reviewed changes
build.gradle Outdated Show resolved Hide resolved
@findepi
Copy link
Collaborator Author

findepi commented Apr 13, 2022

@rdblue i applied most of the comments (no more jackson-datatype-jdk8, json-related annotations, get in accessor names). I also switched over from base16-encoded test "fixtures" to test resources.

I switched writing to use ByteBuffer, this removes removed data copying upon compression.
This is as a fixup for now. Please let me know if you want me to use ByteBuffer in the reader/writer APIs as well?
It seems byte[] works there well (eg because uncompressed size is known, so no need to re-allocation), so please confirm before I apply further changes.

@rdblue
Copy link
Contributor

rdblue commented Apr 13, 2022

@findepi, I would prefer to use ByteBuffer everywhere. If the backing buffer was easy to allocate and work with, that's great. But you're not forced to reallocate if it is not.

@findepi
Copy link
Collaborator Author

findepi commented Apr 20, 2022

( squashed and rebased on top of current version of #4534, no other changes in this push )

@findepi
Copy link
Collaborator Author

findepi commented Apr 20, 2022

AC
@rdblue @singhpk234 thanks for your review, let me know what else I can change.

@findepi
Copy link
Collaborator Author

findepi commented Apr 22, 2022

AC & rebased after #4534 merged.

@findepi findepi force-pushed the findepi/stats-file branch 2 times, most recently from 872e253 to 9430d36 Compare June 9, 2022 12:54
@findepi findepi mentioned this pull request Jun 13, 2022
Merged
@findepi
Copy link
Collaborator Author

findepi commented Jun 14, 2022

Rebased after #5019 merged.

nastra
nastra reviewed Jun 15, 2022
View reviewed changes
Copy link
Contributor

@nastra nastra left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

overall LGTM, just a few suggestions here and there

core/src/main/java/org/apache/iceberg/puffin/BlobMetadata.java
return type;
}

public List<Integer> inputFields() {
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

the spec mentions that input fields are JSON longs, so I'm just wondering whether this should be a List<Long>?

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Iceberg field IDs are integers, so the implementation is chosen to be limited to integers.

We can maybe change fields | list of JSON long in the puffin spec to be list of integers.

Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Yes, we should update the spec to match the type used by the table spec for field IDs.

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

#5087

core/src/main/java/org/apache/iceberg/puffin/PuffinFormat.java Show resolved Hide resolved
core/src/main/java/org/apache/iceberg/puffin/PuffinFormat.java Show resolved Hide resolved
core/src/main/java/org/apache/iceberg/puffin/PuffinFormat.java Show resolved Hide resolved
core/src/main/java/org/apache/iceberg/puffin/PuffinFormat.java Outdated Show resolved Hide resolved
core/src/test/java/org/apache/iceberg/puffin/TestFileMetadataParser.java Show resolved Hide resolved
core/src/test/java/org/apache/iceberg/puffin/TestPuffinFormat.java Show resolved Hide resolved
core/src/test/java/org/apache/iceberg/puffin/TestPuffinFormat.java Show resolved Hide resolved
core/src/main/java/org/apache/iceberg/puffin/PuffinReader.java Show resolved Hide resolved
core/src/test/java/org/apache/iceberg/puffin/TestPuffinWriter.java Show resolved Hide resolved
@findepi findepi force-pushed the findepi/stats-file branch 2 times, most recently from d3ca971 to be6bb83 Compare June 15, 2022 11:01
@findepi findepi mentioned this pull request Jun 15, 2022
Closed
@findepi
Copy link
Collaborator Author

findepi commented Jun 15, 2022

Thanks @rdblue and @nastra for your reviews!

Updated the code accordingly. Please take another look.

@findepi findepi requested review from danielcweeks, nastra and rdblue and removed request for rdblue and danielcweeks June 15, 2022 11:52
rdblue
rdblue reviewed Jun 15, 2022
View reviewed changes
core/src/main/java/org/apache/iceberg/puffin/PuffinWriter.java
ByteBuffer footerPayload = PuffinFormat.compress(footerCompression, footerJson);
outputStream.write(MAGIC);
int footerPayloadLength = footerPayload.remaining();
writeFully(footerPayload);
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Minor: why not call IOUtil.writeFully(outputStream, footerPayload) directly rather than having a private writeFully method that just adds the output stream?

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

#5088

rdblue
rdblue reviewed Jun 15, 2022
View reviewed changes
core/src/main/java/org/apache/iceberg/io/IOUtil.java
if (!buffer.hasRemaining()) {
return;
}
byte[] chunk = new byte[WRITE_CHUNK_SIZE];
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Rather than allocating every time this is called, can you create a ThreadLocal to share this buffer? Alternatively, you could pass the temporary buffer in.

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Alternatively, you could pass the temporary buffer in.

This poses sizing challenge. I.e. the caller needs to provide a reasonably sized buffer.

Rather than allocating every time this is called, can you create a ThreadLocal to share this buffer?

Sure, this is feasible. Do you happen to know what would be the expected reuse ratio for such a buffer?

Alternatively we can have a static buffer pool that lends buffers to the current thread.
(assuming we have a problem that we want to fix here)

@rdblue rdblue merged commit a7f7c1a into apache:master Jun 15, 2022
@rdblue
Copy link
Contributor

rdblue commented Jun 15, 2022

Thanks, @findepi! This looks good to me. We can still follow up, but I think the majority of the changes are ready so I've merged it to avoid keeping a big PR outstanding.

@findepi findepi mentioned this pull request Jun 20, 2022
Merged
@findepi findepi deleted the findepi/stats-file branch June 20, 2022 07:32
@findepi findepi mentioned this pull request Jun 20, 2022
Merged
namrathamyske pushed a commit to namrathamyske/iceberg that referenced this pull request Jul 10, 2022
@findepi
Core: Add reader and writer for Puffin index and stats format (apache…
62ac4b0 
…#4537)
namrathamyske pushed a commit to namrathamyske/iceberg that referenced this pull request Jul 10, 2022
@findepi
Core: Add reader and writer for Puffin index and stats format (apache…
2051f04 
…#4537)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Reviewers

@RussellSpitzer RussellSpitzer RussellSpitzer left review comments

@alexjo2144 alexjo2144 alexjo2144 left review comments

@kbendick kbendick kbendick left review comments

@singhpk234 singhpk234 singhpk234 left review comments

@rdblue rdblue rdblue approved these changes

@nastra nastra nastra approved these changes

@danielcweeks danielcweeks Awaiting requested review from danielcweeks

Assignees
No one assigned
Labels
build core
Projects
None yet
Milestone
No milestone
Development

Successfully merging this pull request may close these issues.

None yet
9 participants
@findepi @rdblue @ggershinsky @nastra @RussellSpitzer @danielcweeks @alexjo2144 @kbendick @singhpk234