default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.HdfsEndpointBuilder.advanced() |
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.blockSize(long blockSize) |
The size of the HDFS blocks.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.blockSize(String blockSize) |
The size of the HDFS blocks.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.bufferSize(int bufferSize) |
The buffer size used by HDFS.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.bufferSize(String bufferSize) |
The buffer size used by HDFS.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.checkIdleInterval(int checkIdleInterval) |
How often (time in millis) in to run the idle checker background
task.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.checkIdleInterval(String checkIdleInterval) |
How often (time in millis) in to run the idle checker background
task.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.chunkSize(int chunkSize) |
When reading a normal file, this is split into chunks producing a
message per chunk.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.chunkSize(String chunkSize) |
When reading a normal file, this is split into chunks producing a
message per chunk.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.compressionCodec(String compressionCodec) |
The compression codec to use.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.compressionCodec(HdfsEndpointBuilderFactory.HdfsCompressionCodec compressionCodec) |
The compression codec to use.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.compressionType(String compressionType) |
The compression type to use (is default not in use).
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.compressionType(HdfsEndpointBuilderFactory.CompressionType compressionType) |
The compression type to use (is default not in use).
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.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.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.readSuffix(String readSuffix) |
Once the file has been read is renamed with this suffix to avoid to
read it again.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.replication(short replication) |
The HDFS replication factor.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.replication(String replication) |
The HDFS replication factor.
|
default HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder |
HdfsEndpointBuilderFactory.AdvancedHdfsEndpointBuilder.splitStrategy(String splitStrategy) |
In the current version of Hadoop opening a file in append mode is
disabled since it's not very reliable.
|