Commit 60aee3cd authored by ymwang's avatar ymwang

中间结果存储

parent ad5cb34d
...@@ -103,7 +103,7 @@ public class FileService{ ...@@ -103,7 +103,7 @@ public class FileService{
System.out.println(ipList.length); System.out.println(ipList.length);
System.out.println(Arrays.toString(ipList)); System.out.println(Arrays.toString(ipList));
int sliceNum = ipList.length; int sliceNum = 10;
// todo 这里需要制定文件的fileId // todo 这里需要制定文件的fileId
SplitResult splitResult = distributedComService.fileSplit(bufferedImage, sliceNum); SplitResult splitResult = distributedComService.fileSplit(bufferedImage, sliceNum);
...@@ -160,7 +160,7 @@ public class FileService{ ...@@ -160,7 +160,7 @@ public class FileService{
for (int i = 0; i < wxName_list.length; i++){ for (int i = 0; i < wxName_list.length; i++){
ipList[i] = getIpByAppName(clusterId,wxName_list[i]);//通过卫星名字获取卫星ip ipList[i] = getIpByAppName(clusterId,wxName_list[i]);//通过卫星名字获取卫星ip
} }
int sliceNum = ipList.length; int sliceNum = 10;
//int sliceNum = ipList.length; //int sliceNum = ipList.length;
Set<FileSlice> result = new HashSet<>(); Set<FileSlice> result = new HashSet<>();
/* for (String ip : ipList) { /* for (String ip : ipList) {
...@@ -169,7 +169,7 @@ public class FileService{ ...@@ -169,7 +169,7 @@ public class FileService{
}*/ }*/
//异常处理 //异常处理
for (int index = 0; index < ipList.length; index++) { for (int index = 0; index < 10; index++) {
try { try {
Set<FileSlice> fileSliceSet = getFileSlice(ipList[index], fileId); Set<FileSlice> fileSliceSet = getFileSlice(ipList[index], fileId);
result.addAll(fileSliceSet); result.addAll(fileSliceSet);
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment