NAME

Data::Machines - Manage a set of data pipelines

SYNOPSIS

use Data::Machines qw( Pipeline );

my $m = Data::Machine -> new;

$m -> add_pipeline( foo => $pipeline );

$m -> add_source( bar => $source );

$m -> add_connection( bar => foo );

my $iterator = $m -> transform( 'foo' => { additional sources } );

# $iterator is now a Data::Pipeline::Iterator that can be fed into # another machine or pipeline

# for pipelines that map
my $output = $m -> transform( $input );

# for pipelines that  reduce
$m -> start;
$m -> add( $input );
my $output = $m -> finish;

DESCRIPTION