com.twitter.heron.simulator.utils

Class XORManager

java.lang.Object

com.twitter.heron.simulator.utils.XORManager

public class XORManager
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
XORManager(WakeableLooper looper, int timeoutSec, java.util.List<java.lang.Integer> taskIds, int nBuckets)

Method Summary

Modifier and Type	Method and Description
boolean	anchor(int taskId, long key, long value)
void	create(int taskId, long key, long value)
protected java.util.Map<java.lang.Integer,RotatingMap>	getSpoutTasksToRotatingMap()
static XORManager	populateXORManager(WakeableLooper looper, TopologyAPI.Topology topology, int nBuckets, java.util.Map<java.lang.String,java.util.List<java.lang.Integer>> componentToTaskIds) Populate the XORManager for all spouts for the topology.
boolean	remove(int taskId, long key)
protected void	rotate()

Methods inherited from class java.lang.Object

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

Constructor Detail

XORManager

public XORManager(WakeableLooper looper,
                  int timeoutSec,
                  java.util.List<java.lang.Integer> taskIds,
                  int nBuckets)

Method Detail

populateXORManager

public static XORManager populateXORManager(WakeableLooper looper,
                                            TopologyAPI.Topology topology,
                                            int nBuckets,
                                            java.util.Map<java.lang.String,java.util.List<java.lang.Integer>> componentToTaskIds)

Populate the XORManager for all spouts for the topology.

Parameters:

looper - The WakeableLooper to execute timer event

topology - The given topology protobuf

nBuckets - number of buckets to divide the message timeout seconds

componentToTaskIds - the map of componentName to its list of taskIds in the topology

Returns:

the XORManager for all spouts' task for the topology

create

public void create(int taskId,
                   long key,
                   long value)

anchor

public boolean anchor(int taskId,
                      long key,
                      long value)

remove

public boolean remove(int taskId,
                      long key)

rotate

protected void rotate()

getSpoutTasksToRotatingMap

protected java.util.Map<java.lang.Integer,RotatingMap> getSpoutTasksToRotatingMap()