public class LlapDaemon extends org.apache.hadoop.service.CompositeService implements ContainerRunner, LlapDaemonMXBean
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 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 LlapDaemonProtocolProtos.UpdateFragmentResponseProto updateFragment(LlapDaemonProtocolProtos.UpdateFragmentRequestProto request) throws IOException
updateFragment
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 int getNumActive()
LlapDaemonMXBean
getNumActive
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 © 2022 The Apache Software Foundation. All rights reserved.