DeserializeToObject

2012-11-04 分类：spark-sql 阅读(2182) 评论(0)

DeserializeToObject Unary Logical Operator



case class DeserializeToObject(
  deserializer: Expression,
  outputObjAttr: Attribute,
  child: LogicalPlan) extends UnaryNode with ObjectProducer

case class DeserializeToObject(

deserializer: Expression,

outputObjAttr: Attribute,

child: LogicalPlan) extends UnaryNode with ObjectProducer

DeserializeToObject is a unary logical operator that takes the input row from the input child logical plan and turns it into the input outputObjAttr attribute using the given deserializer expression.

DeserializeToObject is a ObjectProducer which produces domain objects as output. DeserializeToObject‘s output is a single-field safe row containing the produced object.