FlowResolver¶
Creating Instance¶
FlowResolver takes the following to be created:
FlowResolver is created alongside a CoreDataflowNodeProcessor.
attemptResolveFlow¶
attemptResolveFlow(
flowToResolve: UnresolvedFlow,
allInputs: Set[TableIdentifier],
availableResolvedInputs: Map[TableIdentifier, Input]): ResolvedFlow
attemptResolveFlow...FIXME
attemptResolveFlow is used when:
CoreDataflowNodeProcessoris requested to processUnresolvedFlow
convertResolvedToTypedFlow¶
convertResolvedToTypedFlow(
flow: UnresolvedFlow,
funcResult: FlowFunctionResult): ResolvedFlow
convertResolvedToTypedFlow converts the given UnresolvedFlow as follows (and in that order):
- AppendOnceFlow for a once flow
- StreamingFlow for the given
FlowFunctionResultwith a streamingDataFrame - CompleteFlow, otherwise