public class LlapDaemon extends org.apache.hadoop.service.CompositeService implements ContainerRunner, LlapDaemonMXBean
Modifier and Type | Field and Description |
---|---|
static String |
HADOOP_METRICS2_PROPERTIES_FILE |
static String |
LLAP_HADOOP_METRICS2_PROPERTIES_FILE |
static String |
LOG4j2_PROPERTIES_FILE |
Constructor and Description |
---|
LlapDaemon(org.apache.hadoop.conf.Configuration daemonConf,
int numExecutors,
long executorMemoryBytes,
boolean ioEnabled,
boolean isDirectCache,
long ioMemoryBytes,
String[] localDirs,
int srvPort,
int mngPort,
int shufflePort,
int webPort,
String appName) |
addIfService, addService, getServices, removeService
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public static final String LOG4j2_PROPERTIES_FILE
public static final String LLAP_HADOOP_METRICS2_PROPERTIES_FILE
public static final String HADOOP_METRICS2_PROPERTIES_FILE
public static long getTotalHeapSize()
public void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.CompositeService
Exception
public void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.CompositeService
Exception
public void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.CompositeService
Exception
public void shutdown()
public LlapDaemonProtocolProtos.SubmitWorkResponseProto submitWork(LlapDaemonProtocolProtos.SubmitWorkRequestProto request) throws IOException
submitWork
in interface ContainerRunner
IOException
public LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto sourceStateUpdated(LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request) throws IOException
sourceStateUpdated
in interface ContainerRunner
IOException
public LlapDaemonProtocolProtos.QueryCompleteResponseProto queryComplete(LlapDaemonProtocolProtos.QueryCompleteRequestProto request) throws IOException
queryComplete
in interface ContainerRunner
IOException
public LlapDaemonProtocolProtos.TerminateFragmentResponseProto terminateFragment(LlapDaemonProtocolProtos.TerminateFragmentRequestProto request) throws IOException
terminateFragment
in interface ContainerRunner
IOException
public long getNumSubmissions()
public InetSocketAddress getListenerAddress()
public int getRpcPort()
LlapDaemonMXBean
getRpcPort
in interface LlapDaemonMXBean
public int getNumExecutors()
LlapDaemonMXBean
getNumExecutors
in interface LlapDaemonMXBean
public int getShufflePort()
LlapDaemonMXBean
getShufflePort
in interface LlapDaemonMXBean
public String getLocalDirs()
LlapDaemonMXBean
getLocalDirs
in interface LlapDaemonMXBean
public Set<String> getExecutorsStatus()
LlapDaemonMXBean
getExecutorsStatus
in interface LlapDaemonMXBean
public long getExecutorMemoryPerInstance()
LlapDaemonMXBean
getExecutorMemoryPerInstance
in interface LlapDaemonMXBean
public long getIoMemoryPerInstance()
LlapDaemonMXBean
getIoMemoryPerInstance
in interface LlapDaemonMXBean
public boolean isIoEnabled()
LlapDaemonMXBean
isIoEnabled
in interface LlapDaemonMXBean
public long getMaxJvmMemory()
LlapDaemonMXBean
getMaxJvmMemory
in interface LlapDaemonMXBean
Copyright © 2016 The Apache Software Foundation. All rights reserved.