Skip to content

Commit

Permalink
Merge pull request #24117 from mmaslankaprv/parquet-values
Browse files Browse the repository at this point in the history
Added conversion from `iceberg::value` to `serde::parquet::value`
  • Loading branch information
mmaslankaprv authored Nov 14, 2024
2 parents fa1ff88 + 5819cd6 commit 3d70d13
Show file tree
Hide file tree
Showing 8 changed files with 619 additions and 0 deletions.
17 changes: 17 additions & 0 deletions src/v/datalake/BUILD
Original file line number Diff line number Diff line change
Expand Up @@ -439,3 +439,20 @@ redpanda_cc_library(
"//src/v/serde/parquet:schema",
],
)

redpanda_cc_library(
name = "values_parquet",
srcs = [
"values_parquet.cc",
],
hdrs = [
"values_parquet.h",
],
include_prefix = "datalake",
visibility = [":__subpackages__"],
deps = [
":conversion_outcome",
"//src/v/iceberg:values",
"//src/v/serde/parquet:value",
],
)
1 change: 1 addition & 0 deletions src/v/datalake/CMakeLists.txt
Original file line number Diff line number Diff line change
Expand Up @@ -49,6 +49,7 @@ v_cc_library(
cloud_data_io.cc
translation_task.cc
schema_parquet.cc
values_parquet.cc
DEPS
v::cloud_io
v::datalake_common
Expand Down
2 changes: 2 additions & 0 deletions src/v/datalake/tests/BUILD
Original file line number Diff line number Diff line change
Expand Up @@ -282,7 +282,9 @@ redpanda_cc_gtest(
deps = [
"//src/v/bytes:iobuf_parser",
"//src/v/datalake:schema_parquet",
"//src/v/datalake:values_parquet",
"//src/v/iceberg:datatypes",
"//src/v/iceberg/tests:value_generator",
"//src/v/test_utils:gtest",
"//src/v/test_utils:random",
"@fmt",
Expand Down
Loading

0 comments on commit 3d70d13

Please sign in to comment.