1 file changed
+1
-1
lines changed- src/v/datalake/data_writer_interface.cc+2
- src/v/datalake/data_writer_interface.h+70-4
- src/v/datalake/local_parquet_file_writer.cc+34-8
- src/v/datalake/local_parquet_file_writer.h+14-3
- src/v/datalake/partitioning_writer.cc+30-3
- src/v/datalake/partitioning_writer.h+7-1
- src/v/datalake/record_multiplexer.cc+63-30
- src/v/datalake/record_multiplexer.h+51-10
- src/v/datalake/serde_parquet_writer.cc+29-5
- src/v/datalake/serde_parquet_writer.h+18-5
- src/v/datalake/tests/BUILD+3
- src/v/datalake/tests/gtest_record_multiplexer_test.cc+18-17
- src/v/datalake/tests/local_parquet_file_writer_test.cc+21-9
- src/v/datalake/tests/partitioning_writer_test.cc+9-5
- src/v/datalake/tests/record_multiplexer_bench.cc+7-8
- src/v/datalake/tests/record_multiplexer_test.cc+23-8
- src/v/datalake/tests/serde_parquet_writer_test.cc+6-2
- src/v/datalake/tests/test_data_writer.h+32-5
- src/v/datalake/tests/translation_task_test.cc+38-30
- src/v/datalake/translation/BUILD+17
- src/v/datalake/translation/CMakeLists.txt+2-1
- src/v/datalake/translation/deps.cc+21
- src/v/datalake/translation/deps.h+24
- src/v/datalake/translation/partition_translator.cc+10-17
- src/v/datalake/translation_task.cc+37-19
- src/v/datalake/translation_task.h+24-9
- src/v/serde/parquet/writer.cc+7-2
- src/v/serde/parquet/writer.h+1-1
- src/v/utils/BUILD+3
- src/v/utils/CMakeLists.txt+1
- src/v/utils/null_output_stream.cc+43
- src/v/utils/null_output_stream.h+8-19
0 commit comments