Skip to content

CoreDataflowNodeProcessor

Creating Instance

CoreDataflowNodeProcessor takes the following to be created:

CoreDataflowNodeProcessor is created when:

  • DataflowGraph is requested to resolve

FlowResolver

CoreDataflowNodeProcessor creates a FlowResolver when created.

The FlowResolver is used to process an UnresolvedFlow.

processNode

processNode(
  node: GraphElement,
  upstreamNodes: Seq[GraphElement]): Seq[GraphElement]

processNode...FIXME


processNode is used when:

  • DataflowGraph is requested to resolve

processUnresolvedFlow

processUnresolvedFlow(
  flow: UnresolvedFlow): ResolvedFlow

processUnresolvedFlow...FIXME