com.hazelcast.cache.impl.journal

Class CacheEventJournalReadResultSetImpl<K,V,T>

java.lang.Object

java.util.AbstractCollection<E>

java.util.AbstractList<E>

com.hazelcast.ringbuffer.impl.ReadResultSetImpl<InternalEventJournalCacheEvent,T>

com.hazelcast.cache.impl.journal.CacheEventJournalReadResultSetImpl<K,V,T>

All Implemented Interfaces:

HazelcastInstanceAware, DataSerializable, IdentifiedDataSerializable, Versioned, ReadResultSet<T>, Iterable<T>, Collection<T>, List<T>

public class CacheEventJournalReadResultSetImpl<K,V,T>
extends ReadResultSetImpl<InternalEventJournalCacheEvent,T>

Field Summary

Fields inherited from class com.hazelcast.ringbuffer.impl.ReadResultSetImpl

serializationService

Fields inherited from class java.util.AbstractList

modCount

Fields inherited from interface com.hazelcast.ringbuffer.ReadResultSet

SEQUENCE_UNAVAILABLE

Constructor Summary

Constructors

Constructor and Description
CacheEventJournalReadResultSetImpl()

Method Summary

Modifier and Type	Method and Description
void	addItem(long seq, Object item) Applies the Projection and adds an item to this ReadResultSetImpl if it passes the Predicate and IFunction with which it was constructed.
int	getFactoryId() Returns DataSerializableFactory factory ID for this class.
int	getId() Returns type identifier for this class.

Methods inherited from class com.hazelcast.ringbuffer.impl.ReadResultSetImpl

add, get, getDataItems, getNextSequenceToReadFrom, getSequence, isMaxSizeReached, isMinSizeReached, readCount, readData, setHazelcastInstance, setNextSequenceToReadFrom, setSerializationService, size, writeData

Methods inherited from class java.util.AbstractList

add, addAll, clear, equals, hashCode, indexOf, iterator, lastIndexOf, listIterator, listIterator, remove, removeRange, set, subList

Methods inherited from class java.util.AbstractCollection

addAll, contains, containsAll, isEmpty, remove, removeAll, retainAll, toArray, toArray, toString

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.lang.Iterable

forEach, iterator, spliterator

Methods inherited from interface java.util.List

addAll, contains, containsAll, isEmpty, remove, removeAll, replaceAll, retainAll, sort, spliterator, toArray, toArray

Methods inherited from interface java.util.Collection

parallelStream, removeIf, stream

Constructor Detail

CacheEventJournalReadResultSetImpl

public CacheEventJournalReadResultSetImpl()

Method Detail

addItem

public void addItem(long seq,
                    Object item)

Description copied from class: ReadResultSetImpl

Applies the Projection and adds an item to this ReadResultSetImpl if it passes the Predicate and IFunction with which it was constructed. The item may be in serialized or deserialized format as this method will adapt the parameter if necessary before providing it to the predicate and projection.

If the item is in Data format and there is no filter, predicate or projection, the item is added to the set without any additional serialization or deserialization.

Overrides:

addItem in class ReadResultSetImpl<InternalEventJournalCacheEvent,T>

Parameters:

seq - the sequence ID of the item

item - the item to add to the result set

getFactoryId

public int getFactoryId()

Description copied from interface: IdentifiedDataSerializable

Returns DataSerializableFactory factory ID for this class.

Specified by:

getFactoryId in interface IdentifiedDataSerializable

Overrides:

getFactoryId in class ReadResultSetImpl<InternalEventJournalCacheEvent,T>

Returns:

factory ID

getId

public int getId()

Description copied from interface: IdentifiedDataSerializable

Returns type identifier for this class. It should be unique per DataSerializableFactory.

Specified by:

getId in interface IdentifiedDataSerializable

Overrides:

getId in class ReadResultSetImpl<InternalEventJournalCacheEvent,T>

Returns:

type ID