August 2017
Beginner to intermediate
284 pages
6h 51m
English
Now let's make the jump from component IDs to actual executors, as that's the level at which the Storm cluster deals with assignments.
The process is quite straightforward:
private Set<ExecutorDetails> getAllAliveExecutors(Cluster cluster, TopologyDetails topologyDetails) { // Get the existing assignment of the current topology as it's live in the cluster SchedulerAssignment existingAssignment = cluster.getAssignmentById(topologyDetails.getId()); // Return alive executors, ...Read now
Unlock full access