pyspark.sql.streaming.ForeachBatchFunction

class pyspark.sql.streaming.ForeachBatchFunction(sql_ctx, func)

This is the Python implementation of Java interface ‘ForeachBatchFunction’. This wraps the user-defined ‘foreachBatch’ function such that it can be called from the JVM when the query is active.

Methods

call(jdf, batch_id)

pyspark.sql.streaming.DataStreamWriter pyspark.sql.streaming.StreamingQuery