CompleteFlow¶

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

CompleteFlow is planned for execution as BatchTableWrite by FlowPlanner.

Creating Instance¶

CompleteFlow takes the following to be created:

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

CompleteFlow is created when:

• FlowResolver is requested to convertResolvedToTypedFlow (for UnresolvedFlows that are neither once nor their results are streaming dataframes)