Uses of Class
org.apache.storm.generated.LocalAssignment

Packages that use LocalAssignment

Package	Description
org.apache.storm.daemon.supervisor
org.apache.storm.generated
org.apache.storm.localizer
org.apache.storm.utils

Uses of LocalAssignment in org.apache.storm.daemon.supervisor

Fields in org.apache.storm.daemon.supervisor declared as LocalAssignment

Modifier and Type	Field and Description
protected LocalAssignment	Container._assignment

Methods in org.apache.storm.daemon.supervisor that return types with arguments of type LocalAssignment

Modifier and Type	Method and Description
AtomicReference<Map<Long,LocalAssignment>>	Supervisor.getCurrAssignment()
protected Map<Integer,LocalAssignment>	ReadClusterState.readAssignments(Map<String,VersionedData<Assignment>> assignmentsSnapshot)
protected Map<Integer,LocalAssignment>	ReadClusterState.readMyExecutors(String stormId, String assignmentId, Assignment assignment)

Methods in org.apache.storm.daemon.supervisor with parameters of type LocalAssignment

Modifier and Type	Method and Description
Container	RunAsUserContainerLauncher.launchContainer(int port, LocalAssignment assignment, LocalState state)
Container	LocalContainerLauncher.launchContainer(int port, LocalAssignment assignment, LocalState state)
abstract Container	ContainerLauncher.launchContainer(int port, LocalAssignment assignment, LocalState state) Launch a container in a given slot
Container	BasicContainerLauncher.launchContainer(int port, LocalAssignment assignment, LocalState state)
Container	RunAsUserContainerLauncher.recoverContainer(int port, LocalAssignment assignment, LocalState state)
Container	LocalContainerLauncher.recoverContainer(int port, LocalAssignment assignment, LocalState state)
abstract Container	ContainerLauncher.recoverContainer(int port, LocalAssignment assignment, LocalState state) Recover a container for a running process
Container	BasicContainerLauncher.recoverContainer(int port, LocalAssignment assignment, LocalState state)
void	Slot.setNewAssignment(LocalAssignment newAssignment) Set a new assignment asynchronously

Constructors in org.apache.storm.daemon.supervisor with parameters of type LocalAssignment

Constructor and Description
BasicContainer(Container.ContainerType type, Map<String,Object> conf, String supervisorId, int port, LocalAssignment assignment, LocalState localState, String workerId) Create a new BasicContainer
Container(Container.ContainerType type, Map<String,Object> conf, String supervisorId, int port, LocalAssignment assignment, String workerId, Map<String,Object> topoConf, AdvancedFSOps ops) Create a new Container.
LocalContainer(Map<String,Object> conf, String supervisorId, int port, LocalAssignment assignment, IContext sharedContext)
RunAsUserContainer(Container.ContainerType type, Map<String,Object> conf, String supervisorId, int port, LocalAssignment assignment, LocalState localState, String workerId)

Constructor parameters in org.apache.storm.daemon.supervisor with type arguments of type LocalAssignment

Constructor and Description
Slot(ILocalizer localizer, Map<String,Object> conf, ContainerLauncher containerLauncher, String host, int port, LocalState localState, IStormClusterState clusterState, ISupervisor iSupervisor, AtomicReference<Map<Long,LocalAssignment>> cachedCurrentAssignments)

Uses of LocalAssignment in org.apache.storm.generated

Methods in org.apache.storm.generated that return LocalAssignment

Modifier and Type	Method and Description
LocalAssignment	LocalAssignment.deepCopy()

Methods in org.apache.storm.generated that return types with arguments of type LocalAssignment

Modifier and Type	Method and Description
Map<Integer,LocalAssignment>	LSSupervisorAssignments.get_assignments()

Methods in org.apache.storm.generated with parameters of type LocalAssignment

Modifier and Type	Method and Description
int	LocalAssignment.compareTo(LocalAssignment other)
boolean	LocalAssignment.equals(LocalAssignment that)
void	LSSupervisorAssignments.put_to_assignments(int key, LocalAssignment val)

Method parameters in org.apache.storm.generated with type arguments of type LocalAssignment

Modifier and Type	Method and Description
void	LSSupervisorAssignments.set_assignments(Map<Integer,LocalAssignment> assignments)

Constructors in org.apache.storm.generated with parameters of type LocalAssignment

Constructor and Description
LocalAssignment(LocalAssignment other) Performs a deep copy on other.

Constructor parameters in org.apache.storm.generated with type arguments of type LocalAssignment

Constructor and Description
LSSupervisorAssignments(Map<Integer,LocalAssignment> assignments)

Uses of LocalAssignment in org.apache.storm.localizer

Methods in org.apache.storm.localizer with parameters of type LocalAssignment

Modifier and Type	Method and Description
void	ILocalizer.recoverRunningTopology(LocalAssignment assignemnt, int port) Recover a running topology by incrementing references for what it has already downloaded.
void	AsyncLocalizer.recoverRunningTopology(LocalAssignment assignment, int port)
boolean	LocalDownloadedResource.release(int port, LocalAssignment la) Release a port from the reference count, and update isDone if all is done.
void	ILocalizer.releaseSlotFor(LocalAssignment assignment, int port) dec reference count on all blobs associated with this topology.
void	AsyncLocalizer.releaseSlotFor(LocalAssignment assignment, int port)
Future<Void>	ILocalizer.requestDownloadBaseTopologyBlobs(LocalAssignment assignment, int port) Download storm.jar, storm.conf, and storm.ser for this topology if not done so already, and inc a reference count on them.
Future<Void>	AsyncLocalizer.requestDownloadBaseTopologyBlobs(LocalAssignment assignment, int port)
Future<Void>	ILocalizer.requestDownloadTopologyBlobs(LocalAssignment assignment, int port) Download the blobs for this topology (reading in list in from the config) and inc reference count for these blobs.
Future<Void>	AsyncLocalizer.requestDownloadTopologyBlobs(LocalAssignment assignment, int port)
Future<Void>	LocalDownloadedResource.reserve(int port, LocalAssignment la) Reserve the resources

Uses of LocalAssignment in org.apache.storm.utils

Methods in org.apache.storm.utils that return types with arguments of type LocalAssignment

Modifier and Type	Method and Description
Map<Integer,LocalAssignment>	LocalState.getLocalAssignmentsMap()

Method parameters in org.apache.storm.utils with type arguments of type LocalAssignment

Modifier and Type	Method and Description
void	LocalState.setLocalAssignmentsMap(Map<Integer,LocalAssignment> localAssignmentMap)