英文:
create file with webHdfs
问题
我想使用webhdfs创建一个文件到HDFS，我编写了以下函数：
public ResponseEntity createFile(MultipartFile f) throws URISyntaxException {
URI uriPut = new URI(
webhdfsBaseurl +
"/gateway/default/webhdfs/v1/__MY_PATH/" + f.getName() +
"?op=CREATE" + "&overwrite=true&data=true");
ResponseEntity e = restTemplate.exchange(uriPut, HttpMethod.PUT,
new HttpEntity<Resource>(f.getResource()), Map.class);
URI location = e.getHeaders().getLocation();
System.out.println(location.toString());
URI uriPutFnal = new URI(
location +
"?op=CREATE" + "&overwrite=true&data=true");
ResponseEntity eFnal = restTemplate.exchange(uriPutFnal, HttpMethod.PUT,
new HttpEntity<Resource>(f.getResource()), Map.class);
URI uri = new URI(webhdfsBaseurl +
"/gateway/default/webhdfs/v1/_PATH_" + "?op=LISTSTATUS");
String test = restTemplate.getForObject(uri, String.class);
System.out.println(test);
return eFnal;
}
在最后一次打印中，我看不到我的文件...
有什么想法？
英文:
I would like to create a file to hdfs with webhdfs, I wrote the function below
public ResponseEntity createFile(MultipartFile f) throws URISyntaxException {
URI uriPut = new URI(
webhdfsBaseurl+
"/gateway/default/webhdfs/v1/__MY_PATH/"+f.getName()+
"?op=CREATE" + "&overwrite=true&data=true");
ResponseEntity e = restTemplate.exchange(uriPut, HttpMethod.PUT,
new HttpEntity<Resource>(f.getResource()), Map.class);
URI location = e.getHeaders().getLocation();
System.out.println(location.toString());
URI uriPutFnal = new URI(
location+
"?op=CREATE" + "&overwrite=true&data=true");
ResponseEntity eFnal = restTemplate.exchange(uriPutFnal, HttpMethod.PUT,
new HttpEntity<Resource>(f.getResource()), Map.class);
URI uri = new URI(webhdfsBaseurl+
"/gateway/default/webhdfs/v1/_PATH_"+"?op=LISTSTATUS");
String test = restTemplate.getForObject(uri, String.class);
System.out.println(test);
return eFnal;
}
In the last print I don't see my file...
Any idea ?
答案1
得分: 0
public ResponseEntity createFile(MultipartFile f) throws URISyntaxException, RestClientException, IOException {
URI uriPut = new URI(webhdfsBaseurl + "/gateway/default/webhdfs/v1/dev/ep/flux_entrant/pg6/"
+ f.getOriginalFilename() + "?op=CREATE" + "&overwrite=true&data=true");
ResponseEntity e = restTemplate.exchange(uriPut, HttpMethod.PUT, null, Map.class);
if (e.getStatusCode().is3xxRedirection()) {
URI location = e.getHeaders().getLocation();
System.out.println(location.toString());
URI uriPutFnal = new URI(location + "?op=CREATE" + "&overwrite=true&data=true");
ResponseEntity eFnal = restTemplate.exchange(uriPutFnal, HttpMethod.PUT,
new HttpEntity<Resource>(f.getResource()), Map.class);
if (eFnal.getStatusCode().is2xxSuccessful()) {
URI uri = new URI(
webhdfsBaseurl + "/gateway/default/webhdfs/v1/dev/ep/flux_entrant/pg6" + "?op=LISTSTATUS");
String test = restTemplate.getForObject(uri, String.class);
System.out.println(test);
return eFnal;
}
}
return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
}
英文:
public ResponseEntity createFile(MultipartFile f) throws URISyntaxException, RestClientException, IOException {
URI uriPut = new URI(webhdfsBaseurl + "/gateway/default/webhdfs/v1/dev/ep/flux_entrant/pg6/"
+ f.getOriginalFilename() + "?op=CREATE" + "&overwrite=true&data=true");
ResponseEntity e = restTemplate.exchange(uriPut, HttpMethod.PUT, null, Map.class);
if (e.getStatusCode().is3xxRedirection()) {
URI location = e.getHeaders().getLocation();
System.out.println(location.toString());
URI uriPutFnal = new URI(location + "?op=CREATE" + "&overwrite=true&data=true");
ResponseEntity eFnal = restTemplate.exchange(uriPutFnal, HttpMethod.PUT,
new HttpEntity<Resource>(f.getResource()), Map.class);
if (eFnal.getStatusCode().is2xxSuccessful()) {
URI uri = new URI(
webhdfsBaseurl + "/gateway/default/webhdfs/v1/dev/ep/flux_entrant/pg6" + "?op=LISTSTATUS");
String test = restTemplate.getForObject(uri, String.class);
System.out.println(test);
return eFnal;
}
}
return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).build();
}
通过集体智慧和协作来改善编程学习和解决问题的方式。致力于成为全球开发者共同参与的知识库，让每个人都能够通过互相帮助和分享经验来进步。
评论