org.apache.ignite.internal.client.thin

Class ClientCacheAffinityMapping

java.lang.Object

org.apache.ignite.internal.client.thin.ClientCacheAffinityMapping

public class ClientCacheAffinityMapping
extends Object

Affinity mapping (partition to nodes) for each cache.

Method Summary

Modifier and Type	Method and Description
UUID	affinityNode(IgniteBinary binary, int cacheId, Object key) Calculates affinity node for given cache and key.
Collection<Integer>	cacheIds() Gets cache IDs.
static ClientCacheAffinityMapping	merge(ClientCacheAffinityMapping... mappings) Merge specified mappings into one instance.
static ClientCacheAffinityMapping	readResponse(org.apache.ignite.internal.client.thin.PayloadInputChannel ch) Reads caches affinity response from the input channel and creates ClientCacheAffinityMapping instance from this response.
AffinityTopologyVersion	topologyVersion() Gets topology version.
static void	writeRequest(org.apache.ignite.internal.client.thin.PayloadOutputChannel ch, Collection<Integer> cacheIds) Writes caches affinity request to the output channel.

Methods inherited from class java.lang.Object

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

Method Detail

topologyVersion

public AffinityTopologyVersion topologyVersion()

Gets topology version.

cacheIds

public Collection<Integer> cacheIds()

Gets cache IDs.

affinityNode

public UUID affinityNode(IgniteBinary binary,
                         int cacheId,
                         Object key)

Calculates affinity node for given cache and key.

Parameters:

binary - Binary data processor (needed to extract affinity field from the key).

cacheId - Cache ID.

key - Key.

Returns:

Affinity node id or null if affinity node can't be determined for given cache and key.

merge

public static ClientCacheAffinityMapping merge(ClientCacheAffinityMapping... mappings)

Merge specified mappings into one instance.

writeRequest

public static void writeRequest(org.apache.ignite.internal.client.thin.PayloadOutputChannel ch,
                                Collection<Integer> cacheIds)

Writes caches affinity request to the output channel.

Parameters:

ch - Output channel.

cacheIds - Cache IDs.

readResponse

public static ClientCacheAffinityMapping readResponse(org.apache.ignite.internal.client.thin.PayloadInputChannel ch)

Reads caches affinity response from the input channel and creates ClientCacheAffinityMapping instance from this response.

Parameters:

ch - Input channel.