diff --git a/docs/content/program-api/java-api.md b/docs/content/program-api/java-api.md index f7b9cd103748..6dd82fbee278 100644 --- a/docs/content/program-api/java-api.md +++ b/docs/content/program-api/java-api.md @@ -192,7 +192,9 @@ public class ReadTable { // 3. Distribute these splits to different tasks // 4. Read a split in task - TableRead read = readBuilder.newRead(); + // You can use executeFilter to do filter per record. + // By default, only capable of performing coarse-grained filtering. + TableRead read = readBuilder.newRead().executeFilter(); RecordReader reader = read.createReader(splits); reader.forEachRemaining(System.out::println); } @@ -304,7 +306,9 @@ public class StreamReadTable { // can be restored in scan.restore(state) after fail over // 3. Read a split in task - TableRead read = readBuilder.newRead(); + // You can use executeFilter to do filter per record. + // By default, only capable of performing coarse-grained filtering. + TableRead read = readBuilder.newRead().executeFilter(); RecordReader reader = read.createReader(splits); reader.forEachRemaining(System.out::println);