Changeset 30940
- Timestamp:
- 2016-10-26T14:01:01+13:00 (8 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
other-projects/hathitrust/solr-extracted-features/trunk/src/main/java/org/hathitrust/ClusterFileIO.java
r30938 r30940 5 5 import java.io.BufferedReader; 6 6 import java.io.BufferedWriter; 7 import java.io.FileInputStream;8 7 import java.io.FileOutputStream; 9 8 import java.io.IOException; … … 81 80 82 81 if (isHDFS(fileIn)) { 83 //URI uri = URI.create (fileIn);82 URI uri = URI.create (fileIn); 84 83 //Configuration conf = new Configuration(); 85 84 //FileSystem file = FileSystem.get(uri, conf); 86 85 //FSDataInputStream fin = file.open(new Path(uri)); 87 86 88 FSDataInputStream fin = _fs.open(new Path(fileIn)); 89 87 //FSDataInputStream fin = _fs.open(new Path(fileIn)); 88 FSDataInputStream fin = _fs.open(new Path(uri)); 89 90 90 bis = new BufferedInputStream(fin); 91 91 }
Note:
See TracChangeset
for help on using the changeset viewer.