T
- the return type of the projection. It is equal to an implementation of
if the projection is null
or it is the identity projectionpublic class MapEventJournalReadOperation<K,V,T> extends EventJournalReadOperation<T,InternalEventJournalMapEvent>
null
in which case all elements are returned
and no projection is applied.Modifier and Type | Field and Description |
---|---|
protected Predicate<? super EventJournalMapEvent<K,V>> |
predicate |
protected Function<? super EventJournalMapEvent<K,V>,? extends T> |
projection |
maxSize, minSize, name, namespace, resultSet, sequence, startSequence
GENERIC_PARTITION_ID
Constructor and Description |
---|
MapEventJournalReadOperation() |
MapEventJournalReadOperation(String mapName,
long startSequence,
int minSize,
int maxSize,
Predicate<? super EventJournalMapEvent<K,V>> predicate,
Function<? super EventJournalMapEvent<K,V>,? extends T> projection) |
Modifier and Type | Method and Description |
---|---|
protected ReadResultSetImpl<InternalEventJournalMapEvent,T> |
createResultSet() |
int |
getFactoryId()
Returns DataSerializableFactory factory ID for this class.
|
int |
getId()
Returns type identifier for this class.
|
protected EventJournal<InternalEventJournalMapEvent> |
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 EventJournalMapEvent<K,V>> predicate
protected Function<? super EventJournalMapEvent<K,V>,? extends T> projection
public MapEventJournalReadOperation()
public MapEventJournalReadOperation(String mapName, long startSequence, int minSize, int maxSize, Predicate<? super EventJournalMapEvent<K,V>> predicate, Function<? super EventJournalMapEvent<K,V>,? extends T> projection)
protected ReadResultSetImpl<InternalEventJournalMapEvent,T> createResultSet()
createResultSet
in class EventJournalReadOperation<T,InternalEventJournalMapEvent>
protected EventJournal<InternalEventJournalMapEvent> getJournal()
getJournal
in class EventJournalReadOperation<T,InternalEventJournalMapEvent>
public int getFactoryId()
IdentifiedDataSerializable
public int getId()
IdentifiedDataSerializable
public String getServiceName()
getServiceName
in class EventJournalReadOperation<T,InternalEventJournalMapEvent>
protected void writeInternal(ObjectDataOutput out) throws IOException
writeInternal
in class EventJournalReadOperation<T,InternalEventJournalMapEvent>
IOException
protected void readInternal(ObjectDataInput in) throws IOException
readInternal
in class EventJournalReadOperation<T,InternalEventJournalMapEvent>
IOException
Copyright © 2019 Hazelcast, Inc.. All Rights Reserved.