Skip to content

Commit 323768f

Browse files
authored
Merge branch 'main' into avro_writer
2 parents 0fd82d4 + ff8eea9 commit 323768f

25 files changed

+3178
-69
lines changed

src/iceberg/CMakeLists.txt

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,7 @@ set(ICEBERG_INCLUDES "$<BUILD_INTERFACE:${PROJECT_BINARY_DIR}/src>"
2020
set(ICEBERG_SOURCES
2121
arrow_c_data_guard_internal.cc
2222
catalog/memory/in_memory_catalog.cc
23+
delete_file_index.cc
2324
expression/aggregate.cc
2425
expression/binder.cc
2526
expression/evaluator.cc
@@ -80,6 +81,7 @@ set(ICEBERG_SOURCES
8081
update/update_properties.cc
8182
update/update_sort_order.cc
8283
util/bucket_util.cc
84+
util/content_file_util.cc
8385
util/conversions.cc
8486
util/decimal.cc
8587
util/gzip_internal.cc

src/iceberg/avro/avro_reader.cc

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -89,10 +89,10 @@ class AvroReader::Impl {
8989
read_schema_ = options.projection;
9090

9191
// Open the input stream and adapt to the avro interface.
92-
// TODO(gangwu): make this configurable
93-
constexpr int64_t kDefaultBufferSize = 1024 * 1024;
94-
ICEBERG_ASSIGN_OR_RAISE(auto input_stream,
95-
CreateInputStream(options, kDefaultBufferSize));
92+
ICEBERG_ASSIGN_OR_RAISE(
93+
auto input_stream,
94+
CreateInputStream(options,
95+
options.properties->Get(ReaderProperties::kAvroBufferSize)));
9696

9797
::avro::ValidSchema file_schema;
9898

0 commit comments

Comments
 (0)