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

stateInfo: Option[StatefulOperatorStateInfo]

The StatefulOperatorStateInfo of the physical operator

Table 2. StatefulOperators (Direct Implementations)
StatefulOperator Description

StateStoreReader

StateStoreWriter

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

results matching ""

    No results matching ""