pyspark.sql.streaming.StatefulProcessor.init

abstract StatefulProcessor.init(handle)

Function that will be invoked as the first method that allows for users to initialize all their state variables and perform other init actions before handling data.

Parameters

handlepyspark.sql.streaming.stateful_processor.StatefulProcessorHandle

Handle to the stateful processor that provides access to the state store and other stateful processing related APIs.