pbspark/_proto.py
def register_serializer(
        self,
        message: t.Type[Message],
        serializer: t.Callable,
        return_type: DataType,
    ):
        """Map a message type to a custom serializer and spark output type.

        The serializer should be a function which returns an object which
        can be coerced into the spark return type.
        """
        full_name = message.DESCRIPTOR.full_name
        self._custom_serializers[full_name] = serializer
        self._message_type_to_spark_type_map[full_name] = return_type
Map a message type to a custom serializer and spark output type.

        The serializer should be a function which returns an object which
        can be coerced into the spark return type.
        
Map a message type to a custom serializer and spark output type.
The serializer should be a function which returns an object which
can be coerced into the spark return type.
Map a message type to a custom serializer and spark output type . The serializer should be a function which returns an object which can be coerced into the spark return type .
def register_serializer(
        self,
        message: t.Type[Message],
        serializer: t.Callable,
        return_type: DataType,
    ):
        full_name = message.DESCRIPTOR.full_name
        self._custom_serializers[full_name] = serializer
        self._message_type_to_spark_type_map[full_name] = return_type
def register_serializer ( self , message : t . Type [ Message ] , serializer : t . Callable , return_type : DataType , ) : full_name = message . DESCRIPTOR . full_name self . _custom_serializers [ full_name ] = serializer self . _message_type_to_spark_type_map [ full_name ] = return_type
Map a message type to a custom serializer and spark output type.
Map a message type to a custom serializer and spark output type .
"""Map a message type to a custom serializer and spark output type.

        The serializer should be a function which returns an object which
        can be coerced into the spark return type.
        """
self
message
t.Type[Message]
serializer
t.Callable
return_type
DataType