spark技术分享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.
|
1 2 3 4 5 6 7 8 9 |
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.
| ObjectConsumerExec | Description |
|---|---|
|
|
|
|
|
|
inputObjectType Method
|
1 2 3 4 5 |
inputObjectType: DataType |
inputObjectType simply returns the data type of the single output attribute of the child physical operator.
|
Note
|
inputObjectType is used when…FIXME
|
