pyspark.sql.streaming.StatefulProcessor.close

abstract StatefulProcessor.close()

Function called as the last method that allows for users to perform any cleanup or teardown operations.