org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication

Interface HadoopCommunicationClient

All Known Implementing Classes:

HadoopAbstractCommunicationClient, HadoopTcpNioCommunicationClient

public interface HadoopCommunicationClient

Method Summary

Modifier and Type	Method and Description
boolean	close()
boolean	closed()
void	forceClose() Forces client close.
long	getIdleTime() Gets idle time of this client.
void	release() Releases this client by decreasing reservations.
boolean	reserve()
boolean	reserved()
void	sendMessage(HadoopProcessDescriptor desc, HadoopMessage msg)

Method Detail

close

boolean close()

Returns:

True if client has been closed by this call, false if failed to close client (due to concurrent reservation or concurrent close).

forceClose

void forceClose()

Forces client close.

closed

boolean closed()

Returns:

True if client is closed;

reserve

boolean reserve()

Returns:

True if client was reserved, false otherwise.

release

void release()

Releases this client by decreasing reservations.

reserved

boolean reserved()

Returns:

True if client was reserved.

getIdleTime

long getIdleTime()

Gets idle time of this client.

Returns:

Idle time of this client.

sendMessage

void sendMessage(HadoopProcessDescriptor desc,
                 HadoopMessage msg)
          throws IgniteCheckedException

Parameters:

desc - Process descriptor.

msg - Message to send.

Throws:

IgniteCheckedException - If failed.