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

ObjectConsumerExec is the contract of unary physical operators with the child physical operator using a one-attribute output schema.

package org.apache.spark.sql.execution

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

ObjectConsumerExec requests the child physical operator for the output schema attribute set when requested for the references.

Table 1. ObjectConsumerExecs
ObjectConsumerExec Description

AppendColumnsWithObjectExec

MapElementsExec

MapPartitionsExec

SerializeFromObjectExec

inputObjectType Method

inputObjectType: DataType

inputObjectType simply returns the data type of the single output attribute of the child physical operator.

Note
 inputObjectType is used when…​FIXME

results matching ""

    No results matching ""