1
0
Fork 0

minor changes

This commit is contained in:
miconis 2020-03-24 17:43:51 +01:00
parent 8e8b5e8f30
commit 02320de371
1 changed files with 0 additions and 20 deletions

View File

@ -80,24 +80,4 @@ public class SparkCreateDedupTest {
System.out.println(s2.hashCode()); System.out.println(s2.hashCode());
System.out.println(hashFunction.hashString(s2).asLong()); System.out.println(hashFunction.hashString(s2).asLong());
} }
@Test
public void fileExistsTest() throws IOException {
boolean result = false;
FileSystem fileSystem = FileSystem.get(new Configuration());
FileStatus[] fileStatuses = fileSystem.listStatus(new Path("/tmp"));
for (FileStatus fs : fileStatuses) {
if (fs.isDirectory()) {
if (fileSystem.exists(new Path(DedupUtility.createMergeRelPath("/tmp", fs.getPath().getName(), "cicciopasticcio")))) {
System.out.println("fs = " + DedupUtility.createMergeRelPath("/tmp", fs.getPath().getName(), "cicciopasticcio"));
result = true;
}
}
}
}
} }