default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.backoffErrorThreshold(int backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.backoffErrorThreshold(String backoffErrorThreshold) |
The number of subsequent error polls (failed due some error) that
should happen before the backoffMultipler should kick-in.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.backoffIdleThreshold(int backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.backoffIdleThreshold(String backoffIdleThreshold) |
The number of subsequent idle polls that should happen before the
backoffMultipler should kick-in.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.backoffMultiplier(int backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.backoffMultiplier(String backoffMultiplier) |
To let the scheduled polling consumer backoff if there has been a
number of subsequent idles/errors in a row.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointConsumerBuilder.basic() |
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.bridgeErrorHandler(boolean bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.bridgeErrorHandler(String bridgeErrorHandler) |
Allows for bridging the consumer to the Camel routing Error Handler,
which mean any exceptions occurred while the consumer is trying to
pickup incoming messages, or the likes, will now be processed as a
message and handled by the routing Error Handler.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.connectOnStartup(boolean connectOnStartup) |
Whether to connect to the HDFS file system on starting the
producer/consumer.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.connectOnStartup(String connectOnStartup) |
Whether to connect to the HDFS file system on starting the
producer/consumer.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.delay(long delay) |
Milliseconds before the next poll.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.delay(String delay) |
Milliseconds before the next poll.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.fileSystemType(String fileSystemType) |
Set to LOCAL to not use HDFS but local java.io.File instead.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.fileSystemType(HdfsEndpointBuilderFactory.HdfsFileSystemType fileSystemType) |
Set to LOCAL to not use HDFS but local java.io.File instead.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.fileType(String fileType) |
The file type to use.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.fileType(HdfsEndpointBuilderFactory.HdfsFileType fileType) |
The file type to use.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.greedy(boolean greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.greedy(String greedy) |
If greedy is enabled, then the ScheduledPollConsumer will run
immediately again, if the previous run polled 1 or more messages.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.initialDelay(long initialDelay) |
Milliseconds before the first poll starts.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.initialDelay(String initialDelay) |
Milliseconds before the first poll starts.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.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).
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.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)).
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.kerberosUsername(String kerberosUsername) |
The username used to authenticate with the kerberos nodes.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.keyType(String keyType) |
The type for the key in case of sequence or map files.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.keyType(HdfsEndpointBuilderFactory.WritableType keyType) |
The type for the key in case of sequence or map files.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.maxMessagesPerPoll(int maxMessagesPerPoll) |
To define a maximum messages to gather per poll.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.maxMessagesPerPoll(String maxMessagesPerPoll) |
To define a maximum messages to gather per poll.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.namedNodes(String namedNodes) |
A comma separated list of named nodes (e.g.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.owner(String owner) |
The file owner must match this owner for the consumer to pickup the
file.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.pattern(String pattern) |
The pattern used for scanning the directory.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.repeatCount(long repeatCount) |
Specifies a maximum limit of number of fires.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.repeatCount(String repeatCount) |
Specifies a maximum limit of number of fires.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.runLoggingLevel(String runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.runLoggingLevel(org.apache.camel.LoggingLevel runLoggingLevel) |
The consumer logs a start/complete log line when it polls.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.scheduledExecutorService(String scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.scheduledExecutorService(ScheduledExecutorService scheduledExecutorService) |
Allows for configuring a custom/shared thread pool to use for the
consumer.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.scheduler(Object scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.scheduler(String scheduler) |
To use a cron scheduler from either camel-spring or camel-quartz
component.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.schedulerProperties(String key,
Object value) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.schedulerProperties(Map values) |
To configure additional properties when using a custom scheduler or
any of the Quartz, Spring based scheduler.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.sendEmptyMessageWhenIdle(boolean sendEmptyMessageWhenIdle) |
If the polling consumer did not poll any files, you can enable this
option to send an empty message (no body) instead.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.sendEmptyMessageWhenIdle(String sendEmptyMessageWhenIdle) |
If the polling consumer did not poll any files, you can enable this
option to send an empty message (no body) instead.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.startScheduler(boolean startScheduler) |
Whether the scheduler should be auto started.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.startScheduler(String startScheduler) |
Whether the scheduler should be auto started.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.streamDownload(boolean streamDownload) |
Sets the download method to use when not using a local working
directory.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.streamDownload(String streamDownload) |
Sets the download method to use when not using a local working
directory.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.timeUnit(String timeUnit) |
Time unit for initialDelay and delay options.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.timeUnit(TimeUnit timeUnit) |
Time unit for initialDelay and delay options.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.useFixedDelay(boolean useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.useFixedDelay(String useFixedDelay) |
Controls if fixed delay or fixed rate is used.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.valueType(String valueType) |
The type for the key in case of sequence or map files.
|
default HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointConsumerBuilder.valueType(HdfsEndpointBuilderFactory.WritableType valueType) |
The type for the key in case of sequence or map files.
|