Class DataFrameToIterableRow

  • All Implemented Interfaces:
    Function<org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>,​Iterable<? extends org.apache.spark.sql.Row>>

    public class DataFrameToIterableRow
    extends Object
    implements Function<org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>,​Iterable<? extends org.apache.spark.sql.Row>>
    A Function to convert a Dataset into an Iterable of Rows.
    • Constructor Detail

      • DataFrameToIterableRow

        public DataFrameToIterableRow()
    • Method Detail

      • apply

        public Iterable<? extends org.apache.spark.sql.Row> apply​(org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> dataset)
        Specified by:
        apply in interface Function<org.apache.spark.sql.Dataset<org.apache.spark.sql.Row>,​Iterable<? extends org.apache.spark.sql.Row>>