def _Load(self, vm, **kwargs):
    kwargs.setdefault('threads', self._default_preload_threads)
    kwargs.setdefault('recordcount', FLAGS.ycsb_record_count)
    for pv in FLAGS.ycsb_load_parameters:
      param, value = pv.split('=', 1)
      kwargs[param] = value
    command = self._BuildCommand('load', **kwargs)
    stdout, _ = vm.RobustRemoteCommand(command)
    return ParseResults(str(stdout))
Execute 'ycsb load' on 'vm'.
dataset/ETHPy150Open GoogleCloudPlatform/PerfKitBenchmarker/perfkitbenchmarker/linux_packages/ycsb.py/YCSBExecutor._Load