File Coverage

blib/lib/Hadoop/Streaming/Mapper.pm

Criterion	Covered	Total	%
statement	6	11	54.5
branch			n/a
condition			n/a
subroutine	2	3	66.6
pod	1	1	100.0
total	9	15	60.0

package Hadoop::Streaming::Mapper;
$Hadoop::Streaming::Mapper::VERSION = '0.143060';
use Moo::Role;
use IO::Handle;

with 'Hadoop::Streaming::Role::Emitter';
#requires qw(emit counter status); #from Hadoop::Streaming::Role::Emitter
requires qw(map);  # from consumer

# ABSTRACT: Simplify writing Hadoop Streaming Mapper jobs.  Write a map() function and let this role handle the Stream interface.




sub run
{
    my $class = shift;
    my $self  = $class->new;

    while ( my $line = STDIN->getline )
    {
        chomp $line;
        $self->map($line);
    }
}

1;

__END__