|
@@ -480,7 +480,7 @@ class WebHdfs(Hdfs):
|
|
|
params = self._getparams()
|
|
params = self._getparams()
|
|
|
params['op'] = 'MODIFYACLENTRIES'
|
|
params['op'] = 'MODIFYACLENTRIES'
|
|
|
params['aclspec'] = aclspec
|
|
params['aclspec'] = aclspec
|
|
|
- self._invoke_with_redirect('PUT', path, params)
|
|
|
|
|
|
|
+ return self._root.put(path, params)
|
|
|
|
|
|
|
|
|
|
|
|
|
def remove_acl_entries(self, path, aclspec):
|
|
def remove_acl_entries(self, path, aclspec):
|
|
@@ -488,36 +488,36 @@ class WebHdfs(Hdfs):
|
|
|
params = self._getparams()
|
|
params = self._getparams()
|
|
|
params['op'] = 'REMOVEACLENTRIES'
|
|
params['op'] = 'REMOVEACLENTRIES'
|
|
|
params['aclspec'] = aclspec
|
|
params['aclspec'] = aclspec
|
|
|
- self._invoke_with_redirect('PUT', path, params)
|
|
|
|
|
|
|
+ return self._root.put(path, params)
|
|
|
|
|
|
|
|
|
|
|
|
|
def remove_default_acl(self, path):
|
|
def remove_default_acl(self, path):
|
|
|
path = Hdfs.normpath(path)
|
|
path = Hdfs.normpath(path)
|
|
|
params = self._getparams()
|
|
params = self._getparams()
|
|
|
params['op'] = 'REMOVEDEFAULTACL'
|
|
params['op'] = 'REMOVEDEFAULTACL'
|
|
|
- self._invoke_with_redirect('PUT', path, params)
|
|
|
|
|
|
|
+ return self._root.put(path, params)
|
|
|
|
|
|
|
|
|
|
|
|
|
def remove_acl(self, path):
|
|
def remove_acl(self, path):
|
|
|
path = Hdfs.normpath(path)
|
|
path = Hdfs.normpath(path)
|
|
|
params = self._getparams()
|
|
params = self._getparams()
|
|
|
params['op'] = 'REMOVEACL'
|
|
params['op'] = 'REMOVEACL'
|
|
|
- self._invoke_with_redirect('PUT', path, params)
|
|
|
|
|
|
|
+ return self._root.put(path, params)
|
|
|
|
|
|
|
|
|
|
|
|
|
def set_acl(self, path, aclspec):
|
|
def set_acl(self, path, aclspec):
|
|
|
path = Hdfs.normpath(path)
|
|
path = Hdfs.normpath(path)
|
|
|
params = self._getparams()
|
|
params = self._getparams()
|
|
|
- params['op'] = 'REMOVEACL'
|
|
|
|
|
|
|
+ params['op'] = 'SETACL'
|
|
|
params['aclspec'] = aclspec
|
|
params['aclspec'] = aclspec
|
|
|
- self._invoke_with_redirect('PUT', path, params)
|
|
|
|
|
|
|
+ return self._root.put(path, params)
|
|
|
|
|
|
|
|
|
|
|
|
|
def get_acl_status(self, path):
|
|
def get_acl_status(self, path):
|
|
|
path = Hdfs.normpath(path)
|
|
path = Hdfs.normpath(path)
|
|
|
params = self._getparams()
|
|
params = self._getparams()
|
|
|
params['op'] = 'GETACLSTATUS'
|
|
params['op'] = 'GETACLSTATUS'
|
|
|
- self._invoke_with_redirect('PUT', path, params)
|
|
|
|
|
|
|
+ return self._root.get(path, params)
|
|
|
|
|
|
|
|
|
|
|
|
|
def copyfile(self, src, dst, skip_header=False):
|
|
def copyfile(self, src, dst, skip_header=False):
|