File Coverage

blib/lib/App/RecordStream/Aggregator/MapReduce/FieldSet.pm

Criterion	Covered	Total	%
statement	28	29	96.5
branch			n/a
condition			n/a
subroutine	8	9	88.8
pod	0	4	0.0
total	36	42	85.7

package App::RecordStream::Aggregator::MapReduce::FieldSet;

our $VERSION = "4.0.23";

use strict;
use warnings;

use App::RecordStream::Aggregator::MapReduce;
use App::RecordStream::DomainLanguage::Valuation::KeySpec;

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

sub new
{
  my $class = shift;
  my @fields = @_;

  return new_from_valuation($class, map { App::RecordStream::DomainLanguage::Valuation::KeySpec->new($_) } @fields);
}

sub new_from_valuation
{
  my $class = shift;
  my @valuations = @_;

  my $this =
  {
    'valuations' => \@valuations,
  };
  bless $this, $class;

  return $this;
}

sub map
{
  my ($this, $record) = @_;

  return $this->map_fields(map { $_->evaluate_record($record) } @{$this->{'valuations'}});
}

sub map_fields
{
  die "FieldSet subclass does not implement map_fields\n";
}

1;