Skip to content

ObjectConsumerExec -- Unary Physical Operators with Child Physical Operator with One-Attribute Output Schema

ObjectConsumerExec is the <> of <> with the child physical operator using a one-attribute <>.

[[contract]] [source, scala]


package org.apache.spark.sql.execution

trait ObjectConsumerExec extends UnaryExecNode { // No properties (vals and methods) that have no implementation }


[[references]] ObjectConsumerExec requests the child physical operator for the <> when requested for the <>.

[[implementations]] .ObjectConsumerExecs [cols="1,2",options="header",width="100%"] |=== | ObjectConsumerExec | Description

| AppendColumnsWithObjectExec | [[AppendColumnsWithObjectExec]]

| MapPartitionsExec | [[MapPartitionsExec]]

| <> | [[SerializeFromObjectExec]] |===

=== [[inputObjectType]] inputObjectType Method

[source, scala]

inputObjectType: DataType

inputObjectType simply returns the <> of the single <> of the child physical operator.

NOTE: inputObjectType is used when...FIXME