python/ray/data/impl/stats.py
def summary_string(self, exclude_first_window: bool = True) -> str:
        """Return a human-readable summary of this pipeline's stats."""
        already_printed = set()
        out = ""
        for i, stats in self.history_buffer:
            out += "== Pipeline Window {} ==\n".format(i)
            out += stats.summary_string(already_printed)
            out += "\n"
        out += "##### Overall Pipeline Time Breakdown #####\n"
        # Drop the first sample since there's no pipelining there.
        wait_time_s = self.wait_time_s[1 if exclude_first_window else 0 :]
        if wait_time_s:
            out += (
                "* Time stalled waiting for next dataset: "
                "{} min, {} max, {} mean, {} total\n".format(
                    fmt(min(wait_time_s)),
                    fmt(max(wait_time_s)),
                    fmt(np.mean(wait_time_s)),
                    fmt(sum(wait_time_s)),
                )
            )
        out += self._summarize_iter()
        return out
Return a human-readable summary of this pipeline's stats.
Return a human-readable summary of this pipeline's stats.
Return a human - readable summary of this pipeline ' s stats .
def summary_string(self, exclude_first_window: bool = True) -> str:
        already_printed = set()
        out = ""
        for i, stats in self.history_buffer:
            out += "== Pipeline Window {} ==\n".format(i)
            out += stats.summary_string(already_printed)
            out += "\n"
        out += "##### Overall Pipeline Time Breakdown #####\n"
        wait_time_s = self.wait_time_s[1 if exclude_first_window else 0 :]
        if wait_time_s:
            out += (
                "* Time stalled waiting for next dataset: "
                "{} min, {} max, {} mean, {} total\n".format(
                    fmt(min(wait_time_s)),
                    fmt(max(wait_time_s)),
                    fmt(np.mean(wait_time_s)),
                    fmt(sum(wait_time_s)),
                )
            )
        out += self._summarize_iter()
        return out
def summary_string ( self , exclude_first_window : bool = True ) -> str : already_printed = set ( ) out = "" for i , stats in self . history_buffer : out += "== Pipeline Window {} ==\n" . format ( i ) out += stats . summary_string ( already_printed ) out += "\n" out += "##### Overall Pipeline Time Breakdown #####\n" wait_time_s = self . wait_time_s [ 1 if exclude_first_window else 0 : ] if wait_time_s : out += ( "* Time stalled waiting for next dataset: " "{} min, {} max, {} mean, {} total\n" . format ( fmt ( min ( wait_time_s ) ) , fmt ( max ( wait_time_s ) ) , fmt ( np . mean ( wait_time_s ) ) , fmt ( sum ( wait_time_s ) ) , ) ) out += self . _summarize_iter ( ) return out
Return a human-readable summary of this pipeline's stats.
Return a human - readable summary of this pipeline ' s stats .
"""Return a human-readable summary of this pipeline's stats.""" # Drop the first sample since there's no pipelining there.
self
exclude_first_window
bool