'@param host hostname or IP of the namenode
@param thrift_port port on which the Thrift plugin is listening
@param hdfs_port port on which NameNode IPC is listening
@param hadoop_bin_path path to find the hadoop wrapper script on the
installed system - default is fine if it is in
the user\'s PATH env
@param temp_dir Temporary directory, for mktemp()'

def __init__(self, host, thrift_port, hdfs_port=8020, nn_kerberos_principal='hdfs', dn_kerberos_principal='hdfs', security_enabled=False, hadoop_bin_path='hadoop', temp_dir='/tmp'):

    self.host = host
    self.thrift_port = thrift_port
    self.hdfs_port = hdfs_port
    self.security_enabled = security_enabled
    self.nn_kerberos_principal = nn_kerberos_principal
    self.dn_kerberos_principal = dn_kerberos_principal
    self.hadoop_bin_path = hadoop_bin_path
    self._resolve_hadoop_path()
    self.security_enabled = security_enabled
    self._temp_dir = temp_dir
    self.nn_client = thrift_util.get_client(Namenode.Client, host, thrift_port, service_name='HDFS    Namenode    HUE    Plugin', use_sasl=security_enabled, kerberos_principal=nn_kerberos_principal, timeout_seconds=NN_THRIFT_TIMEOUT)
    self.thread_local = threading.local()
    self.setuser(DEFAULT_USER)
    LOG.debug('Initialized    HadoopFS:    %s:%d    (%s)', host, thrift_port, hadoop_bin_path)
