CatalystSerde object consists of three methods:

CatalystSerde is a Scala object and belongs to org.apache.spark.sql.catalyst.plans.logical package.

Creating DeserializeToObject Logical Operator for Child Logical Plan — deserialize Method

deserialize[T : Encoder](child: LogicalPlan): DeserializeToObject

deserialize creates a DeserializeToObject logical operator for the input child logical plan.

Internally, deserialize creates a UnresolvedDeserializer for the deserializer for the type T first and passes it on to a DeserializeToObject with a AttributeReference (being the result of generateObjAttr).

serialize Method

serialize[T : Encoder](child: LogicalPlan): SerializeFromObject

generateObjAttr Method

generateObjAttr[T : Encoder]: Attribute

results matching ""

    No results matching ""