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.

Sign up for GitHub

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

enhance: Adding a generic stream payload reader #30682

Merged
merged 3 commits into from
Feb 21, 2024
Merged

enhance: Adding a generic stream payload reader #30682

Changes from 1 commit
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
342e0ab
Adding a generic stream payload reader.
tedxu Feb 20, 2024
4d15cb9
Code style fixes.
tedxu Feb 20, 2024
1dc2e2a
Close readers early in data_codec
tedxu Feb 20, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
Code style fixes. 
Signed-off-by: Ted Xu <ted.xu@zilliz.com>
  • Loading branch information
@tedxu
tedxu committed Feb 20, 2024
commit 4d15cb970b0dd2f5fafc1e7a5c750d5df701d1ad
2 changes: 2 additions & 0 deletions internal/storage/payload_test.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1437,6 +1437,7 @@ func BenchmarkDefaultReader(b *testing.B) {
}
}
}

func BenchmarkDataSetReader(b *testing.B) {
size := 1000000
buffer, err := dataGen(size)
Expand Down Expand Up @@ -1464,6 +1465,7 @@ func BenchmarkDataSetReader(b *testing.B) {
}
}
}

func BenchmarkArrowRecordReader(b *testing.B) {
size := 1000000
buffer, err := dataGen(size)
Expand Down
Loading