Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- dataset.foreachPartition(new ForeachPartitionFunction<Row>() {
- public void call(Iterator<Row> t) throws Exception {
- while (t.hasNext()){
- Row row = t.next();
- System.out.println(row.getString(2));
- }
- }
- });
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement