File Coverage

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

Criterion	Covered	Total	%
statement	18	41	43.9
branch	0	2	0.0
condition			n/a
subroutine	6	14	42.8
pod	0	8	0.0
total	24	65	36.9

package App::RecordStream::Aggregator::RecordForMinimum;

our $VERSION = "4.0.23";

use strict;
use warnings;

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

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

sub new
{
  my $class = shift;
  my $field = shift;

  return new_from_valuation($class, App::RecordStream::DomainLanguage::Valuation::KeySpec->new($field));
}

sub new_from_valuation
{
  my $class = shift;
  my ($valuation) = @_;

  my $this =
  {
    'valuation' => $valuation,
  };
  bless $this, $class;

  return $this;
}

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

  my $value = $this->{'valuation'}->evaluate_record($record);

  return [$value, $record];
}

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

  my ($v1, $r1) = @$cookie1;
  my ($v2, $r2) = @$cookie2;

  if($v1 < $v2)
  {
    return $cookie1;
  }

  return $cookie2;
}

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

  my ($v, $r) = @$cookie;

  return $r;
}

sub argct
{
  return 1;
}

sub short_usage
{
  return "returns the record corresponding to the minimum value for a field";
}

sub long_usage
{
  return <
Usage: recformin,
   The record corresponding to the minimum value of specified field.
EOF
}

App::RecordStream::Aggregator->register_implementation('recformin', __PACKAGE__);
App::RecordStream::Aggregator->register_implementation('recforminimum', __PACKAGE__);
App::RecordStream::Aggregator->register_implementation('recordformin', __PACKAGE__);
App::RecordStream::Aggregator->register_implementation('recordforminimum', __PACKAGE__);

App::RecordStream::DomainLanguage::Registry::register_vfn(__PACKAGE__, 'new_from_valuation', 'recformin', 'VALUATION');
App::RecordStream::DomainLanguage::Registry::register_vfn(__PACKAGE__, 'new_from_valuation', 'recforminimum', 'VALUATION');
App::RecordStream::DomainLanguage::Registry::register_vfn(__PACKAGE__, 'new_from_valuation', 'recordformin', 'VALUATION');
App::RecordStream::DomainLanguage::Registry::register_vfn(__PACKAGE__, 'new_from_valuation', 'recordforminimum', 'VALUATION');

1;