Package | Description |
---|---|
org.apache.storm.daemon.supervisor | |
org.apache.storm.generated | |
org.apache.storm.localizer | |
org.apache.storm.utils |
Modifier and Type | Class and Description |
---|---|
class |
TimerDecoratedAssignment |
Modifier and Type | Field and Description |
---|---|
protected LocalAssignment |
Container.assignment |
Modifier and Type | Method and Description |
---|---|
AtomicReference<Map<Long,LocalAssignment>> |
Supervisor.getCurrAssignment() |
protected Map<Integer,LocalAssignment> |
ReadClusterState.readAssignments(Map<String,Assignment> assignmentsSnapshot) |
protected Map<Integer,LocalAssignment> |
ReadClusterState.readMyExecutors(String topoId,
String assignmentId,
Assignment assignment) |
Modifier and Type | Method and Description |
---|---|
void |
Slot.blobChanging(LocalAssignment assignment,
int port,
LocallyCachedBlob blob,
GoodToGo go) |
long |
Container.getTotalTopologyMemoryReserved(LocalAssignment withUpdatedLimits)
Get the total memory reserved.
|
boolean |
BasicContainer.isMemoryLimitViolated(LocalAssignment withUpdatedLimits) |
boolean |
Container.isMemoryLimitViolated(LocalAssignment withUpdatedLimits)
Check if the container is over its memory limit AND needs to be killed.
|
Container |
LocalContainerLauncher.launchContainer(int port,
LocalAssignment assignment,
LocalState state) |
Container |
RunAsUserContainerLauncher.launchContainer(int port,
LocalAssignment assignment,
LocalState state) |
Container |
BasicContainerLauncher.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 |
LocalContainerLauncher.recoverContainer(int port,
LocalAssignment assignment,
LocalState state) |
Container |
RunAsUserContainerLauncher.recoverContainer(int port,
LocalAssignment assignment,
LocalState state) |
Container |
BasicContainerLauncher.recoverContainer(int port,
LocalAssignment assignment,
LocalState state) |
abstract Container |
ContainerLauncher.recoverContainer(int port,
LocalAssignment assignment,
LocalState state)
Recover a container for a running process.
|
void |
Slot.setNewAssignment(LocalAssignment newAssignment)
Set a new assignment asynchronously.
|
Constructor and Description |
---|
BasicContainer(Container.ContainerType type,
Map<String,Object> conf,
String supervisorId,
int supervisorPort,
int port,
LocalAssignment assignment,
ResourceIsolationInterface resourceIsolationManager,
LocalState localState,
String workerId,
StormMetricsRegistry metricsRegistry,
ContainerMemoryTracker containerMemoryTracker)
Create a new BasicContainer.
|
Container(Container.ContainerType type,
Map<String,Object> conf,
String supervisorId,
int supervisorPort,
int port,
LocalAssignment assignment,
ResourceIsolationInterface resourceIsolationManager,
String workerId,
Map<String,Object> topoConf,
AdvancedFSOps ops,
StormMetricsRegistry metricsRegistry,
ContainerMemoryTracker containerMemoryTracker)
Create a new Container.
|
LocalContainer(Map<String,Object> conf,
String supervisorId,
int supervisorPort,
int port,
LocalAssignment assignment,
IContext sharedContext,
StormMetricsRegistry metricsRegistry,
ContainerMemoryTracker containerMemoryTracker,
Supervisor.Iface localSupervisor) |
RunAsUserContainer(Container.ContainerType type,
Map<String,Object> conf,
String supervisorId,
int supervisorPort,
int port,
LocalAssignment assignment,
ResourceIsolationInterface resourceIsolationManager,
LocalState localState,
String workerId,
StormMetricsRegistry metricsRegistry,
ContainerMemoryTracker containerMemoryTracker) |
TimerDecoratedAssignment(LocalAssignment other,
com.codahale.metrics.Timer timer) |
Constructor and Description |
---|
Slot(AsyncLocalizer localizer,
Map<String,Object> conf,
ContainerLauncher containerLauncher,
String host,
int port,
LocalState localState,
IStormClusterState clusterState,
ISupervisor supervisor,
AtomicReference<Map<Long,LocalAssignment>> cachedCurrentAssignments,
OnlyLatestExecutor<Integer> metricsExec,
WorkerMetricsProcessor metricsProcessor,
org.apache.storm.daemon.supervisor.SlotMetrics slotMetrics) |
Modifier and Type | Method and Description |
---|---|
LocalAssignment |
LocalAssignment.deepCopy() |
Modifier and Type | Method and Description |
---|---|
Map<Integer,LocalAssignment> |
LSSupervisorAssignments.get_assignments() |
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) |
Modifier and Type | Method and Description |
---|---|
void |
LSSupervisorAssignments.set_assignments(Map<Integer,LocalAssignment> assignments) |
Constructor and Description |
---|
LocalAssignment(LocalAssignment other)
Performs a deep copy on other.
|
Constructor and Description |
---|
LSSupervisorAssignments(Map<Integer,LocalAssignment> assignments) |
Modifier and Type | Method and Description |
---|---|
LocalAssignment |
TimePortAndAssignment.getAssignment() |
LocalAssignment |
PortAndAssignment.getAssignment() |
Modifier and Type | Method and Description |
---|---|
void |
BlobChangingCallback.blobChanging(LocalAssignment assignment,
int port,
LocallyCachedBlob blob,
GoodToGo go)
Informs the listener that a blob has changed and is ready to update and replace a localized blob that has been marked as tied to the life cycle of the worker process.
|
void |
AsyncLocalizer.recoverRunningTopology(LocalAssignment currentAssignment,
int port,
BlobChangingCallback cb)
Do everything needed to recover the state in the AsyncLocalizer for a running topology.
|
void |
AsyncLocalizer.releaseSlotFor(LocalAssignment assignment,
int port)
Remove this assignment/port as blocking resources from being cleaned up.
|
CompletableFuture<Void> |
AsyncLocalizer.requestDownloadTopologyBlobs(LocalAssignment assignment,
int port,
BlobChangingCallback cb)
Request that all of the blobs necessary for this topology be downloaded.
|
Modifier and Type | Method and Description |
---|---|
Map<Integer,LocalAssignment> |
LocalState.getLocalAssignmentsMap() |
Modifier and Type | Method and Description |
---|---|
void |
LocalState.setLocalAssignmentsMap(Map<Integer,LocalAssignment> localAssignmentMap) |
Copyright © 2022 The Apache Software Foundation. All rights reserved.