- Timestamp:
- 2016-12-18T20:38:59+13:00 (7 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
other-projects/hathitrust/wcsa/extracted-features-solr/trunk/solr-ingest/src/main/java/org/hathitrust/extractedfeatures/ProcessForWhitelist.java
r31246 r31247 105 105 106 106 }); 107 JavaPairRDD<Integer, String> sorted_swapped_pair = swappedPair.sortByKey( true, 1); // 1st arg configures ascending sort, 2nd arg configures one task107 JavaPairRDD<Integer, String> sorted_swapped_pair = swappedPair.sortByKey(false,1); 108 108 109 109 JavaPairRDD<String, Integer> sorted_swaped_back_pair = sorted_swapped_pair.mapToPair(new PairFunction<Tuple2<Integer, String>, String, Integer>() { … … 126 126 127 127 //sorted_counts.saveAsTextFile(_json_list_filename + ".out"); 128 129 sorted_swaped_back_pair.saveAsTextFile( _json_list_filename + ".out");128 String output_directory = _json_list_filename.replaceAll("\\.txt$","-out"); 129 sorted_swaped_back_pair.saveAsTextFile(output_directory); 130 130 131 131
Note:
See TracChangeset
for help on using the changeset viewer.