Interface HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder

  • All Superinterfaces:
    org.apache.camel.builder.EndpointProducerBuilder, org.apache.camel.EndpointProducerResolver
    All Known Subinterfaces:
    HdfsEndpointBuilderFactory.HdfsEndpointBuilder
    Enclosing interface:
    HdfsEndpointBuilderFactory

    public static interface HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder
    extends org.apache.camel.builder.EndpointProducerBuilder
    Builder for endpoint producers for the HDFS component.
    • Method Detail

      • connectOnStartup

        default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder connectOnStartup​(boolean connectOnStartup)
        Whether to connect to the HDFS file system on starting the producer/consumer. If false then the connection is created on-demand. Notice that HDFS may take up till 15 minutes to establish a connection, as it has hardcoded 45 x 20 sec redelivery. By setting this option to false allows your application to startup, and not block for up till 15 minutes. The option is a: boolean type. Default: true Group: common
      • connectOnStartup

        default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder connectOnStartup​(String connectOnStartup)
        Whether to connect to the HDFS file system on starting the producer/consumer. If false then the connection is created on-demand. Notice that HDFS may take up till 15 minutes to establish a connection, as it has hardcoded 45 x 20 sec redelivery. By setting this option to false allows your application to startup, and not block for up till 15 minutes. The option will be converted to a boolean type. Default: true Group: common
      • fileSystemType

        default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder fileSystemType​(String fileSystemType)
        Set to LOCAL to not use HDFS but local java.io.File instead. The option will be converted to a org.apache.camel.component.hdfs.HdfsFileSystemType type. Default: HDFS Group: common
      • fileType

        default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder fileType​(String fileType)
        The file type to use. For more details see Hadoop HDFS documentation about the various files types. The option will be converted to a org.apache.camel.component.hdfs.HdfsFileType type. Default: NORMAL_FILE Group: common
      • lazyStartProducer

        default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder lazyStartProducer​(boolean lazyStartProducer)
        Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing. The option is a: boolean type. Default: false Group: producer
      • lazyStartProducer

        default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder lazyStartProducer​(String lazyStartProducer)
        Whether the producer should be started lazy (on the first message). By starting lazy you can use this to allow CamelContext and routes to startup in situations where a producer may otherwise fail during starting and cause the route to fail being started. By deferring this startup to be lazy then the startup failure can be handled during routing messages via Camel's routing error handlers. Beware that when the first message is processed then creating and starting the producer may take a little time and prolong the total processing time of the processing. The option will be converted to a boolean type. Default: false Group: producer
      • kerberosConfigFileLocation

        default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder kerberosConfigFileLocation​(String kerberosConfigFileLocation)
        The location of the kerb5.conf file (https://web.mit.edu/kerberos/krb5-1.12/doc/admin/conf_files/krb5_conf.html). The option is a: java.lang.String type. Group: security
      • kerberosKeytabLocation

        default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder kerberosKeytabLocation​(String kerberosKeytabLocation)
        The location of the keytab file used to authenticate with the kerberos nodes (contains pairs of kerberos principals and encrypted keys (which are derived from the Kerberos password)). The option is a: java.lang.String type. Group: security