default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.basic() |
|
default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.connectOnStartup(boolean connectOnStartup) |
Whether to connect to the HDFS file system on starting the
producer/consumer.
|
default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.connectOnStartup(String connectOnStartup) |
Whether to connect to the HDFS file system on starting the
producer/consumer.
|
static HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.endpointBuilder(String componentName,
String path) |
|
default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.fileSystemType(String fileSystemType) |
Set to LOCAL to not use HDFS but local java.io.File instead.
|
default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.fileSystemType(HdfsEndpointBuilderFactory.HdfsFileSystemType fileSystemType) |
Set to LOCAL to not use HDFS but local java.io.File instead.
|
default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.fileType(String fileType) |
The file type to use.
|
default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.fileType(HdfsEndpointBuilderFactory.HdfsFileType fileType) |
The file type to use.
|
default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsBuilders.hdfs(String path) |
HDFS (camel-hdfs)
Read and write from/to an HDFS filesystem using Hadoop 2.x.
|
default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsBuilders.hdfs(String componentName,
String path) |
HDFS (camel-hdfs)
Read and write from/to an HDFS filesystem using Hadoop 2.x.
|
default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.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.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.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.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.kerberosUsername(String kerberosUsername) |
The username used to authenticate with the kerberos nodes.
|
default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.keyType(String keyType) |
The type for the key in case of sequence or map files.
|
default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.keyType(HdfsEndpointBuilderFactory.WritableType keyType) |
The type for the key in case of sequence or map files.
|
default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.namedNodes(String namedNodes) |
A comma separated list of named nodes (e.g.
|
default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.owner(String owner) |
The file owner must match this owner for the consumer to pickup the
file.
|
default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.valueType(String valueType) |
The type for the key in case of sequence or map files.
|
default HdfsEndpointBuilderFactory.HdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.valueType(HdfsEndpointBuilderFactory.WritableType valueType) |
The type for the key in case of sequence or map files.
|