Skip to content

Commit 780c65d

Browse files
committed
small fix for upstream ByteStream rename to ByteOutputStream which will be dropped in next rebase
1 parent 0827ca1 commit 780c65d

File tree

2 files changed

+5
-4
lines changed

2 files changed

+5
-4
lines changed

velox/common/memory/tests/HashStringAllocatorTest.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -292,7 +292,7 @@ TEST_F(HashStringAllocatorTest, mixedMultipart) {
292292
const std::string shortString(25, 'x');
293293
const std::string extraLongString(5'000, 'y');
294294

295-
ByteStream stream(allocator_.get());
295+
ByteOutputStream stream(allocator_.get());
296296

297297
auto start = allocator_->newWrite(stream);
298298
stream.appendStringView(shortString);

velox/dwio/parquet/writer/Writer.cpp

Lines changed: 4 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -142,9 +142,10 @@ namespace {
142142
void exportToArrow(
143143
const TypePtr& type,
144144
std::shared_ptr<memory::MemoryPool> pool,
145-
ArrowSchema& out) {
145+
ArrowSchema& out,
146+
const ArrowOptions& options) {
146147
auto leafPool = pool->addLeafChild("parquet-write-schema-convert");
147-
exportToArrow(BaseVector::create(type, 0, leafPool.get()), out);
148+
exportToArrow(BaseVector::create(type, 0, leafPool.get()), out, options);
148149
}
149150

150151
} // namespace
@@ -170,7 +171,7 @@ Writer::Writer(
170171

171172
if (options.schema) {
172173
ArrowSchema arrowSchema;
173-
exportToArrow(options.schema, pool_, arrowSchema);
174+
exportToArrow(options.schema, pool_, arrowSchema, options_);
174175

175176
PARQUET_ASSIGN_OR_THROW(
176177
arrowContext_->schema, ::arrow::ImportSchema(&arrowSchema));

0 commit comments

Comments
 (0)