Package org.apache.ignite.cdc
Interface CdcEvent
-
- All Superinterfaces:
Serializable
public interface CdcEvent extends Serializable
Event of single entry change. Instance presents new value of modified entry.- See Also:
CdcMain,CdcConsumer
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description intcacheId()longexpireTime()Objectkey()intpartition()Ignite split dataset into smaller chunks to distribute them across the cluster.booleanprimary()@Nullable Objectvalue()CacheEntryVersionversion()
-
-
-
Method Detail
-
key
Object key()
- Returns:
- Key for the changed entry.
-
value
@Nullable @Nullable Object value()
- Returns:
- Value for the changed entry or
nullin case of entry removal.
-
primary
boolean primary()
- Returns:
Trueif event fired on primary node for partition containing this entry.- See Also:
- Configuring partition backups.
-
partition
int partition()
Ignite split dataset into smaller chunks to distribute them across the cluster.CdcConsumerimplementations can usepartition()to split changes processing in the same way as it done for the cache.- Returns:
- Partition number.
- See Also:
Affinity.partition(Object),Affinity.partitions(), Data partitioning, Affinity collocation
-
version
CacheEntryVersion version()
- Returns:
- Version of the entry.
-
cacheId
int cacheId()
- Returns:
- Cache ID.
- See Also:
GridCacheUtils.cacheId(String),CacheView.cacheId()
-
expireTime
long expireTime()
- Returns:
- Time when entry will be removed from cache. If
0then entry will be cached until removed. - See Also:
IgniteCache.withExpiryPolicy(ExpiryPolicy),CacheConfiguration.setExpiryPolicyFactory(Factory),GridCacheUtils.EXPIRE_TIME_ETERNAL
-
-