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

Interface SchemaColumnsProcessor

All Superinterfaces:

Flow.Processor<Map.Entry<Object,Object>,org.apache.ignite3.table.DataStreamerItem<Map.Entry<org.apache.ignite3.table.Tuple,org.apache.ignite3.table.Tuple>>>, Flow.Publisher<org.apache.ignite3.table.DataStreamerItem<Map.Entry<org.apache.ignite3.table.Tuple,org.apache.ignite3.table.Tuple>>>, Flow.Subscriber<Map.Entry<Object,Object>>

All Known Implementing Classes:

AbstractSchemaColumnsProcessor, IgnoreMismatchesSchemaColumnProcessor, SimpleSchemaColumnsProcessor, SkipRecordsSchemaColumnsProcessor

public interface SchemaColumnsProcessor
extends Flow.Processor<Map.Entry<Object,Object>,org.apache.ignite3.table.DataStreamerItem<Map.Entry<org.apache.ignite3.table.Tuple,org.apache.ignite3.table.Tuple>>>

SchemaColumnsProcessor.

Method Summary

Modifier and Type	Method	Description
SchemaColumnProcessorStats	getStats()

Methods inherited from interface java.util.concurrent.Flow.Publisher

subscribe

Methods inherited from interface java.util.concurrent.Flow.Subscriber

onComplete, onError, onNext, onSubscribe

Method Details

getStats

SchemaColumnProcessorStats getStats()