Constructor and Description |
---|
PunchletDagExecutor(LinkedBlockingQueue<Tuple> inputQueue,
Map<String,LinkedBlockingQueue<Tuple>> affinityMap,
int layer,
int number,
Punchlet punchlet,
Tuple world)
Ctor.
|
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) |
public PunchletDagExecutor(LinkedBlockingQueue<Tuple> inputQueue, Map<String,LinkedBlockingQueue<Tuple>> affinityMap, int layer, int number, Punchlet punchlet, Tuple world)
inputQueue
- this executor input queueaffinityMap
- the affinnity maplayer
- the block layernumber
- the index of the punchletpunchlet
- one of the punchlet form the dagworld
- the common world tuple passed from the dag punchletpublic void setOutputQueue(String affinity, List<LinkedBlockingQueue<Tuple>> queues)
public static int modulo(long l, int size)
public static long hash(String string)
public static long getLongFromField(String field)
public String getName()
Copyright © 2023. All rights reserved.