StateStoreSaveExec Unary Physical Operator — Saving State of Streaming Aggregates
StateStoreSaveExec Unary Physical Operator — Saving State of Streaming Aggregates
StateStoreSaveExec Unary Physical Operator — Saving State of Streaming Aggregates
StateStoreRestoreExec Unary Physical Operator — Restoring State of Streaming Aggregates
FlatMapGroupsWithStateExec Unary Physical Operator
EventTimeWatermarkExec Unary Physical Operator for Accumulating Event Time Watermark
StreamingExecutionRelation Leaf Logical Operator for Streaming Source At Execution
StreamingRelationV2 Leaf Logical Operator
StreamingRelation Leaf Logical Operator for Streaming Source
MemoryPlan Logical Operator MemoryPlan is a leaf logical operator (i.e. LogicalPlan) that is used to query the dat ...
Deduplicate Unary Logical Operator Deduplicate is a unary logical operator (i.e. LogicalPlan) that is created to r ...
FlatMapGroupsWithState Unary Logical Operator
一周热门排行