Package 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
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, CREATE_RETRY_COUNT, currentPacket, dfsClient, fileId, initialFileSize, lastFlushOffset, LOG, packetSize, shouldSyncBlock, src, streamer, SUPPORTED_CRYPTO_VERSIONS
Fields inherited from interface org.apache.hadoop.fs.StreamCapabilities
ABORTABLE_STREAM, DROPBEHIND, HFLUSH, HSYNC, IOSTATISTICS, IOSTATISTICS_CONTEXT, PREADBYTEBUFFER, READAHEAD, READBYTEBUFFER, UNBUFFER, VECTOREDIO
-
Constructor Summary
ConstructorDescriptionDummyDFSOutputStream
(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
Methods inherited from class org.apache.hadoop.hdfs.DFSOutputStream
addBlock, adjustChunkBoundary, checkClosed, closeImpl, closeThreads, completeFile, completeFile, computePacketChunkSize, createPacket, createWriteTraceScope, endBlock, enqueueCurrentPacket, enqueueCurrentPacketFull, flushInternal, flushInternalWithoutWaitingAck, getAddBlockFlags, getBlock, getBlockToken, getCurrentBlockReplication, getFileEncryptionInfo, getFileId, getInitialLen, getNamespace, getNumCurrentReplicas, getPipeline, getSrc, getStreamer, getUniqKey, hasCapability, hflush, hsync, hsync, isClosed, isLeaseRecovered, newStreamForAppend, newStreamForCreate, recoverLease, setAppendChunk, setArtificialSlowdown, setBytesCurBlock, setChunksPerPacket, setClosed, setCurrentPacketToEmpty, 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
nullOutputStream, write
-
Field Details
-
delegate
-
-
Constructor Details
-
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 Details
-
abort
- Overrides:
abort
in classorg.apache.hadoop.hdfs.DFSOutputStream
- Throws:
IOException
-
close
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Overrides:
close
in classorg.apache.hadoop.hdfs.DFSOutputStream
- Throws:
IOException
-