StatefulOperator Contract — Physical Operators That Read or Write to StateStore

StatefulOperator is the base of physical operators that read or write state (described by stateInfo).

Table 1. StatefulOperator Contract
Method Description


stateInfo: Option[StatefulOperatorStateInfo]

The StatefulOperatorStateInfo of the physical operator

Table 2. StatefulOperators (Direct Implementations)
StatefulOperator Description



Physical operator that writes to a state store and collects the write metrics for execution progress reporting

results matching ""

    No results matching ""