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
All Methods Instance Methods Abstract Methods 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 idbuilder
- component instantiate builderconverter
- 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
-
-