Class CacheEntryPredicateContainsValue
- java.lang.Object
-
- org.apache.ignite.internal.processors.cache.CacheEntryPredicateAdapter
-
- org.apache.ignite.internal.processors.cache.CacheEntryPredicateContainsValue
-
- All Implemented Interfaces:
Serializable,CacheEntryPredicate,IgnitePredicate<GridCacheEntryEx>,Message
public class CacheEntryPredicateContainsValue extends CacheEntryPredicateAdapter
- See Also:
- Serialized Form
-
-
Field Summary
-
Fields inherited from class org.apache.ignite.internal.processors.cache.CacheEntryPredicateAdapter
locked
-
Fields inherited from interface org.apache.ignite.plugin.extensions.communication.Message
DIRECT_TYPE_SIZE
-
-
Constructor Summary
Constructors Constructor Description CacheEntryPredicateContainsValue()Required byMessage.CacheEntryPredicateContainsValue(CacheObject val)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanapply(GridCacheEntryEx e)Predicate body.shortdirectType()Gets message type.bytefieldsCount()Gets fields count.voidfinishUnmarshal(GridCacheContext ctx, ClassLoader ldr)voidprepareMarshal(GridCacheContext ctx)booleanreadFrom(ByteBuffer buf, MessageReader reader)Reads this message from provided byte buffer.StringtoString()booleanwriteTo(ByteBuffer buf, MessageWriter writer)Writes this message to provided byte buffer.-
Methods inherited from class org.apache.ignite.internal.processors.cache.CacheEntryPredicateAdapter
entryLocked, onAckReceived, peekVisibleValue
-
-
-
-
Constructor Detail
-
CacheEntryPredicateContainsValue
public CacheEntryPredicateContainsValue()
Required byMessage.
-
CacheEntryPredicateContainsValue
public CacheEntryPredicateContainsValue(CacheObject val)
- Parameters:
val- Value to compare with.
-
-
Method Detail
-
apply
public boolean apply(GridCacheEntryEx e)
Predicate body.- Parameters:
e- Predicate parameter.- Returns:
- Return value.
-
finishUnmarshal
public void finishUnmarshal(GridCacheContext ctx, ClassLoader ldr) throws IgniteCheckedException
- Specified by:
finishUnmarshalin interfaceCacheEntryPredicate- Overrides:
finishUnmarshalin classCacheEntryPredicateAdapter- Parameters:
ctx- Context.ldr- Class loader.- Throws:
IgniteCheckedException- If failed.
-
prepareMarshal
public void prepareMarshal(GridCacheContext ctx) throws IgniteCheckedException
- Specified by:
prepareMarshalin interfaceCacheEntryPredicate- Overrides:
prepareMarshalin classCacheEntryPredicateAdapter- Parameters:
ctx- Context.- Throws:
IgniteCheckedException- If failed.
-
writeTo
public boolean writeTo(ByteBuffer buf, MessageWriter writer)
Writes this message to provided byte buffer.- Specified by:
writeToin interfaceMessage- Overrides:
writeToin classCacheEntryPredicateAdapter- Parameters:
buf- Byte buffer.writer- Writer.- Returns:
- Whether message was fully written.
-
readFrom
public boolean readFrom(ByteBuffer buf, MessageReader reader)
Reads this message from provided byte buffer.- Specified by:
readFromin interfaceMessage- Overrides:
readFromin classCacheEntryPredicateAdapter- Parameters:
buf- Byte buffer.reader- Reader.- Returns:
- Whether message was fully read.
-
directType
public short directType()
Gets message type.- Specified by:
directTypein interfaceMessage- Overrides:
directTypein classCacheEntryPredicateAdapter- Returns:
- Message type.
-
fieldsCount
public byte fieldsCount()
Gets fields count.- Specified by:
fieldsCountin interfaceMessage- Overrides:
fieldsCountin classCacheEntryPredicateAdapter- Returns:
- Fields count.
-
-