python/ray/data/dataset_pipeline.py
def iter_datasets(self) -> Iterator[Dataset[T]]:
        """Iterate over the output datasets of this pipeline.

        Returns:
            Iterator over the datasets outputted from this pipeline.
        """
        if self._executed[0]:
            raise RuntimeError("Pipeline cannot be read multiple times.")
        self._executed[0] = True
        if self._first_dataset is None:
            self._peek()
        iter = itertools.chain([self._first_dataset], self._dataset_iter)
        self._first_dataset = None
        self._dataset_iter = None
        return iter
Iterate over the output datasets of this pipeline.

        Returns:
            Iterator over the datasets outputted from this pipeline.
        
Iterate over the output datasets of this pipeline.
Iterate over the output datasets of this pipeline .
def iter_datasets(self) -> Iterator[Dataset[T]]:
        if self._executed[0]:
            raise RuntimeError("Pipeline cannot be read multiple times.")
        self._executed[0] = True
        if self._first_dataset is None:
            self._peek()
        iter = itertools.chain([self._first_dataset], self._dataset_iter)
        self._first_dataset = None
        self._dataset_iter = None
        return iter
def iter_datasets ( self ) -> Iterator [ Dataset [ T ] ] : if self . _executed [ 0 ] : raise RuntimeError ( "Pipeline cannot be read multiple times." ) self . _executed [ 0 ] = True if self . _first_dataset is None : self . _peek ( ) iter = itertools . chain ( [ self . _first_dataset ] , self . _dataset_iter ) self . _first_dataset = None self . _dataset_iter = None return iter
Iterate over the output datasets of this pipeline.
Iterate over the output datasets of this pipeline .
"""Iterate over the output datasets of this pipeline.

        Returns:
            Iterator over the datasets outputted from this pipeline.
        """
Iterator over the datasets outputted from this pipeline.
Iterator over the datasets outputted from this pipeline .
self