class_docstr: Iterator used to access the output of an Executor execution.
  
  This is a blocking iterator. Datasets guarantees that all its iterators are
  thread-safe (i.e., multiple threads can block on them at the same time).
docstr: Can be used to pull outputs by a specified output index.
  
  This is used to support the streaming_split() API, where the output of a
  streaming execution is to be consumed by multiple processes.
  
  Args:
      output_split_idx: The output split index to get results for. This arg is
          only allowed for iterators created by `Dataset.streaming_split()`.
  
  Raises:
      StopIteration if there are no more outputs to return.
docstr_tok: ["Can","be","used","to","pull","outputs","by","a","specified","output","index",".","This","is","used","to","support","the","streaming_split","(",")","API",",","where","the","output","of","a","streaming","execution","is","to","be","consumed","by","multiple","processes",".","Args",":","output_split_idx",":","The","output","split","index","to","get","results","for",".","This","arg","is","only","allowed","for","iterators","created","by","`","Dataset.streaming_split","(",")","`",".","Raises",":","StopIteration","if","there","are","no","more","outputs","to","return","."]
code: def get_next(
      self, output_split_idx: Optional[int] = None
  ) -> RefBundle:
      """Can be used to pull outputs by a specified output index.
  
      This is used to support the streaming_split() API, where the output of a
      streaming execution is to be consumed by multiple processes.
  
      Args:
          output_split_idx: The output split index to get results for. This arg is
              only allowed for iterators created by `Dataset.streaming_split()`.
  
      Raises:
          StopIteration if there are no more outputs to return.
      """
      if output_split_idx is not None:
          raise NotImplementedError()
      return next(self._it)
  
file_path: ray/python/ray/data/_internal/execution/interfaces/executor.py
imports: from typing import Iterable, Iterator, Optional
  from .execution_options import ExecutionOptions
  from .physical_operator import PhysicalOperator
  from .ref_bundle import RefBundle
  from ray.data._internal.stats import DatasetStats
label_desc: Use image node_id 2 for calling the OutputIterator obj's underlying member method code with example usage: obj.get_next(output_split_idx) and returns: next