1e6685006c4897c89afd9514b46286b49da22a76,perfkitbenchmarker/benchmarks/hbase_ycsb_benchmark.py,,Prepare,#Any#,144

Before Change

  def InstallHBase(vm):
    vm.Install("hbase")
  vm_util.RunThreaded(InstallHBase, vms)
  hadoop.ConfigureAndStart(master, workers, start_yarn=False)
  hbase.ConfigureAndStart(master, workers, zk_quorum)

  _CreateYCSBTable(master)

After Change

  workers = by_role["workers"]
  assert workers, "No workers: {0}".format(by_role)

  hbase_install_fns = [functools.partial(vm.Install, "hbase")
                       for vm in hbase_vms]
  ycsb_install_fns = [functools.partial(vm.Install, "ycsb")
                      for vm in loaders]

  vm_util.RunThreaded(lambda f: f(), hbase_install_fns + ycsb_install_fns)

  hadoop.ConfigureAndStart(master, workers, start_yarn=False)
  hbase.ConfigureAndStart(master, workers, zk_quorum)

Instances