com.twitter.heron.scheduler.local

Class LocalLauncher

java.lang.Object

com.twitter.heron.scheduler.local.LocalLauncher

All Implemented Interfaces:

ILauncher, java.lang.AutoCloseable

public class LocalLauncher
extends java.lang.Object
implements ILauncher

Launch topology locally to a working directory.

Field Summary

Fields

Modifier and Type	Field and Description
protected static java.util.logging.Logger	LOG

Constructor Summary

Constructors

Constructor and Description
LocalLauncher()

Method Summary

Modifier and Type	Method and Description
void	close() This is to for disposing or cleaning up any internal state accumulated by the ILauncher
protected java.lang.String[]	getSchedulerCommand()
void	initialize(Config mConfig, Config mRuntime) Initialize Launcher with Config, Uploader and topology.
boolean	launch(PackingPlan packing) Launch the topology
protected boolean	setupWorkingDirectory()
protected java.lang.Process	startScheduler(java.lang.String[] schedulerCmd)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

LOG

protected static final java.util.logging.Logger LOG

Constructor Detail

LocalLauncher

public LocalLauncher()

Method Detail

initialize

public void initialize(Config mConfig,
                       Config mRuntime)

Description copied from interface: ILauncher

Initialize Launcher with Config, Uploader and topology. These object will be passed from submitter main. Config will contain information that launcher may use to setup scheduler and other parameters required by launcher to contact services which will launch scheduler.

Specified by:

initialize in interface ILauncher

close

public void close()

Description copied from interface: ILauncher

This is to for disposing or cleaning up any internal state accumulated by the ILauncher

Closes this stream and releases any system resources associated with it. If the stream is already closed then invoking this method has no effect.

Specified by:

close in interface ILauncher

Specified by:

close in interface java.lang.AutoCloseable

launch

public boolean launch(PackingPlan packing)

Launch the topology

Specified by:

launch in interface ILauncher

Parameters:

packing - Initial mapping suggested by running packing algorithm. container_id->List of instance_id to be launched on this container.

Returns:

true if topology launched successfully, false otherwise.

getSchedulerCommand

protected java.lang.String[] getSchedulerCommand()

setupWorkingDirectory

protected boolean setupWorkingDirectory()

startScheduler

protected java.lang.Process startScheduler(java.lang.String[] schedulerCmd)