naoya / hadoop-streaming-frontend fork watch download tarball
public
Description: A frontend framework of Hadoop-Streaming for perl
Clone URL: git://github.com/naoya/hadoop-streaming-frontend.git 
make Moose immutable
naoya (author)
Fri Jun 27 00:47:52 -0700 2008
commit  6c174819f9d1b1be29dbe12be4737b16d9c6741e
tree    e32679d2e429f18b9c667dbb2519a10b0e9bf68a
parent  269081f731ae8a257916aae67cb2c16b138b3dcf
0
lib/Hadoop/Reducer.pm 
...
19
20
21
22
 
 
 
 
 
 
23
24
25
 
...
19
20
21
 
22
23
24
25
26
27
28
29
30
 
0
@@ -19,7 +19,12 @@ sub run {
0
 
0
     while ($iter->has_next) {
0
         my ($key, $values_iter) = $iter->next or last;
0
-        $self->reduce( $key => $values_iter );
0
+        eval {
0
+            $self->reduce( $key => $values_iter );
0
+        };
0
+        if ($@) {
0
+            warn $@;
0
+        }
0
     }
0
 }
0
 
0
lib/Hadoop/Reducer/Input.pm 
...
50
51
52
 
 
53
 
...
50
51
52
53
54
55
 
0
@@ -50,4 +50,6 @@ sub each {
0
     split /\t/, $line;
0
 }
0
 
0
+__PACKAGE__->meta->make_immutable;
0
+
0
 1;
0
lib/Hadoop/Reducer/Input/Iterator.pm 
...
54
55
56
 
 
57
 
...
54
55
56
57
58
59
 
0
@@ -54,4 +54,6 @@ sub retval {
0
     );
0
 }
0
 
0
+__PACKAGE__->meta->make_immutable;
0
+
0
 1;
0
lib/Hadoop/Reducer/Input/ValuesIterator.pm 
...
29
30
31
 
 
32
33
 
...
29
30
31
32
33
34
35
 
0
@@ -29,5 +29,7 @@ sub next {
0
     $value;
0
 }
0
 
0
+__PACKAGE__->meta->make_immutable;
0
+
0
 1;
0
 

Comments

    No one has commented yet.