FlowFunctionResult¶

FlowFunctionResult is the result of executing a FlowFunction.

FlowFunctionResult is a part of ResolutionCompletedFlows.

Creating Instance¶

FlowFunctionResult takes the following to be created:

• TableIdentifiers of the requested inputs
• ResolvedInputs of the batch inputs
• ResolvedInputs of the streaming inputs
• TableIdentifier of the external inputs
• DataFrame
• SQL Configuration
• AnalysisWarning (default: undefined)

FlowFunctionResult is created when:

• FlowAnalysis is requested to createFlowFunctionFromLogicalPlan

DataFrame¶

FlowFunctionResult is given a DataFrame (produced by the corresponding flow) when created.

When this DataFrame is streaming, FlowResolver converts an UnresolvedFlow to a StreamingFlow.

Inputs¶

inputs: Set[TableIdentifier]

inputs are all the TableIdentifiers of the Inputs of this batchInputs and streamingInputs.

inputs is used when:

• ResolvedFlow is requested for the inputs