Package com.rpl.rama

Class ModuleInstanceInfo

java.lang.Object
com.rpl.rama.ModuleInstanceInfo
All Implemented Interfaces:
RamaSerializable, Serializable
public class ModuleInstanceInfo extends Object implements RamaSerializable
Information about current module and worker retrievable during topology execution with Ops.MODULE_INSTANCE_INFO
See Also:

  • Constructor Details

    • ModuleInstanceInfo

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

  • Method Details

    • getModuleName

      public String getModuleName()
      Returns name of module

    • getModuleInstanceId

      public String getModuleInstanceId()
      Returns module instance ID
      See Also:

    • getNumTasks

      public int getNumTasks()
      Returns number of tasks in module

    • getTaskThreadIds

      public Set<Integer> getTaskThreadIds()
      Return lowest task ID for each task thread in the module.

    • getReplicationFactor

      public int getReplicationFactor()
      Returns replication factor of module

    • getSupervisorId

      public String getSupervisorId()
      Returns supervisor ID where ModuleInstanceInfo was fetched
      See Also:

    • getPort

      public int getPort()
      Returns port of worker where ModuleInstanceInfo was fetched