code: def setup(self):
      from mars.core import OutputType
      from mars.core.operand import OperandStage
      from mars.dataframe.operands import DataFrameShuffleProxy
  
      source_chunks = []
      for i in range(1000):
          op = MockDFOperand(
              _output_types=[OutputType.dataframe],
              _key=tokenize(i),
              stage=OperandStage.map,
          )
          source_chunks.append(op.new_chunk([], index=(i,)))
  
      shuffle_chunk = DataFrameShuffleProxy(
          output_types=[OutputType.dataframe]
      ).new_chunk(source_chunks)
  
      from mars.utils import build_fetch_shuffle
  
      fetch_chunk = build_fetch_shuffle(shuffle_chunk, n_reducers=10)
  
      self.test_fetch_chunks = []
      for i in range(1000):
          reduce_op = MockDFOperand(
              _output_types=[OutputType.dataframe],
              _key=tokenize((i, 1)),
              stage=OperandStage.reduce,
          )
          self.test_fetch_chunks.append(
              reduce_op.new_chunk([fetch_chunk], index=(i,))
          )
  
imports: import cloudpickle
  import numpy
  import pandas
  from mars.core.operand import MapReduceOperand
  from mars.dataframe.operands import DataFrameOperandMixin
  from mars.oscar.core import ActorRef
  from mars.oscar.backends.message import SendMessage, new_message_id, ActorRefMessage
  from mars.serialization import serialize, deserialize
  from mars.serialization.serializables import Serializable, Int64Field, Float64Field, ListField, DataTypeField, SeriesField, NDArrayField, StringField, FieldTypes, BoolField, Int32Field, Float32Field, SliceField, Datetime64Field, Timedelta64Field, TupleField, DictField, Complex64Field, Complex128Field
  from mars.services.subtask import Subtask, SubtaskResult, SubtaskStatus
  from mars.services.task import new_task_id
  from mars.utils import tokenize
label_desc: Use image node_id 1 for calling the SerializeFetchShuffleSuite obj's underlying member method code with example usage: obj.setup() without return types