Class FlowResolver
Object
org.apache.spark.sql.pipelines.graph.FlowResolver
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionattemptResolveFlow
(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.
-
Constructor Details
-
FlowResolver
-
-
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.
-