54286d5e125fdebf3fa6a82ee16e8172a2127402,perfkitbenchmarker/providers/aws/aws_dpb_emr.py,AwsDpbEmr,CreateBucket,#AwsDpbEmr#Any#,391

Before Change

    pass

  def CreateBucket(self, source_bucket):
    mb_cmd = self.cmd_prefix + ["s3", "mb", "{}{}".format(
        self.PERSISTENT_FS_PREFIX, source_bucket)]
    _, _, _ = vm_util.IssueCommand(mb_cmd)

  def generate_data(self, source_dir, udpate_default_fs, num_files,
                    size_file):
    Method to generate data using a distributed job on the cluster.

After Change

    Args:
      source_bucket: String, name of the bucket to create.
    
    self.s3_service.MakeBucket(source_bucket)

  def DeleteBucket(self, source_bucket):
    Delete a bucket on S3 used during the persistent data processing.

Instances