class_docstr: This class is used to stream shuffle map outputs to the object store.
  
  It can be subclassed to optimize writing (e.g., batching together small
  records into larger objects). This will be performance critical if your
  input records are small (the example shuffle uses very large records, so
  the naive strategy works well).
docstr: Queue a single item to be written to the object store.
  
  This base implementation immediately writes each given item to the
  object store as a standalone object.
docstr_tok: ["Queue","a","single","item","to","be","written","to","the","object","store",".","This","base","implementation","immediately","writes","each","given","item","to","the","object","store","as","a","standalone","object","."]
code: def add(self, item: InType) -> None:
      """Queue a single item to be written to the object store.
  
      This base implementation immediately writes each given item to the
      object store as a standalone object.
      """
      self.results.append(ray.put(item))
  
imports: import time
  from typing import Any, Callable, Iterable, List, Tuple, Union
  import ray
  from ray import ObjectRef
  from ray.cluster_utils import Cluster
label_desc: Use image node_id 2 for calling the ObjectStoreWriter obj's underlying member method code with example usage: obj.add(item) without return types