spark技术分享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).
| Method | Description | ||
|---|---|---|---|
|
|
The StatefulOperatorStateInfo of the physical operator |
| StatefulOperator | Description |
|---|---|
|
Physical operator that writes to a state store and collects the write metrics for execution progress reporting |
