python/ray/data/impl/plan.py
def clear(self) -> None:
        """Clear all cached block references of this plan, including input blocks.

        This will render the plan un-executable unless the root is a LazyBlockList."""
        self._in_blocks.clear()
        self._snapshot_blocks = None
        self._snapshot_stats = None
        # We're erasing the snapshot, so put all stages into the "after snapshot"
        # bucket.
        self._stages_after_snapshot = (
            self._stages_before_snapshot + self._stages_after_snapshot
        )
        self._stages_before_snapshot = []
Clear all cached block references of this plan, including input blocks.

        This will render the plan un-executable unless the root is a LazyBlockList.
Clear all cached block references of this plan, including input blocks.
This will render the plan un-executable unless the root is a LazyBlockList.
Clear all cached block references of this plan including input blocks . This will render the plan un - executable unless the root is a LazyBlockList .
def clear(self) -> None:
        self._in_blocks.clear()
        self._snapshot_blocks = None
        self._snapshot_stats = None
        self._stages_after_snapshot = (
            self._stages_before_snapshot + self._stages_after_snapshot
        )
        self._stages_before_snapshot = []
def clear ( self ) -> None : self . _in_blocks . clear ( ) self . _snapshot_blocks = None self . _snapshot_stats = None self . _stages_after_snapshot = ( self . _stages_before_snapshot + self . _stages_after_snapshot ) self . _stages_before_snapshot = [ ]
Clear all cached block references of this plan, including input blocks.
Clear all cached block references of this plan including input blocks .
"""Clear all cached block references of this plan, including input blocks.

        This will render the plan un-executable unless the root is a LazyBlockList.""" # We're erasing the snapshot, so put all stages into the "after snapshot" # bucket.
self