Mercurial > lbo > hg > localmr

changeset 90:9853a14b08fb

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
Switch around shard/partition in file names
author Lewin Bormann <lbo@spheniscida.de>
date Sun, 07 Feb 2016 15:29:39 +0000
parents dc8d7e8f4ba1
children f451bcd4cecd
files src/controller.rs src/map.rs
diffstat 2 files changed, 3 insertions(+), 3 deletions(-) [+]
line wrap: on
line diff
--- a/src/controller.rs	Sun Feb 07 15:14:56 2016 +0000
+++ b/src/controller.rs	Sun Feb 07 15:29:39 2016 +0000
@@ -39,7 +39,7 @@
     let mut inputs = Vec::new();
 
     for part in 0..partitions {
-        let name = fmt::format(format_args!("{}{}.{}", params.map_output_location, shard, part));
+        let name = fmt::format(format_args!("{}{}.{}", params.map_output_location, part, shard));
         let wlg_reader = WriteLogReader::new_from_file(&name).unwrap();
         inputs.push(RecordReadIterator::new(wlg_reader));
     }
--- a/src/map.rs	Sun Feb 07 15:14:56 2016 +0000
+++ b/src/map.rs	Sun Feb 07 15:29:39 2016 +0000
@@ -97,8 +97,8 @@
         for i in 0..self.params.reducers {
             let out = self.sink.new_output(&fmt::format(format_args!("{}{}.{}",
                                                                      self.params.map_output_location,
-                                                                     i,
-                                                                     self.params.shard_id)));
+                                                                     self.params.shard_id,
+                                                                     i)));
             outputs.push(out);
         }
         assert_eq!(outputs.len(), self.params.reducers);