cassandra 使用Java 7的示例

a6b3iqyw  于 2022-11-05  发布在  Cassandra
关注(0)|答案(2)|浏览(129)

我有org.apache.sparc.sql.Dataset,并打算遍历每一行。我看到有foreachforeachPartition这样的方法,但我没有看到使用它的文档或示例。我在这里引用的是文档
Spark2.1
Java 7语言
Cassandra3.9
有人能指导我如何遍历Spark Dataset的记录吗?

68bkxrlz

68bkxrlz1#

方法是这样的,

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));
                }
            }
        });
5sxhfpxr

5sxhfpxr2#

def foreach(func: ForeachFunction[T]): Unit
 (Java-specific) Runs func on each***element***of this Dataset.

def foreach(f: (T) ⇒ Unit): Unit
 Applies a function f to all***rows***.

def foreachPartition(func: ForeachPartitionFunction[T]): Unit
 (Java-specific) Runs func on each partition of this Dataset.

def foreachPartition(f: (Iterator[T]) ⇒ Unit): Unit
 Applies a function f to each partition of this Dataset.

相关问题