python/ray/data/impl/plan.py
def _get_source_blocks(self) -> Tuple[BlockList, DatasetStats]:
        """Get the source blocks (and corresponding stats) for plan execution.

        If a computed snapshot exists, return the snapshot blocks and stats; otherwise,
        return the input blocks and stats that the plan was created with.
        """
        if self._snapshot_blocks is not None:
            # If snapshot exists, we only have to execute the plan from the
            # snapshot.
            blocks = self._snapshot_blocks
            stats = self._snapshot_stats
            # Unlink the snapshot blocks from the plan so we can eagerly reclaim the
            # snapshot block memory after the first stage is done executing.
            self._snapshot_blocks = None
        else:
            # If no snapshot exists, we have to execute the full plan from the
            # beginning.
            blocks = self._in_blocks
            stats = self._in_stats
            if not self.has_lazy_input():
                # If not a lazy datasource, unlink the input blocks from the plan so we
                # can eagerly reclaim the input block memory after the first stage is
                # done executing.
                self._in_blocks = None
        return blocks, stats
Get the source blocks (and corresponding stats) for plan execution.

        If a computed snapshot exists, return the snapshot blocks and stats; otherwise,
        return the input blocks and stats that the plan was created with.
        
Get the source blocks (and corresponding stats) for plan execution.
If a computed snapshot exists, return the snapshot blocks and stats; otherwise,
return the input blocks and stats that the plan was created with.
Get the source blocks ( and corresponding stats ) for plan execution . If a computed snapshot exists return the snapshot blocks and stats ; otherwise return the input blocks and stats that the plan was created with .
def _get_source_blocks(self) -> Tuple[BlockList, DatasetStats]:
        if self._snapshot_blocks is not None:
            blocks = self._snapshot_blocks
            stats = self._snapshot_stats
            self._snapshot_blocks = None
        else:
            blocks = self._in_blocks
            stats = self._in_stats
            if not self.has_lazy_input():
                self._in_blocks = None
        return blocks, stats
def _get_source_blocks ( self ) -> Tuple [ BlockList , DatasetStats ] : if self . _snapshot_blocks is not None : blocks = self . _snapshot_blocks stats = self . _snapshot_stats self . _snapshot_blocks = None else : blocks = self . _in_blocks stats = self . _in_stats if not self . has_lazy_input ( ) : self . _in_blocks = None return blocks , stats
Get the source blocks (and corresponding stats) for plan execution.
Get the source blocks ( and corresponding stats ) for plan execution .
"""Get the source blocks (and corresponding stats) for plan execution.

        If a computed snapshot exists, return the snapshot blocks and stats; otherwise,
        return the input blocks and stats that the plan was created with.
        """ # If snapshot exists, we only have to execute the plan from the # snapshot. # Unlink the snapshot blocks from the plan so we can eagerly reclaim the # snapshot block memory after the first stage is done executing. # If no snapshot exists, we have to execute the full plan from the # beginning. # If not a lazy datasource, unlink the input blocks from the plan so we # can eagerly reclaim the input block memory after the first stage is # done executing.
self