InputNeuron

package io.netty.buffer;

import java.util.ArrayList;
import java.util.List;

/**
 *
 */
public class Test {

InputNeuron

String desc = String.format( "Iteration %s of %s", step, iterations ); 

merge( new Job().setDelegate( IterJob.Map.class )
                .setInput( graph_by_source ,
                           "/pr/out/rank_vector" ,
                           "/pr/out/dangling" ,
                           "/pr/out/nonlinked" ,
                           "broadcast:/pr/out/nr_nodes" )
                .setOutput( "shuffle:default",

InputNeuron

    public void test1() throws Exception {

        List<Long> delayOptions = Longs.asList( 0, 1000 );

        List<Boolean> chunkOptions = Booleans.asList( true, false );

        for( long delay : delayOptions ) {

            for ( boolean chunked : chunkOptions ) {

InputNeuron

###
# Main peregrine configuration file.  All values here can be overridden on the
# command line by running --param=value.  For example to change the default
# basedir you can run with --basedir=/d0/peregrine-fs  
#
###

###
#
# The controller which will send and receive RPC messages and handle job