Class CacheEntryPredicateAdapter
- java.lang.Object
-
- org.apache.ignite.internal.processors.cache.CacheEntryPredicateAdapter
-
- All Implemented Interfaces:
Serializable,CacheEntryPredicate,IgnitePredicate<GridCacheEntryEx>,Message
- Direct Known Subclasses:
CacheEntryPredicateContainsValue,CacheEntryPredicateHasValue,CacheEntryPredicateNoValue
public abstract class CacheEntryPredicateAdapter extends Object implements CacheEntryPredicate
- See Also:
- Serialized Form
-
-
Field Summary
Fields Modifier and Type Field Description protected booleanlocked-
Fields inherited from interface org.apache.ignite.plugin.extensions.communication.Message
DIRECT_TYPE_SIZE
-
-
Constructor Summary
Constructors Constructor Description CacheEntryPredicateAdapter()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description shortdirectType()Gets message type.voidentryLocked(boolean locked)bytefieldsCount()Gets fields count.voidfinishUnmarshal(GridCacheContext ctx, ClassLoader ldr)voidonAckReceived()Method called when ack message received.protected @Nullable CacheObjectpeekVisibleValue(GridCacheEntryEx entry)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.-
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
-
Methods inherited from interface org.apache.ignite.lang.IgnitePredicate
apply
-
-
-
-
Method Detail
-
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.
-
entryLocked
public void entryLocked(boolean locked)
- Specified by:
entryLockedin interfaceCacheEntryPredicate- Parameters:
locked- Entry locked
-
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.
-
readFrom
public boolean readFrom(ByteBuffer buf, MessageReader reader)
Reads this message from provided byte buffer.
-
writeTo
public boolean writeTo(ByteBuffer buf, MessageWriter writer)
Writes this message to provided byte buffer.
-
peekVisibleValue
@Nullable protected @Nullable CacheObject peekVisibleValue(GridCacheEntryEx entry)
- Parameters:
entry- Entry.- Returns:
- Value.
-
onAckReceived
public void onAckReceived()
Method called when ack message received.- Specified by:
onAckReceivedin interfaceMessage
-
-