def METHOD_NAME(benchmark_spec):
  """Prepare phase uses schema creation script and sample data to prepare table.
  Args:
    benchmark_spec: Configuration that holds the definition and instance details
      of the resources used for benchmarking.
  """
  storage_service = object_storage_service.GetObjectStorageClass(FLAGS.cloud)()
  dpb_service_instance = benchmark_spec.dpb_service
  run_uri = benchmark_spec.uuid.split('-')[0]
  uri_map = ManageLifecycleResources(run_uri, dpb_service_instance,
                                     storage_service)
  dml_script_uri = uri_map['dml_script']
  data_folder_uri = uri_map['data']
  stats = dpb_service_instance.SubmitJob(
      pyspark_file=dml_script_uri,
      job_type=BaseDpbService.PYSPARK_JOB_TYPE,
      job_arguments=[data_folder_uri])
  logging.info(stats)
  if not stats['success']:
    logging.warning('Table Creation Failed')