File Coverage

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

Criterion	Covered	Total	%
statement	32	34	94.1
branch	2	2	100.0
condition			n/a
subroutine	8	10	80.0
pod	0	5	0.0
total	42	51	82.3

package App::RecordStream::Aggregator::Mode;

our $VERSION = "4.0.25";

use strict;
use warnings;

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

use base qw(App::RecordStream::Aggregator::InjectInto::Field);

#sub new -- passed through

#sub new_from_valuation -- passed through

sub initial {
  return {};
}

sub combine_field
{
  my $this   = shift;
  my $cookie = shift;
  my $value  = shift;

  $cookie->{$value}++;
  return $cookie;
}

sub squish {
  my $this   = shift;
  my $cookie = shift;

  my @keys      = keys %$cookie;
  my $max_key   = shift @keys;
  my $max_value = $cookie->{$max_key};

  foreach my $key ( @keys ) {
    my $value = $cookie->{$key};
    if ( $max_value < $value ) {
      $max_key   = $key;
      $max_value = $value;
    }
  }

  return $max_key;
}

sub short_usage
{
  return "most common value for a field";
}

sub long_usage
{
  print <
Usage: mode,
   Finds the most common value for a field and returns it.
   Will load all values into memory.
EOF
}

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

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

1;