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

Class FlowAnalysis

Object

org.apache.spark.sql.pipelines.graph.FlowAnalysis

public class FlowAnalysis
extends Object

Constructor Summary

Constructors

Constructor	Description
FlowAnalysis()

Method Summary

Modifier and Type	Method	Description
static FlowFunction	createFlowFunctionFromLogicalPlan(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)	Creates a FlowFunction that attempts to analyze the provided LogicalPlan using the existing resolved inputs.

Methods inherited from class java.lang.Object

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

Constructor Details

FlowAnalysis

public FlowAnalysis()

Method Details

createFlowFunctionFromLogicalPlan

public static FlowFunction createFlowFunctionFromLogicalPlan(org.apache.spark.sql.catalyst.plans.logical.LogicalPlan plan)

Creates a FlowFunction that attempts to analyze the provided LogicalPlan using the existing resolved inputs. - If all upstream inputs have been resolved, then analysis succeeds and the function returns a FlowFunctionResult containing the dataframe. - If any upstream inputs are unresolved, then the function throws an exception.

Parameters:

plan - The user-supplied LogicalPlan defining a flow.

Returns:

A FlowFunction that attempts to analyze the provided LogicalPlan.