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) |
TaskExecutorService(int numExecutors,
int waitQueueSize,
String waitQueueComparatorClassName,
boolean enablePreemption,
ClassLoader classLoader,
LlapDaemonExecutorMetrics metrics,
org.apache.hadoop.yarn.util.Clock clock) |
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) |