public class PartitionConnected<A extends Agent<?>,T extends Link> extends java.lang.Object implements Connector<A>
| Constructor and Description |
|---|
PartitionConnected(java.lang.Class<T> linkClass,
SerializableBiConsumer<A,T> dataInjector) |
| Modifier and Type | Method and Description |
|---|---|
void |
connectAgent(A agent,
GroupInformation sourceInfo,
GroupInformation targetInfo)
The method that creates links between the agent whose `agentInit` is in charge of.
|
PartitionConnected<A,T> |
shard() |
PartitionConnected<A,T> |
weave() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitcreateLink, createLinkspublic PartitionConnected(java.lang.Class<T> linkClass, SerializableBiConsumer<A,T> dataInjector)
public PartitionConnected<A,T> weave()
public PartitionConnected<A,T> shard()
public void connectAgent(A agent, GroupInformation sourceInfo, GroupInformation targetInfo)
ConnectorconnectAgent in interface Connector<A extends Agent<?>>agent - : the agent to be connected. Links are to be added directly to this agent.sourceInfo - : information of the source grouptargetInfo - : information of the target group