Mercurial > lbo > hg > localmr

changeset 34:eca9d24b105f

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
rustfmt
author Lewin Bormann <lbo@spheniscida.de>
date Sun, 31 Jan 2016 19:33:36 +0000
parents def737737bc8
children fcb3ee662ee7
files src/map.rs src/parameters.rs
diffstat 2 files changed, 14 insertions(+), 5 deletions(-) [+]
line wrap: on
line diff
--- a/src/map.rs	Sun Jan 31 19:33:13 2016 +0000
+++ b/src/map.rs	Sun Jan 31 19:33:36 2016 +0000
@@ -26,7 +26,11 @@
 }
 
 impl<MR: MapReducer, SinkGen: MRSinkGenerator> MapPartition<MR, SinkGen> {
-    pub fn _new(params: MRParameters, input: MapInput, mr: MR, output: SinkGen) -> MapPartition<MR, SinkGen> {
+    pub fn _new(params: MRParameters,
+                input: MapInput,
+                mr: MR,
+                output: SinkGen)
+                -> MapPartition<MR, SinkGen> {
         MapPartition {
             mr: mr,
             params: params,
@@ -91,7 +95,9 @@
         let mut outputs = Vec::new();
 
         for i in 0..self.params.reducers {
-            let out = self.sink.new_output(&fmt::format(format_args!("mapout_{}.{}", self.params.shard_id, i)));
+            let out = self.sink.new_output(&fmt::format(format_args!("mapout_{}.{}",
+                                                                     self.params.shard_id,
+                                                                     i)));
             outputs.push(out);
         }
         assert_eq!(outputs.len(), self.params.reducers);
@@ -142,7 +148,7 @@
 #[cfg(test)]
 mod tests {
     use closure_mr::ClosureMapReducer;
-    use formats::util::{RecordIterator};
+    use formats::util::RecordIterator;
     use formats::lines::LinesSinkGenerator;
     use map::MapPartition;
     use mapreducer::{MEmitter, REmitter, Record, MultiRecord};
@@ -183,7 +189,10 @@
 
     #[test]
     fn test_map_partition() {
-        let mp = MapPartition::_new(MRParameters::new().set_concurrency(4, 3), get_input(), get_mr(), get_output());
+        let mp = MapPartition::_new(MRParameters::new().set_concurrency(4, 3),
+                                    get_input(),
+                                    get_mr(),
+                                    get_output());
         mp._run();
     }
 }
--- a/src/parameters.rs	Sun Jan 31 19:33:13 2016 +0000
+++ b/src/parameters.rs	Sun Jan 31 19:33:36 2016 +0000
@@ -7,7 +7,7 @@
 
     pub mappers: usize,
     pub reducers: usize,
-    
+
     pub map_partition_size: usize,
 
     // Internal parameters