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