fix

getChan · Feb 17, 2025 · d307c8c · d307c8c
1 parent 590d91d
commit d307c8c
Showing 1 changed file with 8 additions and 8 deletions.
diff --git a/_posts/2024-06-08-paper_review_arrow_datafusion.md b/_posts/2024-06-08-paper_review_arrow_datafusion.md
@@ -82,15 +82,15 @@ Apache Arrow DataFusion : Rust 및 Apache Arrow 메모리 모델 기반으로
   - 파이프라인을 깨는 연산(풀 정렬, 최종 집계, 해시 조인)은 필요하다면 디스크에 스필한다.
 ```rust
 impl Stream for MyOperator {
-  ...
-  // Pull next input (may yield at await)
-  while let Some(batch) = stream.next().await {
-    // Calculate, check if output is ready
-    if Some(output) = self.process(&batch)? {
-      // "Return" RecordBatch to output
-      tx.send(batch).await
+    ...
+    // Pull next input (may yield at await)
+    while let Some(batch) = stream.next().await {
+        // Calculate, check if output is ready
+        if Some(output) = self.process(&batch)? {
+          // "Return" RecordBatch to output
+          tx.send(batch).await
+        }
     }
-  }
 }
 ```
 - Multi-Core Execution