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

      • 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: