DirectReader implements Serializable { public static List <Row> directRead(BatchOperator batchOperator) { return directRead(collect(batchOperator)); }  static DataBridge collect(BatchOperator<?> model); static List <Row> directRead(BatchOperator batchOperator); static List<Row> directRead(DataBridge dataBridge); static List <Row> directRead(DataBridge dataBridge, FilterFunction <Row> filter);  }
@Test public void testDirectRead() { Set<String> inputSet = new HashSet<>(Arrays.asList(inputArray)); List<Row> collected = DirectReader.directRead(input); Assert.assertEquals(inputSet.size(), collected.size()); for (Row r : collected) { Assert.assertTrue(inputSet.contains(r.getField(0))); } }