nxcals.api.extraction.data.builders.DataFrame.foreach
- DataFrame.foreach(f: Callable[[Row], None]) None
Applies the
f
function to allRow
of thisDataFrame
.This is a shorthand for
df.rdd.foreach()
.New in version 1.3.0.
- Parameters:
f (function) – A function that accepts one parameter which will receive each row to process.
Examples
>>> df = spark.createDataFrame( ... [(14, "Tom"), (23, "Alice"), (16, "Bob")], ["age", "name"]) >>> def func(person): ... print(person.name) ... >>> df.foreach(func)