org.apache.spark.sql.execution

Class EvaluatePython

Object

org.apache.spark.sql.catalyst.trees.TreeNode<PlanType>

org.apache.spark.sql.catalyst.plans.QueryPlan<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>

org.apache.spark.sql.catalyst.plans.logical.LogicalPlan

org.apache.spark.sql.catalyst.plans.logical.UnaryNode

org.apache.spark.sql.execution.EvaluatePython

All Implemented Interfaces:

java.io.Serializable, org.apache.spark.sql.catalyst.trees.UnaryNode<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>, scala.Equals, scala.Product

public class EvaluatePython
extends org.apache.spark.sql.catalyst.plans.logical.UnaryNode
implements scala.Product, scala.Serializable

:: DeveloperApi :: Evaluates a PythonUDF, appending the result to the end of the input tuple.

See Also:

Serialized Form

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.spark.sql.catalyst.plans.logical.LogicalPlan

org.apache.spark.sql.catalyst.plans.logical.LogicalPlan.Statistics, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan.Statistics$

Constructor Summary

Constructors

Constructor and Description
EvaluatePython(org.apache.spark.sql.execution.PythonUDF udf, org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.spark.sql.catalyst.plans.logical.LogicalPlan	child()
scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute>	output()
org.apache.spark.sql.catalyst.expressions.AttributeReference	resultAttribute()
org.apache.spark.sql.execution.PythonUDF	udf()

Methods inherited from class org.apache.spark.sql.catalyst.plans.logical.UnaryNode

children

Methods inherited from class org.apache.spark.sql.catalyst.plans.logical.LogicalPlan

childrenResolved, inputSet, resolve, resolve, resolveChildren, resolved, statistics, Statistics

Methods inherited from class org.apache.spark.sql.catalyst.plans.QueryPlan

expressions, org$apache$spark$sql$catalyst$plans$QueryPlan$$transformExpressionDown$1, org$apache$spark$sql$catalyst$plans$QueryPlan$$transformExpressionUp$1, outputSet, printSchema, schema, schemaString, transformAllExpressions, transformExpressions, transformExpressionsDown, transformExpressionsUp

Methods inherited from class org.apache.spark.sql.catalyst.trees.TreeNode

apply, argString, asCode, collect, fastEquals, flatMap, foreach, generateTreeString, getNodeNumbered, id, makeCopy, map, mapChildren, nextId, nodeName, numberedTreeString, otherCopyArgs, sameInstance, simpleString, stringArgs, toString, transform, transformChildrenDown, transformChildrenUp, transformDown, transformUp, treeString, withNewChildren

Methods inherited from class Object

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

Methods inherited from interface scala.Product

productArity, productElement, productIterator, productPrefix

Methods inherited from interface scala.Equals

canEqual, equals

Constructor Detail

EvaluatePython

public EvaluatePython(org.apache.spark.sql.execution.PythonUDF udf,
              org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child)

Method Detail

udf

public org.apache.spark.sql.execution.PythonUDF udf()

child

public org.apache.spark.sql.catalyst.plans.logical.LogicalPlan child()

Specified by:

child in interface org.apache.spark.sql.catalyst.trees.UnaryNode<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>

resultAttribute

public org.apache.spark.sql.catalyst.expressions.AttributeReference resultAttribute()

output

public scala.collection.Seq<org.apache.spark.sql.catalyst.expressions.Attribute> output()

Specified by:

output in class org.apache.spark.sql.catalyst.plans.QueryPlan<org.apache.spark.sql.catalyst.plans.logical.LogicalPlan>