Class CacheEntrySerializablePredicate
- java.lang.Object
-
- org.apache.ignite.internal.processors.cache.CacheEntrySerializablePredicate
-
- All Implemented Interfaces:
Serializable,CacheEntryPredicate,IgnitePredicate<GridCacheEntryEx>,Message
public class CacheEntrySerializablePredicate extends Object implements CacheEntryPredicate
- See Also:
- Serialized Form
-
-
Field Summary
-
Fields inherited from interface org.apache.ignite.plugin.extensions.communication.Message
DIRECT_TYPE_SIZE
-
-
Constructor Summary
Constructors Constructor Description CacheEntrySerializablePredicate()Required byMessage.CacheEntrySerializablePredicate(CacheEntryPredicate p)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanapply(GridCacheEntryEx e)Predicate body.shortdirectType()Gets message type.voidentryLocked(boolean locked)bytefieldsCount()Gets fields count.voidfinishUnmarshal(GridCacheContext ctx, ClassLoader ldr)voidonAckReceived()Method called when ack message received.CacheEntryPredicatepredicate()voidprepareMarshal(GridCacheContext ctx)booleanreadFrom(ByteBuffer buf, MessageReader reader)Reads this message from provided byte buffer.booleanwriteTo(ByteBuffer buf, MessageWriter writer)Writes this message to provided byte buffer.
-
-
-
Constructor Detail
-
CacheEntrySerializablePredicate
public CacheEntrySerializablePredicate()
Required byMessage.
-
CacheEntrySerializablePredicate
public CacheEntrySerializablePredicate(CacheEntryPredicate p)
- Parameters:
p- Serializable predicate.
-
-
Method Detail
-
predicate
public CacheEntryPredicate predicate()
- Returns:
- Predicate.
-
onAckReceived
public void onAckReceived()
Method called when ack message received.- Specified by:
onAckReceivedin interfaceMessage
-
entryLocked
public void entryLocked(boolean locked)
- Specified by:
entryLockedin interfaceCacheEntryPredicate- Parameters:
locked- Entry locked
-
finishUnmarshal
public void finishUnmarshal(GridCacheContext ctx, ClassLoader ldr) throws IgniteCheckedException
- Specified by:
finishUnmarshalin interfaceCacheEntryPredicate- Parameters:
ctx- Context.ldr- Class loader.- Throws:
IgniteCheckedException- If failed.
-
prepareMarshal
public void prepareMarshal(GridCacheContext ctx) throws IgniteCheckedException
- Specified by:
prepareMarshalin interfaceCacheEntryPredicate- Parameters:
ctx- Context.- Throws:
IgniteCheckedException- If failed.
-
apply
public boolean apply(GridCacheEntryEx e)
Predicate body.- Specified by:
applyin interfaceIgnitePredicate<GridCacheEntryEx>- Parameters:
e- Predicate parameter.- Returns:
- Return value.
-
writeTo
public boolean writeTo(ByteBuffer buf, MessageWriter writer)
Writes this message to provided byte buffer.
-
readFrom
public boolean readFrom(ByteBuffer buf, MessageReader reader)
Reads this message from provided byte buffer.
-
directType
public short directType()
Gets message type.- Specified by:
directTypein interfaceMessage- Returns:
- Message type.
-
fieldsCount
public byte fieldsCount()
Gets fields count.- Specified by:
fieldsCountin interfaceMessage- Returns:
- Fields count.
-
-