default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.append(boolean append) |
Append to existing file.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.append(String append) |
Append to existing file.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.basic() |
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.connectOnStartup(boolean connectOnStartup) |
Whether to connect to the HDFS file system on starting the
producer/consumer.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.connectOnStartup(String connectOnStartup) |
Whether to connect to the HDFS file system on starting the
producer/consumer.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.fileSystemType(String fileSystemType) |
Set to LOCAL to not use HDFS but local java.io.File instead.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.fileSystemType(HdfsEndpointBuilderFactory.HdfsFileSystemType fileSystemType) |
Set to LOCAL to not use HDFS but local java.io.File instead.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.fileType(String fileType) |
The file type to use.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.fileType(HdfsEndpointBuilderFactory.HdfsFileType fileType) |
The file type to use.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
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).
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
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)).
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.kerberosUsername(String kerberosUsername) |
The username used to authenticate with the kerberos nodes.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.keyType(String keyType) |
The type for the key in case of sequence or map files.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.keyType(HdfsEndpointBuilderFactory.WritableType keyType) |
The type for the key in case of sequence or map files.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.lazyStartProducer(boolean lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.lazyStartProducer(String lazyStartProducer) |
Whether the producer should be started lazy (on the first message).
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.namedNodes(String namedNodes) |
A comma separated list of named nodes (e.g.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.overwrite(boolean overwrite) |
Whether to overwrite existing files with the same name.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.overwrite(String overwrite) |
Whether to overwrite existing files with the same name.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.owner(String owner) |
The file owner must match this owner for the consumer to pickup the
file.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.valueType(String valueType) |
The type for the key in case of sequence or map files.
|
default HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.valueType(HdfsEndpointBuilderFactory.WritableType valueType) |
The type for the key in case of sequence or map files.
|