Skip to content

Commit d307c8c

Browse files
committed
fix
1 parent 590d91d commit d307c8c

1 file changed

Lines changed: 8 additions & 8 deletions

File tree

_posts/2024-06-08-paper_review_arrow_datafusion.md

Lines changed: 8 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -82,15 +82,15 @@ Apache Arrow DataFusion : Rust 및 Apache Arrow 메모리 모델 기반으로
8282
- 파이프라인을 깨는 연산(풀 정렬, 최종 집계, 해시 조인)은 필요하다면 디스크에 스필한다.
8383
```rust
8484
impl Stream for MyOperator {
85-
...
86-
// Pull next input (may yield at await)
87-
while let Some(batch) = stream.next().await {
88-
// Calculate, check if output is ready
89-
if Some(output) = self.process(&batch)? {
90-
// "Return" RecordBatch to output
91-
tx.send(batch).await
85+
...
86+
// Pull next input (may yield at await)
87+
while let Some(batch) = stream.next().await {
88+
// Calculate, check if output is ready
89+
if Some(output) = self.process(&batch)? {
90+
// "Return" RecordBatch to output
91+
tx.send(batch).await
92+
}
9293
}
93-
}
9494
}
9595
```
9696
- Multi-Core Execution

0 commit comments

Comments
 (0)