Changeset 19783

Timestamp:

09/24/08 00:37:05 (5 years ago)

Author:

lopnor

Message:

lang/perl/App-Hachero: hadoop support for A::H::Result

Location:

lang/perl/App-Hachero/trunk

Files:

• lib/App/Hachero/Plugin/Parse/HadoopReduce.pm (modified) (2 diffs)
• lib/App/Hachero/Result.pm (modified) (1 diff)
• t/plugin/output_line/01_hadoop_map.t (modified) (2 diffs)
• t/plugin/parse/03_hadoop_reduce.t (modified) (1 diff)

lang/perl/App-Hachero/trunk/lib/App/Hachero/Plugin/Parse/HadoopReduce.pm

@@ -3 +3 @@
 use warnings;
 use base 'App::Hachero::Plugin::Base';
+use App::Hachero::Result;
 
 sub parse : Hook {
@@ -12 +13 @@
     my $record = $context->result->{$prime}->{$second};
     if ($record) {
-        $record->{count} += $VAR1->{count};
+        $record->count_up($VAR1->{count});
     } else {
         $context->result->{$prime}->{$second} = $VAR1;

lang/perl/App-Hachero/trunk/lib/App/Hachero/Result.pm

@@ -69 +69 @@
 
 sub count_up {
-    shift->{count}++;
+    my ($self, $n) = @_;
+    $n ||= 1;
+    shift->{count} += $n;
 }
 

lang/perl/App-Hachero/trunk/t/plugin/output_line/01_hadoop_map.t

@@ -1 +1 @@
 use strict;
 use warnings;
-use Test::More tests => 3;
+use Test::More tests => 4;
 use App::Hachero;
 use App::Hachero::Result;
@@ -44 +44 @@
 my $VAR1;
 eval $value;
+isa_ok $VAR1, 'App::Hachero::Result::Data';
 is_deeply $VAR1, {a => 1, count => 1};

lang/perl/App-Hachero/trunk/t/plugin/parse/03_hadoop_reduce.t

@@ -16 +16 @@
 my $app = App::Hachero->new({config => $config});
 
-$app->currentline(qq(hoo-bar\t\$VAR1={"a" => 1,"count" => 3}\n));
+$app->currentline(qq(hoo-bar\t\$VAR1=bless( {"a" => 1,"count" => 3}, 'App::Hachero::Result::Data' )\n));
 $app->run_hook('parse');
 is_deeply $app->result->{hoo}->{bar}, {a => 1, count => 3};
-$app->currentline(qq(hoo-bar\t\$VAR1={"a" => 1,"count" => 7}\n));
+$app->currentline(qq(hoo-bar\t\$VAR1=bless( {"a" => 1,"count" => 7}, 'App::Hachero::Result::Data' )\n));
 $app->run_hook('parse');
 is_deeply $app->result->{hoo}->{bar}, {a => 1, count => 10};