AMReporter(int numExecutors,
int maxThreads,
AtomicReference<InetSocketAddress> localAddress,
QueryFailedHandler queryFailedHandler,
org.apache.hadoop.conf.Configuration conf,
DaemonId daemonId,
SocketFactory socketFactory) |
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) |
LlapProtocolServerImpl(SecretManager secretManager,
int numHandlers,
ContainerRunner containerRunner,
AtomicReference<InetSocketAddress> srvAddress,
AtomicReference<InetSocketAddress> mngAddress,
int srvPort,
int mngPort,
DaemonId daemonId) |