Container.ContainerTypeassignment, conf, containerMemoryTracker, ops, port, resourceIsolationManager, runAsUser, supervisorId, supervisorPort, symlinksDisabled, topoConf, topologyId, type, workerId| Constructor and Description |
|---|
LocalContainer(Map<String,Object> conf,
String supervisorId,
int supervisorPort,
int port,
LocalAssignment assignment,
IContext sharedContext,
StormMetricsRegistry metricsRegistry,
ContainerMemoryTracker containerMemoryTracker,
Supervisor.Iface localSupervisor) |
| Modifier and Type | Method and Description |
|---|---|
boolean |
areAllProcessesDead()
Check whether all processes are dead.
|
protected void |
createArtifactsLink()
Create symlink from the containers directory/artifacts to the artifacts directory.
|
protected void |
createBlobstoreLinks()
Create symlinks for each of the blobs from the container’s directory to corresponding links in the storm dist directory.
|
boolean |
didMainProcessExit()
Return true if the main process exited, else false.
|
void |
kill()
Kill the processes in this container nicely.
|
void |
launch()
Launch the process for the first time.
|
void |
relaunch()
Restart the processes in this container.
|
boolean |
runProfiling(ProfileRequest request,
boolean stop)
Run a profiling request.
|
cleanUp, cleanUpForRestart, deleteSavedWorkerUser, forceKill, getMemoryReservationMb, getMemoryUsageMb, getTotalTopologyMemoryReserved, getTotalTopologyMemoryUsed, getTotalWorkersForThisTopology, getWorkerId, getWorkerUser, isMemoryLimitViolated, readHeartbeat, readTopoConf, saveWorkerUser, setup, toString, updateMemoryAccounting, writeLogMetadatapublic LocalContainer(Map<String,Object> conf, String supervisorId, int supervisorPort, int port, LocalAssignment assignment, IContext sharedContext, StormMetricsRegistry metricsRegistry, ContainerMemoryTracker containerMemoryTracker, Supervisor.Iface localSupervisor) throws IOException
IOExceptionprotected void createArtifactsLink()
ContainerCreate symlink from the containers directory/artifacts to the artifacts directory.
createArtifactsLink in class Containerprotected void createBlobstoreLinks()
ContainerCreate symlinks for each of the blobs from the container’s directory to corresponding links in the storm dist directory.
createBlobstoreLinks in class Containerpublic void launch()
throws IOException
ContainerLaunch the process for the first time. PREREQUISITE: setup has run and passed
launch in class ContainerIOException - on any errorpublic void kill()
throws IOException
KillableKill the processes in this container nicely. kill -15 equivalent
kill in interface Killablekill in class ContainerIOException - on any errorpublic boolean areAllProcessesDead()
throws IOException
KillableCheck whether all processes are dead.
areAllProcessesDead in interface KillableareAllProcessesDead in class ContainerIOException - on any errorpublic void relaunch()
throws IOException
ContainerRestart the processes in this container. PREREQUISITE: cleanUpForRestart has run and passed
relaunch in class ContainerIOException - on any errorpublic boolean didMainProcessExit()
ContainerReturn true if the main process exited, else false. This is just best effort return false if unknown.
didMainProcessExit in class Containerpublic boolean runProfiling(ProfileRequest request, boolean stop) throws IOException, InterruptedException
ContainerRun a profiling request.
runProfiling in class Containerrequest - the request to runstop - is this a stop request?IOException - on any errorInterruptedException - if running the command is interrupted.Copyright © 2021 The Apache Software Foundation. All rights reserved.