File Coverage

blib/lib/Hadoop/Streaming/Role/Emitter.pm

Criterion	Covered	Total	%
statement	6	22	27.2
branch	0	2	0.0
condition	0	6	0.0
subroutine	2	6	33.3
pod	4	4	100.0
total	12	40	30.0

package Hadoop::Streaming::Role::Emitter;
$Hadoop::Streaming::Role::Emitter::VERSION = '0.143060';
use Moo::Role;
use Params::Validate qw/validate_pos/;

#provides qw(run emit counter status);

# ABSTRACT: Role to provide emit, counter, and status interaction with Hadoop::Streaming.


sub emit {
    my ($self, $key, $value) = @_;
    eval {
        $self->put($key, $value);
    };
    if ($@) {
        warn $@;
    }
}


sub put
{
    my ($self, $key, $value) = validate_pos(@_, 1, 1, 1);
    printf "%s\t%s\n", $key, $value;
}


sub counter
{
    my ( $self, %opts ) = @_;

    my $group   = $opts{group}   || 'group';
    my $counter = $opts{counter} || 'counter';
    my $amount  = $opts{amount}  || 'amount';

    my $msg
        = sprintf( "reporter:counter:%s,%s,%s\n", $group, $counter, $amount );
    print STDERR $msg;
}


sub status
{
    my ($self, $message ) = @_;

    my $msg = sprintf( "reporter:status:%s\n", $message);
    print STDERR $msg;
}

1;

__END__