FlowResolver¶

Creating Instance¶

FlowResolver takes the following to be created:

• DataflowGraph

FlowResolver is created alongside a CoreDataflowNodeProcessor.

attemptResolveFlow¶

attemptResolveFlow(
  flowToResolve: UnresolvedFlow,
  allInputs: Set[TableIdentifier],
  availableResolvedInputs: Map[TableIdentifier, Input]): ResolvedFlow

attemptResolveFlow...FIXME

attemptResolveFlow is used when:

• CoreDataflowNodeProcessor is 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 FlowFunctionResult with a streaming DataFrame
• CompleteFlow, otherwise