T
- the return type of the projection. It is equal to the journal event type
if the projection is null
or it is the identity projectionpublic class CacheEventJournalReadOperation<K,V,T> extends EventJournalReadOperation<T,InternalEventJournalCacheEvent>
null
in which case all elements are returned
and no projection is applied.Modifier and Type | Field and Description |
---|---|
protected Predicate<? super EventJournalCacheEvent<K,V>> |
predicate |
protected Projection<? super EventJournalCacheEvent<K,V>,? extends T> |
projection |
maxSize, minSize, name, namespace, resultSet, sequence, startSequence
GENERIC_PARTITION_ID
Constructor and Description |
---|
CacheEventJournalReadOperation() |
CacheEventJournalReadOperation(String cacheName,
long startSequence,
int minSize,
int maxSize,
Predicate<? super EventJournalCacheEvent<K,V>> predicate,
Projection<? super EventJournalCacheEvent<K,V>,? extends T> projection) |
Modifier and Type | Method and Description |
---|---|
protected ReadResultSetImpl<InternalEventJournalCacheEvent,T> |
createResultSet() |
int |
getFactoryId()
Returns DataSerializableFactory factory ID for this class.
|
int |
getId()
Returns type identifier for this class.
|
protected EventJournal<InternalEventJournalCacheEvent> |
getJournal() |
String |
getServiceName() |
protected void |
readInternal(ObjectDataInput in) |
protected void |
writeInternal(ObjectDataOutput out) |
beforeRun, getResponse, getWaitKey, onWaitExpire, run, shouldWait
afterRun, call, executedLocally, getCallerAddress, getCallerUuid, getCallId, getCallTimeout, getConnection, getInvocationTime, getLogger, getNodeEngine, getOperationResponseHandler, getPartitionId, getReplicaIndex, getService, getWaitTimeout, isUrgent, logError, onExecutionFailure, onInvocationException, onSetCallId, readData, requiresExplicitServiceName, returnsResponse, sendResponse, setCallerUuid, setNodeEngine, setOperationResponseHandler, setPartitionId, setReplicaIndex, setService, setServiceName, setValidateTarget, setWaitTimeout, toString, toString, validatesTarget, writeData
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
readData, writeData
getPartitionId
getWaitTimeout
protected Predicate<? super EventJournalCacheEvent<K,V>> predicate
protected Projection<? super EventJournalCacheEvent<K,V>,? extends T> projection
public CacheEventJournalReadOperation()
public CacheEventJournalReadOperation(String cacheName, long startSequence, int minSize, int maxSize, Predicate<? super EventJournalCacheEvent<K,V>> predicate, Projection<? super EventJournalCacheEvent<K,V>,? extends T> projection)
protected EventJournal<InternalEventJournalCacheEvent> getJournal()
getJournal
in class EventJournalReadOperation<T,InternalEventJournalCacheEvent>
public int getFactoryId()
IdentifiedDataSerializable
public int getId()
IdentifiedDataSerializable
public String getServiceName()
getServiceName
in class EventJournalReadOperation<T,InternalEventJournalCacheEvent>
protected void writeInternal(ObjectDataOutput out) throws IOException
writeInternal
in class EventJournalReadOperation<T,InternalEventJournalCacheEvent>
IOException
protected void readInternal(ObjectDataInput in) throws IOException
readInternal
in class EventJournalReadOperation<T,InternalEventJournalCacheEvent>
IOException
protected ReadResultSetImpl<InternalEventJournalCacheEvent,T> createResultSet()
createResultSet
in class EventJournalReadOperation<T,InternalEventJournalCacheEvent>
Copyright © 2018 Hazelcast, Inc.. All Rights Reserved.