Package org.apache.storm.executor

Class LocalExecutor

java.lang.Object

org.apache.storm.executor.LocalExecutor

public class LocalExecutor
extends Object

Constructor Summary

Constructors

Constructor	Description
LocalExecutor()

Method Summary

Modifier and Type	Method	Description
static void	clearTrackId()
static Executor	mkExecutor(WorkerState workerState, List<Long> executorId, Map<String,String> initialCredentials)
static void	setTrackId(String trackId)

Methods inherited from class java.lang.Object

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

Constructor Detail

LocalExecutor

public LocalExecutor()

Method Detail

mkExecutor

public static Executor mkExecutor(WorkerState workerState,
                                  List<Long> executorId,
                                  Map<String,String> initialCredentials)
                           throws Exception

Throws:

Exception

setTrackId

public static void setTrackId(String trackId)

clearTrackId

public static void clearTrackId()