StatefulOperator Physical Operators¶

StatefulOperator is the <> of <> that <> or <> state (described by <>).

[[contract]] .StatefulOperator Contract [cols="1m,2",options="header",width="100%"] |=== | Method | Description

| stateInfo a| [[stateInfo]]

[source, scala]¶

stateInfo: Option[StatefulOperatorStateInfo]¶

The StatefulOperatorStateInfo of the physical operator |===

[[extensions]] .StatefulOperators (Direct Implementations) [cols="1,2",options="header",width="100%"] |=== | StatefulOperator | Description

| <> | [[StateStoreReader]]

| StateStoreWriter | [[StateStoreWriter]] Physical operator that writes to a state store and collects the write metrics for execution progress reporting |===