org.apache.hadoop.hdfs.server.datanode.fsdataset

Class ReplicaOutputStreams

java.lang.Object

org.apache.hadoop.hdfs.server.datanode.fsdataset.ReplicaOutputStreams

All Implemented Interfaces:

Closeable, AutoCloseable

public class ReplicaOutputStreams
extends Object
implements Closeable

Contains the output streams for the data and checksum of a replica.

Constructor Summary

Constructors

Constructor and Description
ReplicaOutputStreams(OutputStream dataOut, OutputStream checksumOut, org.apache.hadoop.util.DataChecksum checksum, boolean isTransientStorage) Create an object with a data output stream, a checksum output stream and a checksum.

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
org.apache.hadoop.util.DataChecksum	getChecksum()
OutputStream	getChecksumOut()
OutputStream	getDataOut()
boolean	isTransientStorage()
void	syncChecksumOut() Sync the checksum stream if it supports it.
void	syncDataOut() Sync the data stream if it supports it.

Methods inherited from class java.lang.Object

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

Constructor Detail

ReplicaOutputStreams

public ReplicaOutputStreams(OutputStream dataOut,
                    OutputStream checksumOut,
                    org.apache.hadoop.util.DataChecksum checksum,
                    boolean isTransientStorage)

Create an object with a data output stream, a checksum output stream and a checksum.

Method Detail

getDataOut

public OutputStream getDataOut()

Returns:

the data output stream.

getChecksumOut

public OutputStream getChecksumOut()

Returns:

the checksum output stream.

getChecksum

public org.apache.hadoop.util.DataChecksum getChecksum()

Returns:

the checksum.

isTransientStorage

public boolean isTransientStorage()

Returns:

is writing to a transient storage?

close

public void close()

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

syncDataOut

public void syncDataOut()
                 throws IOException

Sync the data stream if it supports it.

Throws:

IOException

syncChecksumOut

public void syncChecksumOut()
                     throws IOException

Sync the checksum stream if it supports it.

Throws:

IOException