pyspark.sql.streaming.StatefulProcessor.init ============================================ .. currentmodule:: pyspark.sql.streaming .. automethod:: StatefulProcessor.init