Uses of Class
org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessDescriptor

Packages that use HadoopProcessDescriptor

Package	Description
org.apache.ignite.internal.processors.hadoop.jobtracker
org.apache.ignite.internal.processors.hadoop.taskexecutor.external
org.apache.ignite.internal.processors.hadoop.taskexecutor.external.child
org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication

Uses of HadoopProcessDescriptor in org.apache.ignite.internal.processors.hadoop.jobtracker

Methods in org.apache.ignite.internal.processors.hadoop.jobtracker that return types with arguments of type HadoopProcessDescriptor

Modifier and Type	Method and Description
Map<Integer,HadoopProcessDescriptor>	HadoopJobMetadata.reducersAddresses() Gets reducers addresses for external execution.

Methods in org.apache.ignite.internal.processors.hadoop.jobtracker with parameters of type HadoopProcessDescriptor

Modifier and Type	Method and Description
void	HadoopJobTracker.onExternalMappersInitialized(HadoopJobId jobId, Collection<Integer> reducers, HadoopProcessDescriptor desc) Callback from task executor called when process is ready to received shuffle messages.

Method parameters in org.apache.ignite.internal.processors.hadoop.jobtracker with type arguments of type HadoopProcessDescriptor

Modifier and Type	Method and Description
void	HadoopJobMetadata.reducersAddresses(Map<Integer,HadoopProcessDescriptor> reducersAddrs) Sets reducers addresses for external execution.

Uses of HadoopProcessDescriptor in org.apache.ignite.internal.processors.hadoop.taskexecutor.external

Methods in org.apache.ignite.internal.processors.hadoop.taskexecutor.external that return HadoopProcessDescriptor

Modifier and Type	Method and Description
HadoopProcessDescriptor[]	HadoopJobInfoUpdateRequest.reducersAddresses()

Constructors in org.apache.ignite.internal.processors.hadoop.taskexecutor.external with parameters of type HadoopProcessDescriptor

Constructor and Description
HadoopJobInfoUpdateRequest(HadoopJobId jobId, HadoopJobPhase jobPhase, HadoopProcessDescriptor[] reducersAddrs)

Uses of HadoopProcessDescriptor in org.apache.ignite.internal.processors.hadoop.taskexecutor.external.child

Methods in org.apache.ignite.internal.processors.hadoop.taskexecutor.external.child with parameters of type HadoopProcessDescriptor

Modifier and Type	Method and Description
void	HadoopChildProcessRunner.start(HadoopExternalCommunication comm, HadoopProcessDescriptor nodeDesc, ExecutorService msgExecSvc, IgniteLogger parentLog) Starts child process runner.

Uses of HadoopProcessDescriptor in org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication

Methods in org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication that return HadoopProcessDescriptor

Modifier and Type	Method and Description
HadoopProcessDescriptor	HadoopExternalCommunication.localProcessDescriptor() Gets local process descriptor.
HadoopProcessDescriptor	HadoopExternalCommunication.ProcessHandshakeMessage.processDescriptor()

Methods in org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication with parameters of type HadoopProcessDescriptor

Modifier and Type	Method and Description
protected HadoopCommunicationClient	HadoopExternalCommunication.createNioClient(HadoopProcessDescriptor desc)
protected HadoopCommunicationClient	HadoopExternalCommunication.createShmemClient(HadoopProcessDescriptor desc, int port)
protected HadoopCommunicationClient	HadoopExternalCommunication.createTcpClient(HadoopProcessDescriptor desc) Establish TCP connection to remote hadoop process and returns client.
protected void	HadoopExternalCommunication.notifyListener(HadoopProcessDescriptor desc, HadoopMessage msg)
void	HadoopMessageListener.onConnectionLost(HadoopProcessDescriptor desc) Called when connection to remote process was lost.
void	HadoopMessageListener.onMessageReceived(HadoopProcessDescriptor desc, HadoopMessage msg)
void	HadoopCommunicationClient.sendMessage(HadoopProcessDescriptor desc, HadoopMessage msg)
void	HadoopTcpNioCommunicationClient.sendMessage(HadoopProcessDescriptor desc, HadoopMessage msg)
void	HadoopExternalCommunication.sendMessage(HadoopProcessDescriptor desc, HadoopMessage msg) Sends message to Hadoop process.