org.thales.punch.libraries.punchlang.impl

Class PunchletDagExecutor

java.lang.Object

org.thales.punch.libraries.punchlang.impl.PunchletDagExecutor

All Implemented Interfaces:

Runnable

public class PunchletDagExecutor
extends Object
implements Runnable

Instance of the punchlet dag lighweight engine.

Author:

dimi

Constructor Summary

Constructors

Constructor and Description
PunchletDagExecutor(LinkedBlockingQueue<Tuple> inputQueue, Map<String,LinkedBlockingQueue<Tuple>> affinityMap, int layer, int number, Punchlet punchlet, Tuple world) Ctor.

Method Summary

Modifier and Type	Method and Description
static long	getLongFromField(String field)
String	getName()
static long	hash(String string)
static int	modulo(long l, int size)
void	run()
void	setOutputQueue(String affinity, List<LinkedBlockingQueue<Tuple>> queues)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

PunchletDagExecutor

public PunchletDagExecutor(LinkedBlockingQueue<Tuple> inputQueue,
                           Map<String,LinkedBlockingQueue<Tuple>> affinityMap,
                           int layer,
                           int number,
                           Punchlet punchlet,
                           Tuple world)

Ctor.

Parameters:

inputQueue - this executor input queue

affinityMap - the affinnity map

layer - the block layer

number - the index of the punchlet

punchlet - one of the punchlet form the dag

world - the common world tuple passed from the dag punchlet

Method Detail

run

public void run()

Specified by:

run in interface Runnable

setOutputQueue

public void setOutputQueue(String affinity,
                           List<LinkedBlockingQueue<Tuple>> queues)

modulo

public static int modulo(long l,
                         int size)

hash

public static long hash(String string)

getLongFromField

public static long getLongFromField(String field)

getName

public String getName()