NAME

Data::Pipeline - manage aggregated data filters

SYNOPSIS

use Data::Pipeline qw( Pipeline Truncate Count Array );

my $p = Pipeline(
   CSV,
   Truncate( length => 5 ),
);

my $iterator = $p -> from( file => $filename );

until( $iterator -> finished ) {
   my $v = $iterator -> next;
   # get the first five items in a CSV file
}

If combining the output of multiple pipelines:

use Data::Pipeline qw( Pipeline Union );

my $u = Union(
   Pipeline( ... ),
   Pipeline( ... ),
   ...
);

my $iterator = $u -> transform( $source1, $source2, ... );