Changeset 30924
- Timestamp:
- 2016-10-25T23:49:13+13:00 (7 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
other-projects/hathitrust/solr-extracted-features/trunk/src/main/java/org/hathitrust/PagedJSON.java
r30921 r30924 3 3 import java.io.BufferedInputStream; 4 4 import java.io.BufferedReader; 5 import java.io.FileInputStream;6 import java.io.FileNotFoundException;5 //import java.io.FileInputStream; 6 //import java.io.FileNotFoundException; 7 7 import java.io.IOException; 8 8 import java.io.InputStreamReader; 9 import java.io.UnsupportedEncodingException;9 //import java.io.UnsupportedEncodingException; 10 10 import java.net.URI; 11 import java.nio.charset.StandardCharsets;11 //import java.nio.charset.StandardCharsets; 12 12 //import java.nio.file.Files; 13 13 //import java.nio.file.Path; 14 14 //import java.nio.file.Paths; 15 15 import java.util.ArrayList; 16 import java.util.Arrays;16 //import java.util.Arrays; 17 17 import java.util.Iterator; 18 import java.util.List;18 //import java.util.List; 19 19 20 20 import org.apache.commons.compress.compressors.CompressorException; … … 38 38 */ 39 39 40 41 /*42 URI uri = URI.create ("hdfs://host:port/file path");43 Configuration conf = new Configuration();44 FileSystem file = FileSystem.get(uri, conf);45 FSDataInputStream in = file.open(new Path(uri));46 47 */48 40 49 41 class PagedJSON implements FlatMapFunction<String, String>
Note:
See TracChangeset
for help on using the changeset viewer.