Uses of Class
org.apache.storm.generated.Assignment
Package
Description
-
Uses of Assignment in org.apache.storm.assignments
Modifier and TypeMethodDescriptionILocalAssignmentsBackend.getAssignment
(String stormId) Get assignment asAssignment
for a storm.InMemoryAssignmentBackend.getAssignment
(String stormId) Modifier and TypeMethodDescriptionILocalAssignmentsBackend.assignmentsInfo()
Get all the local assignments of local state.InMemoryAssignmentBackend.assignmentsInfo()
Modifier and TypeMethodDescriptionvoid
ILocalAssignmentsBackend.keepOrUpdateAssignment
(String stormId, Assignment assignment) Keep a storm assignment to local state or update old assignment.void
InMemoryAssignmentBackend.keepOrUpdateAssignment
(String stormId, Assignment assignment) -
Uses of Assignment in org.apache.storm.cluster
Modifier and TypeMethodDescriptionIStormClusterState.assignmentInfo
(String stormId, Runnable callback) Get the assignment based on storm id from local backend.StormClusterStateImpl.assignmentInfo
(String stormId, Runnable callback) IStormClusterState.remoteAssignmentInfo
(String stormId, Runnable callback) Get the assignment based on storm id from remote state store, eg: ZK.StormClusterStateImpl.remoteAssignmentInfo
(String stormId, Runnable callback) Modifier and TypeMethodDescriptionIStormClusterState.assignmentInfoWithVersion
(String stormId, Runnable callback) StormClusterStateImpl.assignmentInfoWithVersion
(String stormId, Runnable callback) IStormClusterState.assignmentsInfo()
Get all the topologies assignments mapping stormId -> Assignment from local backend.StormClusterStateImpl.assignmentsInfo()
Modifier and TypeMethodDescriptionvoid
IStormClusterState.setAssignment
(String stormId, Assignment info, Map<String, Object> topoConf) void
StormClusterStateImpl.setAssignment
(String stormId, Assignment info, Map<String, Object> topoConf) -
Uses of Assignment in org.apache.storm.daemon.nimbus
Modifier and TypeMethodDescriptionHeartbeatCache.getAliveExecutors
(String topoId, Set<List<Integer>> allExecutors, Assignment assignment, int taskLaunchSecs) Get all of the alive executors for a given topology.Modifier and TypeMethodDescriptionNimbus.topologiesOnSupervisor
(Map<String, Assignment> assignments, String supervisorId) -
Uses of Assignment in org.apache.storm.daemon.supervisor
Modifier and TypeMethodDescriptionprotected Map<String,
Assignment> ReadClusterState.getAssignmentsSnapshot
(IStormClusterState stormClusterState) Modifier and TypeMethodDescriptionprotected Map<Integer,
LocalAssignment> ReadClusterState.readMyExecutors
(String topoId, String assignmentId, Assignment assignment) Modifier and TypeMethodDescriptionprotected Map<Integer,
LocalAssignment> ReadClusterState.readAssignments
(Map<String, Assignment> assignmentsSnapshot) -
Uses of Assignment in org.apache.storm.daemon.worker
Modifier and TypeMethodDescriptionvoid
WorkerState.suicideIfLocalAssignmentsChanged
(Assignment assignment) -
Uses of Assignment in org.apache.storm.generated
Modifier and TypeMethodDescriptionAssignment.deepCopy()
Supervisor.getLocalAssignmentForStorm_result.get_success()
Supervisor.Client.getLocalAssignmentForStorm
(String id) Supervisor.Iface.getLocalAssignmentForStorm
(String id) Get local assignment for a stormSupervisor.AsyncClient.getLocalAssignmentForStorm_call.getResult()
Supervisor.Client.recv_getLocalAssignmentForStorm()
Modifier and TypeMethodDescriptionSupervisorAssignments.get_storm_assignment()
org.apache.storm.thrift.async.AsyncMethodCallback<Assignment>
Supervisor.AsyncProcessor.getLocalAssignmentForStorm.getResultHandler
(org.apache.storm.thrift.server.AbstractNonblockingServer.AsyncFrameBuffer fb, int seqid) Modifier and TypeMethodDescriptionint
Assignment.compareTo
(Assignment other) boolean
Assignment.equals
(Assignment that) void
SupervisorAssignments.put_to_storm_assignment
(String key, Assignment val) void
Supervisor.getLocalAssignmentForStorm_result.set_success
(Assignment success) Modifier and TypeMethodDescriptionvoid
Supervisor.AsyncClient.getLocalAssignmentForStorm
(String id, org.apache.storm.thrift.async.AsyncMethodCallback<Assignment> resultHandler) void
Supervisor.AsyncIface.getLocalAssignmentForStorm
(String id, org.apache.storm.thrift.async.AsyncMethodCallback<Assignment> resultHandler) void
SupervisorAssignments.set_storm_assignment
(Map<String, Assignment> storm_assignment) void
Supervisor.AsyncProcessor.getLocalAssignmentForStorm.start
(I iface, Supervisor.getLocalAssignmentForStorm_args args, org.apache.storm.thrift.async.AsyncMethodCallback<Assignment> resultHandler) ModifierConstructorDescriptionAssignment
(Assignment other) Performs a deep copy on other.getLocalAssignmentForStorm_result
(Assignment success, NotAliveException e, AuthorizationException aze) ModifierConstructorDescriptiongetLocalAssignmentForStorm_call
(String id, org.apache.storm.thrift.async.AsyncMethodCallback<Assignment> resultHandler, org.apache.storm.thrift.async.TAsyncClient client, org.apache.storm.thrift.protocol.TProtocolFactory protocolFactory, org.apache.storm.thrift.transport.TNonblockingTransport transport)