File tree Expand file tree Collapse file tree 1 file changed +6
-2
lines changed
Expand file tree Collapse file tree 1 file changed +6
-2
lines changed Original file line number Diff line number Diff line change @@ -192,7 +192,9 @@ public class ReadTable {
192192 // 3. Distribute these splits to different tasks
193193
194194 // 4. Read a split in task
195- TableRead read = readBuilder. newRead();
195+ // You can use executeFilter to do filter per record.
196+ // By default, only capable of performing coarse-grained filtering.
197+ TableRead read = readBuilder. newRead(). executeFilter();
196198 RecordReader<InternalRow > reader = read. createReader(splits);
197199 reader. forEachRemaining(System . out:: println);
198200 }
@@ -304,7 +306,9 @@ public class StreamReadTable {
304306 // can be restored in scan.restore(state) after fail over
305307
306308 // 3. Read a split in task
307- TableRead read = readBuilder. newRead();
309+ // You can use executeFilter to do filter per record.
310+ // By default, only capable of performing coarse-grained filtering.
311+ TableRead read = readBuilder. newRead(). executeFilter();
308312 RecordReader<InternalRow > reader = read. createReader(splits);
309313 reader. forEachRemaining(System . out:: println);
310314
You can’t perform that action at this time.
0 commit comments