spark技术分享
StreamingDeduplicateExec Unary Physical Operator for Streaming Deduplication
StreamingDeduplicateExec Unary Physical Operator for Streaming Deduplication
标签：structured-streaming
第8页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
StateStoreRestoreExec Unary Physical Operator — Restoring State of Streaming Aggregates
FlatMapGroupsWithStateExec Unary Physical Operator
FlatMapGroupsWithStateExec Unary Physical Operator
EventTimeWatermarkExec Unary Physical Operator for Accumulating Event Time Watermark
EventTimeWatermarkExec Unary Physical Operator for Accumulating Event Time Watermark
StreamingExecutionRelation Leaf Logical Operator for Streaming Source At Execution
StreamingExecutionRelation Leaf Logical Operator for Streaming Source At Execution
StreamingRelationV2 Leaf Logical Operator
StreamingRelationV2 Leaf Logical Operator
StreamingRelation Leaf Logical Operator for Streaming Source
StreamingRelation Leaf Logical Operator for Streaming Source
MemoryPlan Logical Query Plan
MemoryPlan Logical Operator MemoryPlan is a leaf logical operator (i.e. LogicalPlan) that is used to query the dat ...
Deduplicate Unary Logical Operator
Deduplicate Unary Logical Operator Deduplicate is a unary logical operator (i.e. LogicalPlan) that is created to r ...
