Skip to content

Commit ac2a8ea

Browse files
style(jni): format scan Arrow conversion
Signed-off-by: Christopher Wirt <cwirt@quantcast.com>
1 parent 7116d77 commit ac2a8ea

1 file changed

Lines changed: 10 additions & 10 deletions

File tree

‎vortex-jni/src/scan.rs‎

Lines changed: 10 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -366,23 +366,23 @@ pub extern "system" fn Java_dev_vortex_jni_NativePartition_scanArrow(
366366
handle.spawn(async move {
367367
let chunk = chunk?;
368368
let mut ctx = session.create_execution_ctx();
369-
let arrow = session.arrow().execute_arrow(
370-
chunk,
371-
Some(target.as_ref()),
372-
&mut ctx,
373-
)?;
369+
let arrow =
370+
session
371+
.arrow()
372+
.execute_arrow(chunk, Some(target.as_ref()), &mut ctx)?;
374373
rebase_offsets(RecordBatch::from(arrow.as_struct().clone()))
375374
})
376375
})
377376
.buffered(POOL.worker_count().max(1));
378377

379378
// Each JNI stream has a single consumer, so keep only one completed batch ahead of Java
380379
// rather than the per-core queue of `block_on_stream_thread_safe`.
381-
let iter = RUNTIME
382-
.block_on_stream_prefetch(batches)
383-
.map(|result: VortexResult<RecordBatch>| {
384-
result.map_err(|e| ArrowError::ExternalError(Box::new(e)))
385-
});
380+
let iter =
381+
RUNTIME
382+
.block_on_stream_prefetch(batches)
383+
.map(|result: VortexResult<RecordBatch>| {
384+
result.map_err(|e| ArrowError::ExternalError(Box::new(e)))
385+
});
386386

387387
let reader = RecordBatchIteratorAdapter::new(iter, schema);
388388
let arrow_stream = FFI_ArrowArrayStream::new(Box::new(reader));

0 commit comments

Comments
 (0)