class_docstr: A blocking operator that executes once its inputs are complete.
  
  This operator implements distributed sort / shuffle operations, etc.
code: def all_inputs_done(self) -> None:
      ctx = TaskContext(
          task_idx=self._next_task_index,
          sub_progress_bar_dict=self._sub_progress_bar_dict,
          target_max_block_size=self.actual_target_max_block_size,
      )
      self._output_buffer, self._stats = self._bulk_fn(
          self._input_buffer, ctx
      )
      self._next_task_index += 1
      self._input_buffer.clear()
      super().all_inputs_done()
  
imports: from typing import List, Optional
  from ray.data._internal.execution.interfaces import AllToAllTransformFn, PhysicalOperator, RefBundle, TaskContext
  from ray.data._internal.logical.interfaces import LogicalOperator
  from ray.data._internal.progress_bar import ProgressBar
  from ray.data._internal.stats import StatsDict
label_desc: Use image node_id 4 for calling the AllToAllOperator obj's underlying member method code with example usage: obj.all_inputs_done() without return types