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

store split_fields in split #4190

Merged
merged 6 commits into from
Dec 4, 2023
Merged

store split_fields in split #4190

merged 6 commits into from
Dec 4, 2023

Conversation

PSeitz
Copy link
Contributor

@PSeitz PSeitz commented Nov 23, 2023

Description

Describe the proposed changes made in this PR.

How was this PR tested?

Describe how you tested this PR.

@PSeitz PSeitz force-pushed the list_fields branch 6 times, most recently from d93ed7a to d76e27e Compare November 24, 2023 06:09
@@ -5528,6 +5528,7 @@ dependencies = [
"ulid",
"utoipa",
"vrl",
"zstd 0.13.0",
Copy link
Contributor

Choose a reason for hiding this comment

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

we have several version of zstd?

Copy link
Contributor

Choose a reason for hiding this comment

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

ah yes. so zstd 0.11 is pulled by lindera's build deps.
0.13 is correct.

@@ -116,13 +117,14 @@ impl SplitPayloadBuilder {
/// Creates a new SplitPayloadBuilder for given files and hotcache.
pub fn get_split_payload(
split_files: &[PathBuf],
serialized_split_fields: &[u8],
Copy link
Contributor

Choose a reason for hiding this comment

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

You wanted really hard to avoid writing on the file system?

Copy link
Contributor Author

@PSeitz PSeitz Nov 24, 2023

Choose a reason for hiding this comment

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

Just seemed unnecessary and wasn't much effort. If there's another case, we probably should refactor it to something like

enum SplitFile{
   OnDisk(PathBuf),
   InMemory(String, Vec<u8>)
}

Copy link
Contributor

Choose a reason for hiding this comment

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

So if I recall correctly, down the stream, we build a PutPayload off these files.

Would it be possible to carry a PutPayload earlier maybe?

Copy link
Contributor Author

Choose a reason for hiding this comment

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

I moved it earlier in the code

@PSeitz PSeitz marked this pull request as ready for review November 29, 2023 02:33
@PSeitz PSeitz merged commit 73fde83 into main Dec 4, 2023
4 checks passed
@PSeitz PSeitz deleted the list_fields branch December 4, 2023 09:38
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants