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

Class FlowNode

Object

org.apache.spark.sql.pipelines.graph.FlowNode

All Implemented Interfaces:

Serializable, scala.Equals, scala.Product

public class FlowNode
extends Object
implements scala.Product, Serializable

param: identifier The identifier of the flow. param: inputs The identifiers of nodes used as inputs to this flow. param: output The identifier of the output that this flow writes to.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
FlowNode(org.apache.spark.sql.catalyst.TableIdentifier identifier, scala.collection.immutable.Set<org.apache.spark.sql.catalyst.TableIdentifier> inputs, org.apache.spark.sql.catalyst.TableIdentifier output)

Method Summary

Modifier and Type	Method	Description
abstract static R	apply(T1 v1, T2 v2, T3 v3)
org.apache.spark.sql.catalyst.TableIdentifier	identifier()
scala.collection.immutable.Set<org.apache.spark.sql.catalyst.TableIdentifier>	inputs()
org.apache.spark.sql.catalyst.TableIdentifier	output()
static String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface scala.Equals

canEqual, equals

Methods inherited from interface scala.Product

productArity, productElement, productElementName, productElementNames, productIterator, productPrefix

Constructor Details

FlowNode

public FlowNode(org.apache.spark.sql.catalyst.TableIdentifier identifier,
 scala.collection.immutable.Set<org.apache.spark.sql.catalyst.TableIdentifier> inputs,
 org.apache.spark.sql.catalyst.TableIdentifier output)

Method Details

apply

public abstract static R apply(T1 v1,
 T2 v2,
 T3 v3)

toString

public static String toString()

identifier

public org.apache.spark.sql.catalyst.TableIdentifier identifier()

inputs

public scala.collection.immutable.Set<org.apache.spark.sql.catalyst.TableIdentifier> inputs()

output

public org.apache.spark.sql.catalyst.TableIdentifier output()