Package org.talend.sdk.component.api.service.source

Interface ProducerFinder

All Superinterfaces:

Serializable

public interface ProducerFinder
extends Serializable

This service aims to retrieve a record iterator based on a configured dataset of a connector. It's expected that Producer has no extra-configuration on dataset and is a finite producer (not a queue for example).

Method Summary

Modifier and Type	Method	Description
Iterator<Record>	find(String familyName, String inputName, int version, Map<String,String> configuration)	Retrieve iterator.
ProducerFinder	init(String plugin, Object builder, Function<Object,Record> converter)	Initialize the ProducerFinder

Method Detail

init

ProducerFinder init(String plugin,
                    Object builder,
                    Function<Object,Record> converter)

Initialize the ProducerFinder

Parameters:

plugin - plugin id

builder - component instantiate builder

converter - function to convert to Record

Returns:

initialized ProducerFinder

find

Iterator<Record> find(String familyName,
                      String inputName,
                      int version,
                      Map<String,String> configuration)

Retrieve iterator.

Parameters:

familyName - : connector family name.

inputName - : dataset name.

version - : version of configuration.

configuration - : dataset configuration.

Returns:

the Record iterator