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,
UgiFactory fsUgiFactory,
SocketFactory socketFactory) |
TaskRunnerCallable(LlapDaemonProtocolProtos.SubmitWorkRequestProto request,
QueryFragmentInfo fragmentInfo,
org.apache.hadoop.conf.Configuration conf,
org.apache.tez.runtime.api.ExecutionContext executionContext,
Map<String,String> envMap,
org.apache.hadoop.security.Credentials credentials,
long memoryAvailable,
AMReporter amReporter,
TaskRunnerCallable.ConfParams confParams,
LlapDaemonExecutorMetrics metrics,
KilledTaskHandler killedTaskHandler,
FragmentCompletionHandler fragmentCompleteHandler,
org.apache.tez.hadoop.shim.HadoopShim tezHadoopShim,
org.apache.tez.dag.records.TezTaskAttemptID attemptId,
LlapDaemonProtocolProtos.SignableVertexSpec vertex,
org.apache.tez.runtime.api.impl.TezEvent initialEvent,
org.apache.hadoop.security.UserGroupInformation fsTaskUgi,
SchedulerFragmentCompletingListener completionListener,
SocketFactory socketFactory,
boolean isGuaranteed,
WmFragmentCounters wmCounters) |