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 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<Recordfind​(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