Package org.apache.spark.sql.pipelines.graph

Class FlowResolver

Object

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

public class FlowResolver
extends Object

Constructor Summary

Constructors

Constructor	Description
FlowResolver(DataflowGraph rawGraph)

Method Summary

Modifier and Type	Method	Description
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.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

FlowResolver

public FlowResolver(DataflowGraph rawGraph)

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.