DeserializeToObjectExec¶

DeserializeToObjectExec is a unary physical operator with CodegenSupport.

DeserializeToObjectExec is a ObjectProducerExec.

Creating Instance¶

DeserializeToObjectExec takes the following to be created:

• Deserializer Expression
• Attribute
• Child physical operator

DeserializeToObjectExec is created when:

• BasicOperators execution planning strategy is executed (with a logical query with a DeserializeToObject logical operator)

CodegenSupport¶

DeserializeToObjectExec is a CodegenSupport.

doConsume¶

doConsume(
  ctx: CodegenContext,
  input: Seq[ExprCode],
  row: ExprCode): String

doConsume...FIXME

doConsume is part of the CodegenSupport abstraction.

doProduce¶

doProduce(
  ctx: CodegenContext): String

doProduce...FIXME

doProduce is part of the CodegenSupport abstraction.

inputRDDs¶

inputRDDs(): Seq[RDD[InternalRow]]

inputRDDs requests the child (that is supposed to be a physical operator with CodegenSupport) for the inputRDDs.

inputRDDs is part of the CodegenSupport abstraction.

ObjectProducerExec¶

DeserializeToObjectExec is an ObjectProducerExec.

outputObjAttr¶

DeserializeToObjectExec is given an outputObjAttr when created.

outputObjAttr is part of the ObjectProducerExec abstraction.

SparkPlan¶

DeserializeToObjectExec is a SparkPlan.

Execution¶

doExecute(): RDD[InternalRow]

doExecute...FIXME

doExecute is part of the SparkPlan abstraction.