pbspark/_proto.py
def df_from_protobuf(
    df: DataFrame,
    message_type: t.Type[Message],
    options: t.Optional[dict] = None,
    expanded: bool = False,
    mc: MessageConverter = None,
) -> DataFrame:
    """Decode a dataframe of encoded protobuf.

    If expanded, return a dataframe in which each field is its own column. Otherwise
    return a dataframe with a single struct column named `value`.
    """
    mc = mc or MessageConverter()
    return mc.df_from_protobuf(
        df=df, message_type=message_type, options=options, expanded=expanded
    )
Decode a dataframe of encoded protobuf.

    If expanded, return a dataframe in which each field is its own column. Otherwise
    return a dataframe with a single struct column named `value`.
    
Decode a dataframe of encoded protobuf.
If expanded, return a dataframe in which each field is its own column. Otherwise
return a dataframe with a single struct column named `value`.
Decode a dataframe of encoded protobuf . If expanded return a dataframe in which each field is its own column . Otherwise return a dataframe with a single struct column named ` value ` .
def df_from_protobuf(
    df: DataFrame,
    message_type: t.Type[Message],
    options: t.Optional[dict] = None,
    expanded: bool = False,
    mc: MessageConverter = None,
) -> DataFrame:
    mc = mc or MessageConverter()
    return mc.df_from_protobuf(
        df=df, message_type=message_type, options=options, expanded=expanded
    )
def df_from_protobuf ( df : DataFrame , message_type : t . Type [ Message ] , options : t . Optional [ dict ] = None , expanded : bool = False , mc : MessageConverter = None , ) -> DataFrame : mc = mc or MessageConverter ( ) return mc . df_from_protobuf ( df = df , message_type = message_type , options = options , expanded = expanded )
Decode a dataframe of encoded protobuf.
Decode a dataframe of encoded protobuf .
"""Decode a dataframe of encoded protobuf.

    If expanded, return a dataframe in which each field is its own column. Otherwise
    return a dataframe with a single struct column named `value`.
    """
df
DataFrame
message_type
t.Type[Message]
options
t.Optional[dict]
expanded
bool
mc
MessageConverter