class_docstr: Base class for tf.data service tests.
code: def make_distributed_dataset(
      self,
      dataset,
      cluster,
      processing_mode="parallel_epochs",
      **kwargs,
  ):
      kwargs["task_refresh_interval_hint_ms"] = 20
      if "data_transfer_protocol" not in kwargs:
          kwargs[
              "data_transfer_protocol"
          ] = self.default_data_transfer_protocol
      if "compression" not in kwargs:
          kwargs["compression"] = self.default_compression
  
      # pylint: disable=protected-access
      return dataset.apply(
          data_service_ops._distribute(
              processing_mode, cluster.dispatcher_address(), **kwargs
          )
      )
  
imports: import os
  import shutil
  import tempfile
  from tensorflow.core.protobuf import service_config_pb2
  from tensorflow.python.data.experimental.ops import data_service_ops
  from tensorflow.python.data.experimental.service import server_lib
  from tensorflow.python.data.kernel_tests import test_base
  from tensorflow.python.data.ops import dataset_ops
  from tensorflow.python.framework import combinations
  from tensorflow.python.framework import dtypes
  from tensorflow.python.ops import math_ops
  from tensorflow.python.platform import googletest
label_desc: Use image node_id 5 for calling the TestBase obj's underlying member method code with example usage: obj.make_distributed_dataset(dataset, cluster, processing_mode) and returns: dataset