pbspark/_proto.py
def to_protobuf(
    data: t.Union[Column, str],
    message_type: t.Type[Message],
    options: t.Optional[dict] = None,
    mc: MessageConverter = None,
) -> Column:
    """Serialize spark structs to protobuf messages."""
    mc = mc or MessageConverter()
    return mc.to_protobuf(data=data, message_type=message_type, options=options)
Serialize spark structs to protobuf messages.
Serialize spark structs to protobuf messages.
Serialize spark structs to protobuf messages .
def to_protobuf(
    data: t.Union[Column, str],
    message_type: t.Type[Message],
    options: t.Optional[dict] = None,
    mc: MessageConverter = None,
) -> Column:
    mc = mc or MessageConverter()
    return mc.to_protobuf(data=data, message_type=message_type, options=options)
def to_protobuf ( data : t . Union [ Column , str ] , message_type : t . Type [ Message ] , options : t . Optional [ dict ] = None , mc : MessageConverter = None , ) -> Column : mc = mc or MessageConverter ( ) return mc . to_protobuf ( data = data , message_type = message_type , options = options )
Serialize spark structs to protobuf messages.
Serialize spark structs to protobuf messages .
"""Serialize spark structs to protobuf messages."""
data
t.Union[Column, str]
message_type
t.Type[Message]
options
t.Optional[dict]
mc
MessageConverter