default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointProducerBuilder.advanced() |
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.blockSize(long blockSize) |
The size of the HDFS blocks.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.blockSize(String blockSize) |
The size of the HDFS blocks.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.bufferSize(int bufferSize) |
The buffer size used by HDFS.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.bufferSize(String bufferSize) |
The buffer size used by HDFS.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.checkIdleInterval(int checkIdleInterval) |
How often (time in millis) in to run the idle checker background
task.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.checkIdleInterval(String checkIdleInterval) |
How often (time in millis) in to run the idle checker background
task.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.chunkSize(int chunkSize) |
When reading a normal file, this is split into chunks producing a
message per chunk.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.chunkSize(String chunkSize) |
When reading a normal file, this is split into chunks producing a
message per chunk.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.compressionCodec(String compressionCodec) |
The compression codec to use.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.compressionCodec(HdfsEndpointBuilderFactory.HdfsCompressionCodec compressionCodec) |
The compression codec to use.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.compressionType(String compressionType) |
The compression type to use (is default not in use).
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.compressionType(HdfsEndpointBuilderFactory.CompressionType compressionType) |
The compression type to use (is default not in use).
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.openedSuffix(String openedSuffix) |
When a file is opened for reading/writing the file is renamed with
this suffix to avoid to read it during the writing phase.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.readSuffix(String readSuffix) |
Once the file has been read is renamed with this suffix to avoid to
read it again.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.replication(short replication) |
The HDFS replication factor.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.replication(String replication) |
The HDFS replication factor.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.splitStrategy(String splitStrategy) |
In the current version of Hadoop opening a file in append mode is
disabled since it's not very reliable.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.synchronous(boolean synchronous) |
Sets whether synchronous processing should be strictly used, or Camel
is allowed to use asynchronous processing (if supported).
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointProducerBuilder.synchronous(String synchronous) |
Sets whether synchronous processing should be strictly used, or Camel
is allowed to use asynchronous processing (if supported).
|