Skip to content

Commit a644ca0

Browse files
committed
feat: impl arrow NestedLoopJoin
1 parent 6b50cc5 commit a644ca0

File tree

13 files changed

+584
-31
lines changed

13 files changed

+584
-31
lines changed

core/src/main/java/cn/edu/tsinghua/iginx/engine/physical/memory/execute/compute/join/CrossJoinArrayList.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -61,6 +61,9 @@ public void close() {
6161
buildSideSingleBatch.close();
6262
}
6363

64+
@Override
65+
public void flush() throws ComputeException {}
66+
6467
@Override
6568
public void probe(
6669
DictionaryProvider dictionaryProvider,
@@ -73,9 +76,6 @@ public void probe(
7376
}
7477
}
7578

76-
@Override
77-
public void flush() throws ComputeException {}
78-
7979
private void probe(VectorSchemaRoot probeSideBatch) throws ComputeException {
8080
Preconditions.checkArgument(probeSideBatch.getSchema().equals(probeSideSchema));
8181

0 commit comments

Comments
 (0)