def create_hdfs_user(self, user):
    Execute(('hadoop fs -mkdir -p /user/' + user), user='hdfs', ignore_failures=True)
    Execute(((('hadoop fs -chown ' + user) + ' /user/') + user), user='hdfs')
    Execute(((('hadoop fs -chgrp ' + user) + ' /user/') + user), user='hdfs')
def create_hdfs_user(self, user):
    Execute(('hadoop fs -mkdir -p /user/' + user), user='hdfs', ignore_failures=True)
    Execute(((('hadoop fs -chown ' + user) + ' /user/') + user), user='hdfs')
    Execute(((('hadoop fs -chgrp ' + user) + ' /user/') + user), user='hdfs')