Package org.apache.ignite.migrationtools.persistence.mappers

Class CacheDataRowProcessor

java.lang.Object

org.apache.ignite.migrationtools.persistence.utils.pubsub.BasicProcessor<org.apache.ignite.internal.processors.cache.persistence.CacheDataRow,Map.Entry<Object,Object>>

org.apache.ignite.migrationtools.persistence.mappers.CacheDataRowProcessor

All Implemented Interfaces:

Flow.Processor<org.apache.ignite.internal.processors.cache.persistence.CacheDataRow,Map.Entry<Object,Object>>, Flow.Publisher<Map.Entry<Object,Object>>, Flow.Subscriber<org.apache.ignite.internal.processors.cache.persistence.CacheDataRow>

public class CacheDataRowProcessor
extends BasicProcessor<org.apache.ignite.internal.processors.cache.persistence.CacheDataRow,Map.Entry<Object,Object>>

Processes CacheDataRow into Java Object entries.

Field Summary

Fields inherited from class org.apache.ignite.migrationtools.persistence.utils.pubsub.BasicProcessor

subscriber, subscription

Constructor Summary

Constructors

Constructor	Description
CacheDataRowProcessor(org.apache.ignite.internal.processors.cache.CacheObjectContext ctx)

Method Summary

Modifier and Type	Method	Description
void	onNext(org.apache.ignite.internal.processors.cache.persistence.CacheDataRow row)

Methods inherited from class org.apache.ignite.migrationtools.persistence.utils.pubsub.BasicProcessor

onComplete, onError, onSubscribe, subscribe

Methods inherited from class java.lang.Object

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

Constructor Details

CacheDataRowProcessor

public CacheDataRowProcessor(org.apache.ignite.internal.processors.cache.CacheObjectContext ctx)

Method Details

onNext

public void onNext(org.apache.ignite.internal.processors.cache.persistence.CacheDataRow row)