File Coverage

blib/lib/App/RecordStream/Aggregator/Array.pm

Criterion	Covered	Total	%
statement	22	25	88.0
branch			n/a
condition			n/a
subroutine	8	11	72.7
pod	0	5	0.0
total	30	41	73.1

package App::RecordStream::Aggregator::Array;

our $VERSION = "4.0.23";

use strict;
use warnings;

use App::RecordStream::Aggregator::MapReduce::Field;
use App::RecordStream::Aggregator;
use App::RecordStream::DomainLanguage::Registry;

use base 'App::RecordStream::Aggregator::MapReduce::Field';

sub map_field {
  my ($this, $value) = @_;

  return [$value];
}

sub reduce {
  my ($this, $cookie, $cookie2) = @_;

  return [@$cookie, @$cookie2];
}

sub long_usage {
  return <
Usage: array,
   Collect values from specified field into an array.
EOF
}

sub short_usage {
  return "collect values from provided field into an array";
}

sub argct {
  return 1;
}

App::RecordStream::Aggregator->register_implementation('array', __PACKAGE__);

App::RecordStream::DomainLanguage::Registry::register_vfn(__PACKAGE__, 'new_from_valuation', 'array', 'VALUATION');

1;