org.apache.hadoop.hdfs

Class DistributedFileSystem.HdfsDataOutputStreamBuilder

java.lang.Object

org.apache.hadoop.fs.FSDataOutputStreamBuilder<org.apache.hadoop.fs.FSDataOutputStream,DistributedFileSystem.HdfsDataOutputStreamBuilder>

org.apache.hadoop.hdfs.DistributedFileSystem.HdfsDataOutputStreamBuilder

Enclosing class:

org.apache.hadoop.hdfs.DistributedFileSystem

public static final class DistributedFileSystem.HdfsDataOutputStreamBuilder
extends org.apache.hadoop.fs.FSDataOutputStreamBuilder<org.apache.hadoop.fs.FSDataOutputStream,DistributedFileSystem.HdfsDataOutputStreamBuilder>

HdfsDataOutputStreamBuilder provides the HDFS-specific capabilities to write file on HDFS.

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.fs.FSDataOutputStream	build() Build HdfsDataOutputStream to write.
DistributedFileSystem.HdfsDataOutputStreamBuilder	favoredNodes(InetSocketAddress[] nodes) Set favored DataNodes.
protected EnumSet<org.apache.hadoop.fs.CreateFlag>	getFlags()
protected DistributedFileSystem.HdfsDataOutputStreamBuilder	getThisBuilder()
DistributedFileSystem.HdfsDataOutputStreamBuilder	lazyPersist() Create the block on transient storage if possible.
DistributedFileSystem.HdfsDataOutputStreamBuilder	newBlock() Append data to a new block instead of the end of the last partial block.
DistributedFileSystem.HdfsDataOutputStreamBuilder	noLocalWrite() Advise that a block replica NOT be written to the local DataNode.
DistributedFileSystem.HdfsDataOutputStreamBuilder	syncBlock() Force closed blocks to disk.

Methods inherited from class org.apache.hadoop.fs.FSDataOutputStreamBuilder

append, blockSize, bufferSize, checksumOpt, create, getBlockSize, getBufferSize, getChecksumOpt, getFS, getPath, getPermission, getProgress, getReplication, isRecursive, overwrite, permission, progress, recursive, replication

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getThisBuilder

protected DistributedFileSystem.HdfsDataOutputStreamBuilder getThisBuilder()

Specified by:

getThisBuilder in class org.apache.hadoop.fs.FSDataOutputStreamBuilder<org.apache.hadoop.fs.FSDataOutputStream,DistributedFileSystem.HdfsDataOutputStreamBuilder>

favoredNodes

public DistributedFileSystem.HdfsDataOutputStreamBuilder favoredNodes(@Nonnull
                                                             InetSocketAddress[] nodes)

Set favored DataNodes.

Parameters:

nodes - the addresses of the favored DataNodes.

syncBlock

public DistributedFileSystem.HdfsDataOutputStreamBuilder syncBlock()

Force closed blocks to disk.

See Also:

for the details.

lazyPersist

public DistributedFileSystem.HdfsDataOutputStreamBuilder lazyPersist()

Create the block on transient storage if possible.

See Also:

for the details.

newBlock

public DistributedFileSystem.HdfsDataOutputStreamBuilder newBlock()

Append data to a new block instead of the end of the last partial block.

See Also:

for the details.

noLocalWrite

public DistributedFileSystem.HdfsDataOutputStreamBuilder noLocalWrite()

Advise that a block replica NOT be written to the local DataNode.

See Also:

for the details.

getFlags

protected EnumSet<org.apache.hadoop.fs.CreateFlag> getFlags()

Overrides:

getFlags in class org.apache.hadoop.fs.FSDataOutputStreamBuilder<org.apache.hadoop.fs.FSDataOutputStream,DistributedFileSystem.HdfsDataOutputStreamBuilder>

build

public org.apache.hadoop.fs.FSDataOutputStream build()
                                              throws IOException

Build HdfsDataOutputStream to write.

Specified by:

build in class org.apache.hadoop.fs.FSDataOutputStreamBuilder<org.apache.hadoop.fs.FSDataOutputStream,DistributedFileSystem.HdfsDataOutputStreamBuilder>

Returns:

a fully-initialized OutputStream.

Throws:

IOException - on I/O errors.