com.rpl.rama

Class ModuleInstanceInfo

java.lang.Object

com.rpl.rama.ModuleInstanceInfo

All Implemented Interfaces:

RamaSerializable, java.io.Serializable

public class ModuleInstanceInfo
extends java.lang.Object
implements RamaSerializable

Information about current module and worker retrievable during topology execution with Ops.MODULE_INSTANCE_INFO

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ModuleInstanceInfo(java.lang.String moduleName, java.lang.String moduleInstanceId, int numTasks, int replicationFactor, java.lang.String supervisorId, int port, java.util.Set<java.lang.Integer> taskThreadIds)

Method Summary

Modifier and Type	Method and Description
java.lang.String	getModuleInstanceId() Returns module instance ID
java.lang.String	getModuleName() Returns name of module
int	getNumTasks() Returns number of tasks in module
int	getPort() Returns port of worker where ModuleInstanceInfo was fetched
int	getReplicationFactor() Returns replication factor of module
java.lang.String	getSupervisorId() Returns supervisor ID where ModuleInstanceInfo was fetched
java.util.Set<java.lang.Integer>	getTaskThreadIds() Return lowest task ID for each task thread in the module.

Methods inherited from class java.lang.Object

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

Constructor Detail

ModuleInstanceInfo

public ModuleInstanceInfo(java.lang.String moduleName,
                          java.lang.String moduleInstanceId,
                          int numTasks,
                          int replicationFactor,
                          java.lang.String supervisorId,
                          int port,
                          java.util.Set<java.lang.Integer> taskThreadIds)

Method Detail

getModuleName

public java.lang.String getModuleName()

Returns name of module

getModuleInstanceId

public java.lang.String getModuleInstanceId()

Returns module instance ID

See Also:

Documentation on Rama terminology

getNumTasks

public int getNumTasks()

Returns number of tasks in module

getTaskThreadIds

public java.util.Set<java.lang.Integer> getTaskThreadIds()

Return lowest task ID for each task thread in the module.

getReplicationFactor

public int getReplicationFactor()

Returns replication factor of module

getSupervisorId

public java.lang.String getSupervisorId()

Returns supervisor ID where ModuleInstanceInfo was fetched

See Also:

Documentation on Rama terminology

getPort

public int getPort()

Returns port of worker where ModuleInstanceInfo was fetched