-
Notifications
You must be signed in to change notification settings - Fork 3.4k
Pre-populate file length and modifiedTime in LinePageSourceFactory #26615
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
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.
Pull Request Overview
This PR modifies the LinePageSourceFactory to pre-populate file metadata (length and modified time) when creating TrinoInputFile objects. This optimization allows S3InputStream to avoid aborting connections and enables the filesystem cache to avoid extra filesystem operations by providing metadata upfront rather than fetching it lazily.
- Pre-populates TrinoInputFile with file length and modification time
- Updates method signature to accept fileModifiedTime parameter
- Passes estimatedFileSize and fileModifiedTime to the TrinoInputFile constructor
Tip: Customize your code reviews with copilot-instructions.md. Create the file or learn how to get started.
|
Failure is related |
Allows S3InputStream#closeStream to avoid aborting connections Allows filsystem cache to avoid extra FS operations
2a5f9bb to
f82e822
Compare
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.
Pull Request Overview
Copilot reviewed 4 out of 4 changed files in this pull request and generated 1 comment.
Tip: Customize your code reviews with copilot-instructions.md. Create the file or learn how to get started.
...ive-formats/src/main/java/io/trino/hive/formats/line/sequence/SequenceFileReaderFactory.java
Show resolved
Hide resolved
wendigo
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
Description
Allows S3InputStream#closeStream to avoid aborting connections
Allows filsystem cache to avoid extra FS operations
Additional context and related issues
Release notes
(x) This is not user-visible or is 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: