Skip to content

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 |===


Last update: 2020-11-01