def hadoop(self, hadoop_options=None):
    if (hadoop_options is None):
        hadoop_options = []
    env = self.get_env()
    env['JMX_PORT'] = self.jmx_port
    dse = common.join_bin(self.get_install_dir(), 'bin', 'dse')
    args = [dse, 'hadoop']
    args += hadoop_options
    p = subprocess.Popen(args, env=env)
    p.wait()
def hadoop(self, hadoop_options=None):
    if (hadoop_options is None):
        hadoop_options = []
    env = self.get_env()
    env['JMX_PORT'] = self.jmx_port
    dse = common.join_bin(self.get_install_dir(), 'bin', 'dse')
    args = [dse, 'hadoop']
    args += hadoop_options
    p = subprocess.Popen(args, env=env)
    p.wait()