(self)
return self.map_partitions(pd.DataFrame, self)
Convert to a streaming dataframe

        This calls ``pd.DataFrame`` on all list-elements of this stream
Convert to a streaming dataframe
Convert to a streaming dataframe
def to_dataframe(self):
        """
        Convert to a streaming dataframe

        This calls ``pd.DataFrame`` on all list-elements of this stream
        """
        import pandas as pd
        import streamz.dataframe  # noqa: F401
        return self.map_partitions(pd.DataFrame, self)
def to_dataframe ( self ) : import pandas as pd import streamz . dataframe # noqa: F401 return self . map_partitions ( pd . DataFrame , self )