Package org.apache.ignite.migrationtools.persistence

Interface Ignite2PersistentCacheTools.ColumnsProcessorFactory

Enclosing class:

Ignite2PersistentCacheTools

public static interface Ignite2PersistentCacheTools.ColumnsProcessorFactory

ColumnsProcessorFactory.

Method Summary

Modifier and Type	Method	Description
Flow.Publisher<org.apache.ignite3.table.DataStreamerItem<Map.Entry<org.apache.ignite3.table.Tuple,org.apache.ignite3.table.Tuple>>>	createSubscribed(Flow.Publisher<Map.Entry<Object,Object>> cacheTuplePublisher, int partitionId, org.apache.ignite3.internal.client.table.ClientSchema clientSchema, Map<String,String> columnsToFieldsMappings, TypeConverterFactory typeConverters)

Method Details

createSubscribed

@Nullable
Flow.Publisher<org.apache.ignite3.table.DataStreamerItem<Map.Entry<org.apache.ignite3.table.Tuple,org.apache.ignite3.table.Tuple>>> createSubscribed(Flow.Publisher<Map.Entry<Object,Object>> cacheTuplePublisher,
 int partitionId,
 org.apache.ignite3.internal.client.table.ClientSchema clientSchema,
 Map<String,String> columnsToFieldsMappings,
 TypeConverterFactory typeConverters)