StreamingFlow¶

StreamingFlow is a ResolvedFlow that may or may not be append.

StreamingFlow is planned for execution as StreamingTableWrite by FlowPlanner.

Creating Instance¶

StreamingFlow takes the following to be created:

• UnresolvedFlow
• FlowFunctionResult
• mustBeAppend flag (default: false)

StreamingFlow is created when:

• FlowResolver is requested to convertResolvedToTypedFlow (for UnresolvedFlows with their results being streaming dataframes)