Class FlowResolver

Object
org.apache.spark.sql.pipelines.graph.FlowResolver

public class FlowResolver extends Object
  • Constructor Details

  • Method Details

    • attemptResolveFlow

      public ResolvedFlow attemptResolveFlow(UnresolvedFlow flowToResolve, scala.collection.immutable.Set<org.apache.spark.sql.catalyst.TableIdentifier> allInputs, scala.collection.immutable.Map<org.apache.spark.sql.catalyst.TableIdentifier,Input> availableResolvedInputs)
      Attempts resolving a single flow using the map of resolved inputs.