org.apache.ignite.internal.processors.hadoop.mapreduce

Class MapReduceClient

java.lang.Object

org.apache.ignite.internal.processors.hadoop.mapreduce.MapReduceClient

public class MapReduceClient
extends Object

Client.

Constructor Summary

Constructors

Constructor and Description
MapReduceClient(String cluster, Collection<String> addrs) Constructor.

Method Summary

Modifier and Type	Method and Description
boolean	acquire() Increments usage count.
GridClient	client() Gets the client.
String	cluster()
boolean	release() Decrements the usages of the client and closes it if this is the last usage.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MapReduceClient

public MapReduceClient(String cluster,
                       Collection<String> addrs)

Constructor.

Parameters:

cluster - Cluster name.

addrs - Addresses.

Method Detail

cluster

public String cluster()

Returns:

Cluster name..

client

public GridClient client()
                  throws IOException

Gets the client.

Returns:

The client.

Throws:

IOException

acquire

public boolean acquire()

Increments usage count.

Returns:

True if succeeded and client can be used.

release

public boolean release()

Decrements the usages of the client and closes it if this is the last usage.

Returns:

True if client can be closed safely by the called.