public class ContainerRunnerImpl extends org.apache.hadoop.service.CompositeService implements ContainerRunner, FragmentCompletionHandler, QueryFailedHandler
Modifier and Type | Field and Description |
---|---|
static String |
THREAD_NAME_FORMAT_PREFIX |
Constructor and Description |
---|
ContainerRunnerImpl(org.apache.hadoop.conf.Configuration conf,
int numExecutors,
int waitQueueSize,
boolean enablePreemption,
String[] localDirsBase,
AtomicReference<Integer> localShufflePort,
AtomicReference<InetSocketAddress> localAddress,
long totalMemoryAvailableBytes,
LlapDaemonExecutorMetrics metrics,
AMReporter amReporter,
ClassLoader classLoader,
DaemonId daemonId) |
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 THREAD_NAME_FORMAT_PREFIX
public ContainerRunnerImpl(org.apache.hadoop.conf.Configuration conf, int numExecutors, int waitQueueSize, boolean enablePreemption, String[] localDirsBase, AtomicReference<Integer> localShufflePort, AtomicReference<InetSocketAddress> localAddress, long totalMemoryAvailableBytes, LlapDaemonExecutorMetrics metrics, AMReporter amReporter, ClassLoader classLoader, DaemonId daemonId)
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
protected void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.CompositeService
Exception
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 static String stringifySubmitRequest(LlapDaemonProtocolProtos.SubmitWorkRequestProto request, LlapDaemonProtocolProtos.SignableVertexSpec vertex)
public void fragmentComplete(QueryFragmentInfo fragmentInfo)
fragmentComplete
in interface FragmentCompletionHandler
public void queryFailed(QueryIdentifier queryIdentifier)
queryFailed
in interface QueryFailedHandler
Copyright © 2016 The Apache Software Foundation. All rights reserved.