Skip to content

DeserializeToObjectExec

DeserializeToObjectExec is a unary physical operator with CodegenSupport.

DeserializeToObjectExec is a ObjectProducerExec.

Creating Instance

DeserializeToObjectExec takes the following to be created:

DeserializeToObjectExec is created when:

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.

Back to top