pyspark.sql.streaming.
ForeachBatchFunction
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.
__init__
Initialize self. See help(type(self)) for accurate signature.
Methods
__init__(sql_ctx, func)
Initialize self.
call(jdf, batch_id)
call