class_docstr: An operator that splits the given data into `n` output splits.
  
  The output bundles of this operator will have a `bundle.output_split_idx` attr
  set to an integer from [0..n-1]. This operator tries to divide the rows evenly
  across output splits. If the `equal` option is set, the operator will furthermore
  guarantee an exact split of rows across outputs, truncating the Dataset.
  
  Implementation wise, this operator keeps an internal buffer of bundles. The buffer
  has a minimum size calculated to enable a good locality hit rate, as well as ensure
  we can satisfy the `equal` requirement.
  
  OutputSplitter does not provide any ordering guarantees.
class_docstr_tok: ["An","operator","that","splits","the","given","data","into","`","n","`","output","splits",".","The","output","bundles","of","this","operator","will","have","a","`","bundle.output_split_idx","`","attr","set","to","an","integer","from","[","0","..","n-1","]",".","This","operator","tries","to","divide","the","rows","evenly","across","output","splits",".","If","the","`","equal","`","option","is","set",",","the","operator","will","furthermore","guarantee","an","exact","split","of","rows","across","outputs",",","truncating","the","Dataset",".","Implementation","wise",",","this","operator","keeps","an","internal","buffer","of","bundles",".","The","buffer","has","a","minimum","size","calculated","to","enable","a","good","locality","hit","rate",",","as","well","as","ensure","we","can","satisfy","the","`","equal","`","requirement",".","OutputSplitter","does","not","provide","any","ordering","guarantees","."]
docstr: Disables resource-based throttling.
  
  It doesn't make sense to throttle the inputs to this operator, since all that
  would do is lower the buffer size and prevent us from emitting outputs /
  reduce the locality hit rate.
docstr_tok: ["Disables","resource-based","throttling",".","It","does","n't","make","sense","to","throttle","the","inputs","to","this","operator",",","since","all","that","would","do","is","lower","the","buffer","size","and","prevent","us","from","emitting","outputs","\/","reduce","the","locality","hit","rate","."]
code: def throttling_disabled(self) -> bool:
      """Disables resource-based throttling.
  
      It doesn't make sense to throttle the inputs to this operator, since all that
      would do is lower the buffer size and prevent us from emitting outputs /
      reduce the locality hit rate.
      """
      return True
  
imports: import math
  from collections import deque
  from typing import Any, Dict, List, Optional
  from ray.data._internal.execution.interfaces import ExecutionOptions, ExecutionResources, NodeIdStr, PhysicalOperator, RefBundle
  from ray.data._internal.execution.util import locality_string
  from ray.data._internal.remote_fn import cached_remote_fn
  from ray.data._internal.stats import StatsDict
  from ray.data.block import Block, BlockAccessor, BlockMetadata
  from ray.types import ObjectRef
label_desc: Use image node_id 3 for calling the OutputSplitter obj's underlying member method code with example usage: obj.throttling_disabled() and returns: True