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 -
TableIdentifierof the external inputs - DataFrame
- SQL Configuration
-
AnalysisWarning(default: undefined)
FlowFunctionResult is created when:
FlowAnalysisis 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:
ResolvedFlowis requested for the inputs