CatalystSerde Helper Object¶
CatalystSerde
is a Scala object that consists of three utility methods:
. <
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