pbspark/_proto.py
def from_protobuf(
    data: t.Union[Column, str],
    message_type: t.Type[Message],
    options: t.Optional[dict] = None,
    mc: MessageConverter = None,
) -> Column:
    """Deserialize protobuf messages to spark structs"""
    mc = mc or MessageConverter()
    return mc.from_protobuf(data=data, message_type=message_type, options=options)
Deserialize protobuf messages to spark structs
Deserialize protobuf messages to spark structs
Deserialize protobuf messages to spark structs
def from_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.from_protobuf(data=data, message_type=message_type, options=options)
def from_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 . from_protobuf ( data = data , message_type = message_type , options = options )
Deserialize protobuf messages to spark structs
Deserialize protobuf messages to spark structs
"""Deserialize protobuf messages to spark structs"""
data
t.Union[Column, str]
message_type
t.Type[Message]
options
t.Optional[dict]
mc
MessageConverter