org.apache.hadoop.hdfs

Class DummyDFSOutputStream

java.lang.Object

java.io.OutputStream

org.apache.hadoop.fs.FSOutputSummer

org.apache.hadoop.hdfs.DFSOutputStream

org.apache.hadoop.hdfs.DummyDFSOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, org.apache.hadoop.fs.CanSetDropBehind, org.apache.hadoop.fs.StreamCapabilities, org.apache.hadoop.fs.Syncable

@InterfaceAudience.Private
public final class DummyDFSOutputStream
extends org.apache.hadoop.hdfs.DFSOutputStream

A dummy DFSOutputStream which is mainly used for lease renewal.

We have to put it under this package as we want to override a package private method.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.fs.StreamCapabilities

org.apache.hadoop.fs.StreamCapabilities.StreamCapability

Field Summary

Fields inherited from class org.apache.hadoop.hdfs.DFSOutputStream

blockSize, byteArrayManager, bytesPerChecksum, cachingStrategy, chunksPerPacket, closed, currentPacket, dfsClient, fileId, initialFileSize, lastFlushOffset, packetSize, shouldSyncBlock, src, streamer

Fields inherited from interface org.apache.hadoop.fs.StreamCapabilities

ABORTABLE_STREAM, DROPBEHIND, HFLUSH, HSYNC, IOSTATISTICS, IOSTATISTICS_CONTEXT, PREADBYTEBUFFER, READAHEAD, READBYTEBUFFER, UNBUFFER, VECTOREDIO

Constructor Summary

Constructors

Constructor and Description
DummyDFSOutputStream(AsyncFSOutput output, org.apache.hadoop.hdfs.DFSClient dfsClient, String src, org.apache.hadoop.hdfs.protocol.HdfsFileStatus stat, EnumSet<org.apache.hadoop.fs.CreateFlag> flag, org.apache.hadoop.util.DataChecksum checksum)

Method Summary

Modifier and Type	Method and Description
void	abort()
void	close()

Methods inherited from class org.apache.hadoop.hdfs.DFSOutputStream

adjustChunkBoundary, checkClosed, closeImpl, closeThreads, completeFile, computePacketChunkSize, createPacket, createWriteTraceScope, flushInternal, flushInternalWithoutWaitingAck, getAddBlockFlags, getCurrentBlockReplication, getFileEncryptionInfo, getFileId, getInitialLen, getNamespace, getNumCurrentReplicas, getPipeline, getStreamer, getUniqKey, hasCapability, hflush, hsync, hsync, recoverLease, setArtificialSlowdown, setChunksPerPacket, setDropBehind, start, toString, writeChunk, writeChunk

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

convertToByteStream, flush, flushBuffer, flushBuffer, getBufferedDataSize, getChecksumSize, getDataChecksum, resetChecksumBufSize, setChecksumBufSize, write, write

Methods inherited from class java.io.OutputStream

write

Methods inherited from class java.lang.Object

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

Constructor Detail

DummyDFSOutputStream

public DummyDFSOutputStream(AsyncFSOutput output,
                            org.apache.hadoop.hdfs.DFSClient dfsClient,
                            String src,
                            org.apache.hadoop.hdfs.protocol.HdfsFileStatus stat,
                            EnumSet<org.apache.hadoop.fs.CreateFlag> flag,
                            org.apache.hadoop.util.DataChecksum checksum)

Method Detail

abort

public void abort()
           throws IOException

Overrides:

abort in class org.apache.hadoop.hdfs.DFSOutputStream

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Overrides:

close in class org.apache.hadoop.hdfs.DFSOutputStream

Throws:

IOException