CatalystSerde Helper Object¶

CatalystSerde is a Scala object that consists of three utility methods:

. <> to create a new logical plan with the input logical plan wrapped inside DeserializeToObject.md[DeserializeToObject] logical operator. . <> . <>

CatalystSerde and belongs to org.apache.spark.sql.catalyst.plans.logical package.

=== [[deserialize]] Creating Logical Plan with DeserializeToObject Logical Operator for Logical Plan -- deserialize Method

[source, scala]¶

deserializeT : Encoder: DeserializeToObject¶

deserialize creates a DeserializeToObject.md[DeserializeToObject logical operator] for the input child spark-sql-LogicalPlan.md[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 <>).

=== [[serialize]] serialize Method

[source, scala]¶

serializeT : Encoder: SerializeFromObject¶

=== [[generateObjAttr]] generateObjAttr Method

[source, scala]¶

generateObjAttr[T : Encoder]: Attribute¶