com.hazelcast.collection.impl.collection

Class CollectionContainer

java.lang.Object

com.hazelcast.collection.impl.collection.CollectionContainer

All Implemented Interfaces:

DataSerializable

Direct Known Subclasses:

ListContainer, SetContainer

public abstract class CollectionContainer
extends Object
implements DataSerializable

Field Summary

Fields

Modifier and Type	Field and Description
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

Methods

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()
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()
protected abstract Collection<CollectionItem>	getCollection()
abstract CollectionConfig	getConfig()
protected abstract Map<Long,CollectionItem>	getMap()
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)
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

Field Detail

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)

getConfig

public abstract CollectionConfig getConfig()

getCollection

protected abstract Collection<CollectionItem> getCollection()

getMap

protected 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()

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()

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

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