Package com.gigaspaces.internal.cluster

Class ClusterTopology

java.lang.Object

com.gigaspaces.internal.cluster.ClusterTopology

All Implemented Interfaces:

SmartExternalizable, Externalizable, Serializable

public class ClusterTopology
extends Object
implements SmartExternalizable

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
static final int	CHUNKS_COUNT

Constructor Summary

Constructors

Constructor	Description
ClusterTopology()
ClusterTopology(int numOfPartitions)	used from unit tests

Method Summary

Modifier and Type	Method	Description
ClusterTopology	copy()
boolean	equivalent(ClusterTopology other)
int	getGeneration()
int	getNumberOfBackups()
int	getNumberOfInstances()
Set<Integer>	getPartitionChunks(int partition)
int	getPartitionId(int routingValue)
int	getPartitionId(long routingValue)
Map<Integer,Set<Integer>>	getPartitionsToChunksMap()
String	getSchema()
void	readExternal(ObjectInput in)
ClusterTopology	setGeneration(int generation)
ClusterTopology	setNumOfBackups(int numOfBackups)
ClusterTopology	setNumOfInstances(int numOfInstances)
ClusterTopology	setPartitionsToChunksMap(Map<Integer,Set<Integer>> partitionsToChunksMap)
ClusterTopology	setSchema(String schema)
String	toString()
void	writeExternal(ObjectOutput out)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.gigaspaces.serialization.SmartExternalizable

enabledSmartExternalizableWithReference

Field Details

CHUNKS_COUNT

public static final int CHUNKS_COUNT

Constructor Details

ClusterTopology

public ClusterTopology()

ClusterTopology

public ClusterTopology(int numOfPartitions)

used from unit tests

Parameters:

numOfPartitions -

Method Details

setGeneration

public ClusterTopology setGeneration(int generation)

setSchema

public ClusterTopology setSchema(String schema)

setNumOfInstances

public ClusterTopology setNumOfInstances(int numOfInstances)

setNumOfBackups

public ClusterTopology setNumOfBackups(int numOfBackups)

setPartitionsToChunksMap

public ClusterTopology setPartitionsToChunksMap(Map<Integer,Set<Integer>> partitionsToChunksMap)

getGeneration

public int getGeneration()

getNumberOfInstances

public int getNumberOfInstances()

getNumberOfBackups

public int getNumberOfBackups()

getSchema

public String getSchema()

getPartitionId

public int getPartitionId(int routingValue)

getPartitionId

public int getPartitionId(long routingValue)

toString

public String toString()

Overrides:

toString in class Object

getPartitionsToChunksMap

public Map<Integer,Set<Integer>> getPartitionsToChunksMap()

getPartitionChunks

public Set<Integer> getPartitionChunks(int partition)

writeExternal

public void writeExternal(ObjectOutput out)
                   throws IOException

Specified by:

writeExternal in interface Externalizable

Throws:

IOException

readExternal

public void readExternal(ObjectInput in)
                  throws IOException,
ClassNotFoundException

Specified by:

readExternal in interface Externalizable

Throws:

IOException

ClassNotFoundException

copy

public ClusterTopology copy()

equivalent

public boolean equivalent(ClusterTopology other)