com.hazelcast.collection.impl.collection

Class CollectionContainer

java.lang.Object

com.hazelcast.collection.impl.collection.CollectionContainer

All Implemented Interfaces:

DataSerializable, IdentifiedDataSerializable

Direct Known Subclasses:

ListContainer, SetContainer

public abstract class CollectionContainer
extends Object
implements IdentifiedDataSerializable

Field Summary

Fields

Modifier and Type	Field and Description
static int	ID_PROMOTION_OFFSET
static int	INVALID_ITEM_ID
protected Map<Long,CollectionItem>	itemMap
protected ILogger	logger
protected String	name
protected NodeEngine	nodeEngine
protected Map<Long,TxCollectionItem>	txMap

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CollectionContainer()
protected	CollectionContainer(String name, NodeEngine nodeEngine)

Method Summary

Modifier and Type	Method and Description
long	add(Data value)
Map<Long,Data>	addAll(List<Data> valueList)
void	addAllBackup(Map<Long,Data> valueMap)
void	addBackup(long itemId, Data value)
Map<Long,Data>	clear(boolean returnValues)
void	clearBackup(Set<Long> itemIdSet)
void	commitAdd(long itemId, Data value)
void	commitAddBackup(long itemId, Data value)
CollectionItem	commitRemove(long itemId)
void	commitRemoveBackup(long itemId)
Map<Long,Data>	compareAndRemove(boolean retain, Set<Data> valueSet)
boolean	contains(Set<Data> valueSet)
void	destroy()
void	ensureReserve(long itemId)
List<Data>	getAll()
abstract Collection<CollectionItem>	getCollection()
abstract CollectionConfig	getConfig()
long	getCurrentId()
int	getFactoryId() Returns DataSerializableFactory factory ID for this class.
abstract Map<Long,CollectionItem>	getMap()
String	getName()
boolean	hasEnoughCapacity(int delta)
void	init(NodeEngine nodeEngine)
long	nextId()
protected abstract void	onDestroy()
void	readData(ObjectDataInput in) Reads fields from the input stream
CollectionItem	remove(Data value)
void	removeBackup(long itemId)
Long	reserveAdd(String transactionId, Data value)
void	reserveAddBackup(long itemId, String transactionId)
CollectionItem	reserveRemove(long reservedItemId, Data value, String transactionId)
void	reserveRemoveBackup(long itemId, String transactionId)
void	rollbackAdd(long itemId)
void	rollbackAddBackup(long itemId)
void	rollbackRemove(long itemId)
void	rollbackRemoveBackup(long itemId)
void	rollbackTransaction(String transactionId)
protected void	setId(long itemId)
int	size()
void	writeData(ObjectDataOutput out) Writes object fields to output stream

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.hazelcast.nio.serialization.IdentifiedDataSerializable

getId

Field Detail

INVALID_ITEM_ID

public static final int INVALID_ITEM_ID

See Also:

Constant Field Values

ID_PROMOTION_OFFSET

public static final int ID_PROMOTION_OFFSET

See Also:

Constant Field Values

txMap

protected final Map<Long,TxCollectionItem> txMap

name

protected String name

nodeEngine

protected NodeEngine nodeEngine

logger

protected ILogger logger

itemMap

protected Map<Long,CollectionItem> itemMap

Constructor Detail

CollectionContainer

protected CollectionContainer()

CollectionContainer

protected CollectionContainer(String name,
                              NodeEngine nodeEngine)

Method Detail

init

public void init(NodeEngine nodeEngine)

getName

public String getName()

getConfig

public abstract CollectionConfig getConfig()

getCollection

public abstract Collection<CollectionItem> getCollection()

getMap

public abstract Map<Long,CollectionItem> getMap()

add

public long add(Data value)

addBackup

public void addBackup(long itemId,
                      Data value)

remove

public CollectionItem remove(Data value)

removeBackup

public void removeBackup(long itemId)

size

public int size()

clear

public Map<Long,Data> clear(boolean returnValues)

clearBackup

public void clearBackup(Set<Long> itemIdSet)

contains

public boolean contains(Set<Data> valueSet)

addAll

public Map<Long,Data> addAll(List<Data> valueList)

addAllBackup

public void addAllBackup(Map<Long,Data> valueMap)

compareAndRemove

public Map<Long,Data> compareAndRemove(boolean retain,
                                       Set<Data> valueSet)

getAll

public List<Data> getAll()

hasEnoughCapacity

public boolean hasEnoughCapacity(int delta)

reserveAdd

public Long reserveAdd(String transactionId,
                       Data value)

reserveAddBackup

public void reserveAddBackup(long itemId,
                             String transactionId)

reserveRemove

public CollectionItem reserveRemove(long reservedItemId,
                                    Data value,
                                    String transactionId)

reserveRemoveBackup

public void reserveRemoveBackup(long itemId,
                                String transactionId)

ensureReserve

public void ensureReserve(long itemId)

rollbackAdd

public void rollbackAdd(long itemId)

rollbackAddBackup

public void rollbackAddBackup(long itemId)

rollbackRemove

public void rollbackRemove(long itemId)

rollbackRemoveBackup

public void rollbackRemoveBackup(long itemId)

commitAdd

public void commitAdd(long itemId,
                      Data value)

commitAddBackup

public void commitAddBackup(long itemId,
                            Data value)

commitRemove

public CollectionItem commitRemove(long itemId)

commitRemoveBackup

public void commitRemoveBackup(long itemId)

rollbackTransaction

public void rollbackTransaction(String transactionId)

nextId

public long nextId()

getCurrentId

public long getCurrentId()

setId

protected void setId(long itemId)

destroy

public void destroy()

onDestroy

protected abstract void onDestroy()

writeData

public void writeData(ObjectDataOutput out)
               throws IOException

Description copied from interface: DataSerializable

Writes object fields to output stream

Specified by:

writeData in interface DataSerializable

Parameters:

out - output

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the output stream has been closed.

readData

public void readData(ObjectDataInput in)
              throws IOException

Description copied from interface: DataSerializable

Reads fields from the input stream

Specified by:

readData in interface DataSerializable

Parameters:

in - input

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the input stream has been closed.

getFactoryId

public int getFactoryId()

Description copied from interface: IdentifiedDataSerializable

Returns DataSerializableFactory factory ID for this class.

Specified by:

getFactoryId in interface IdentifiedDataSerializable

Returns:

factory ID