Package org.apache.ignite.internal.cdc

Class CdcEventImpl

java.lang.Object

org.apache.ignite.internal.cdc.CdcEventImpl

All Implemented Interfaces:

Serializable, CdcEvent

public class CdcEventImpl
extends Object
implements CdcEvent

Event of single entry change. Instance presents new value of modified entry.

See Also:

CdcMain, CdcConsumer, Serialized Form

Constructor Summary

Constructors

Constructor	Description
CdcEventImpl(Object key, Object val, boolean primary, int part, CacheEntryVersion ord, int cacheId, long expireTime)

Method Summary

Modifier and Type	Method	Description
int	cacheId()
long	expireTime()
Object	key()
int	partition()	Ignite split dataset into smaller chunks to distribute them across the cluster.
boolean	primary()
String	toString()
Object	value()
CacheEntryVersion	version()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

CdcEventImpl

public CdcEventImpl(Object key,
                    Object val,
                    boolean primary,
                    int part,
                    CacheEntryVersion ord,
                    int cacheId,
                    long expireTime)

Parameters:

key - Key.

val - Value.

primary - True if changes made on primary node.

part - Partition.

ord - Order of the entry change.

cacheId - Cache id.

expireTime - Expire time.

Method Detail

key

public Object key()

Specified by:

key in interface CdcEvent

Returns:

Key for the changed entry.

value

public Object value()

Specified by:

value in interface CdcEvent

Returns:

Value for the changed entry or null in case of entry removal.

primary

public boolean primary()

Specified by:

primary in interface CdcEvent

Returns:

True if event fired on primary node for partition containing this entry.

See Also:

Configuring partition backups.

partition

public int partition()

Ignite split dataset into smaller chunks to distribute them across the cluster. CdcConsumer implementations can use CdcEvent.partition() to split changes processing in the same way as it done for the cache.

Specified by:

partition in interface CdcEvent

Returns:

Partition number.

See Also:

Affinity.partition(Object), Affinity.partitions(), Data partitioning, Affinity collocation

version

public CacheEntryVersion version()

Specified by:

version in interface CdcEvent

Returns:

Version of the entry.

cacheId

public int cacheId()

Specified by:

cacheId in interface CdcEvent

Returns:

Cache ID.

See Also:

GridCacheUtils.cacheId(String), CacheView.cacheId()

expireTime

public long expireTime()

Specified by:

expireTime in interface CdcEvent

Returns:

Time when entry will be removed from cache. If 0 then entry will be cached until removed.

See Also:

IgniteCache.withExpiryPolicy(ExpiryPolicy), CacheConfiguration.setExpiryPolicyFactory(Factory), GridCacheUtils.EXPIRE_TIME_ETERNAL

toString

public String toString()

Overrides:

toString in class Object