Click or drag to resize

DfsOutputStream Class

Provides a stream for writing files to the distributed file system.
Inheritance Hierarchy
SystemObject
  SystemMarshalByRefObject
    System.IOStream
      Ookii.Jumbo.DfsDfsOutputStream

Namespace: Ookii.Jumbo.Dfs
Assembly: Ookii.Jumbo.Dfs (in Ookii.Jumbo.Dfs.dll) Version: 0.3.0+dc1307f20e065bb638e0b73a34cd216f57e486f1
Syntax
public class DfsOutputStream : Stream, 
	IRecordOutputStream

The DfsOutputStream type exposes the following members.

Constructors
 NameDescription
Public methodDfsOutputStream(INameServerClientProtocol, String) Initializes a new instance of the DfsOutputStream with the specified name server and file.
Public methodDfsOutputStream(INameServerClientProtocol, String, RecordStreamOptions) Initializes a new instance of the DfsOutputStream class.
Public methodDfsOutputStream(INameServerClientProtocol, String, Int32, Int32) Initializes a new instance of the DfsOutputStream with the specified name server and file.
Public methodDfsOutputStream(INameServerClientProtocol, String, Int32, Int32, Boolean, RecordStreamOptions) Initializes a new instance of the DfsOutputStream with the specified name server and file.
Top
Properties
 NameDescription
Public propertyBlockSize Gets the size of the blocks of this file.
Public propertyCanRead Gets a value that indicates whether the current stream supports reading.
(Overrides StreamCanRead)
Public propertyCanSeek Gets a value that indicates whether the current stream supports seeking.
(Overrides StreamCanSeek)
Public propertyCanTimeoutGets a value that determines whether the current stream can time out.
(Inherited from Stream)
Public propertyCanWrite Gets a value that indicates whether the current stream supports writing.
(Overrides StreamCanWrite)
Public propertyLength Gets the length of the stream.
(Overrides StreamLength)
Public propertyPosition Gets the current stream position.
(Overrides StreamPosition)
Public propertyReadTimeoutGets or sets a value, in milliseconds, that determines how long the stream will attempt to read before timing out.
(Inherited from Stream)
Public propertyRecordOptions Gets the options applied to records in the stream.
Public propertyRecordsSize Gets the amount of the stream that is actually used by records.
Public propertyWriteTimeoutGets or sets a value, in milliseconds, that determines how long the stream will attempt to write before timing out.
(Inherited from Stream)
Top
Methods
 NameDescription
Public methodBeginReadBegins an asynchronous read operation. (Consider using ReadAsync(Byte, Int32, Int32) instead.)
(Inherited from Stream)
Public methodBeginWriteBegins an asynchronous write operation. (Consider using WriteAsync(Byte, Int32, Int32) instead.)
(Inherited from Stream)
Public methodCloseCloses the current stream and releases any resources (such as sockets and file handles) associated with the current stream. Instead of calling this method, ensure that the stream is properly disposed.
(Inherited from Stream)
Public methodCopyTo(Stream)Reads the bytes from the current stream and writes them to another stream. Both streams positions are advanced by the number of bytes copied.
(Inherited from Stream)
Public methodCopyTo(Stream, Int32)Reads the bytes from the current stream and writes them to another stream, using a specified buffer size. Both streams positions are advanced by the number of bytes copied.
(Inherited from Stream)
Public methodCopyToAsync(Stream)Asynchronously reads the bytes from the current stream and writes them to another stream. Both streams positions are advanced by the number of bytes copied.
(Inherited from Stream)
Public methodCopyToAsync(Stream, Int32)Asynchronously reads the bytes from the current stream and writes them to another stream, using a specified buffer size. Both streams positions are advanced by the number of bytes copied.
(Inherited from Stream)
Public methodCopyToAsync(Stream, CancellationToken)Asynchronously reads the bytes from the current stream and writes them to another stream, using a specified cancellation token. Both streams positions are advanced by the number of bytes copied.
(Inherited from Stream)
Public methodCopyToAsync(Stream, Int32, CancellationToken)Asynchronously reads the bytes from the current stream and writes them to another stream, using a specified buffer size and cancellation token. Both streams positions are advanced by the number of bytes copied.
(Inherited from Stream)
Protected methodCreateWaitHandleObsolete.
Allocates a WaitHandle object.
(Inherited from Stream)
Public methodDisposeReleases all resources used by the Stream.
(Inherited from Stream)
Protected methodDispose(Boolean) Releases the unmanaged resources used by the DfsOutputStream and optionally releases the managed resources.
(Overrides StreamDispose(Boolean))
Public methodDisposeAsyncAsynchronously releases the unmanaged resources used by the Stream.
(Inherited from Stream)
Public methodEndReadWaits for the pending asynchronous read to complete. (Consider using ReadAsync(Byte, Int32, Int32) instead.)
(Inherited from Stream)
Public methodEndWriteEnds an asynchronous write operation. (Consider using WriteAsync(Byte, Int32, Int32) instead.)
(Inherited from Stream)
Public methodEqualsDetermines whether the specified object is equal to the current object.
(Inherited from Object)
Protected methodFinalize Finalizes this instance of the DfsOutputStream class.
(Overrides ObjectFinalize)
Public methodFlush This method is not used; it does nothing.
(Overrides StreamFlush)
Public methodFlushAsyncAsynchronously clears all buffers for this stream and causes any buffered data to be written to the underlying device.
(Inherited from Stream)
Public methodFlushAsync(CancellationToken)Asynchronously clears all buffers for this stream, causes any buffered data to be written to the underlying device, and monitors cancellation requests.
(Inherited from Stream)
Public methodGetHashCodeServes as the default hash function.
(Inherited from Object)
Public methodGetLifetimeServiceObsolete.
Retrieves the current lifetime service object that controls the lifetime policy for this instance.
(Inherited from MarshalByRefObject)
Public methodGetTypeGets the Type of the current instance.
(Inherited from Object)
Public methodInitializeLifetimeServiceObsolete.
Obtains a lifetime service object to control the lifetime policy for this instance.
(Inherited from MarshalByRefObject)
Public methodMarkRecord Indicates that the current position of the stream is a record boundary.
Protected methodMemberwiseCloneCreates a shallow copy of the current Object.
(Inherited from Object)
Protected methodMemberwiseClone(Boolean)Creates a shallow copy of the current MarshalByRefObject object.
(Inherited from MarshalByRefObject)
Protected methodObjectInvariantObsolete.
Provides support for a Contract.
(Inherited from Stream)
Public methodRead(SpanByte)When overridden in a derived class, reads a sequence of bytes from the current stream and advances the position within the stream by the number of bytes read.
(Inherited from Stream)
Public methodRead(Byte, Int32, Int32) Not supported.
(Overrides StreamRead(Byte, Int32, Int32))
Public methodReadAsync(MemoryByte, CancellationToken)Asynchronously reads a sequence of bytes from the current stream, advances the position within the stream by the number of bytes read, and monitors cancellation requests.
(Inherited from Stream)
Public methodReadAsync(Byte, Int32, Int32)Asynchronously reads a sequence of bytes from the current stream and advances the position within the stream by the number of bytes read.
(Inherited from Stream)
Public methodReadAsync(Byte, Int32, Int32, CancellationToken)Asynchronously reads a sequence of bytes from the current stream, advances the position within the stream by the number of bytes read, and monitors cancellation requests.
(Inherited from Stream)
Public methodReadAtLeastReads at least a minimum number of bytes from the current stream and advances the position within the stream by the number of bytes read.
(Inherited from Stream)
Public methodReadAtLeastAsyncAsynchronously reads at least a minimum number of bytes from the current stream, advances the position within the stream by the number of bytes read, and monitors cancellation requests.
(Inherited from Stream)
Public methodReadByteReads a byte from the stream and advances the position within the stream by one byte, or returns -1 if at the end of the stream.
(Inherited from Stream)
Public methodReadExactly(SpanByte)Reads bytes from the current stream and advances the position within the stream until the buffer is filled.
(Inherited from Stream)
Public methodReadExactly(Byte, Int32, Int32)Reads count number of bytes from the current stream and advances the position within the stream.
(Inherited from Stream)
Public methodReadExactlyAsync(MemoryByte, CancellationToken)Asynchronously reads bytes from the current stream, advances the position within the stream until the buffer is filled, and monitors cancellation requests.
(Inherited from Stream)
Public methodReadExactlyAsync(Byte, Int32, Int32, CancellationToken)Asynchronously reads count number of bytes from the current stream, advances the position within the stream, and monitors cancellation requests.
(Inherited from Stream)
Public methodSeek Not supported.
(Overrides StreamSeek(Int64, SeekOrigin))
Public methodSetLength Not supported.
(Overrides StreamSetLength(Int64))
Public methodToStringReturns a string that represents the current object.
(Inherited from Object)
Public methodWrite(ReadOnlySpanByte) Writes a span of bytes to the current stream and advances the current position within this stream by the number of bytes written.
(Overrides StreamWrite(ReadOnlySpanByte))
Public methodWrite(Byte, Int32, Int32) Writes a sequence of bytes to the current stream and advances the current position within this stream by the number of bytes written.
(Overrides StreamWrite(Byte, Int32, Int32))
Public methodWriteAsync(ReadOnlyMemoryByte, CancellationToken)Asynchronously writes a sequence of bytes to the current stream, advances the current position within this stream by the number of bytes written, and monitors cancellation requests.
(Inherited from Stream)
Public methodWriteAsync(Byte, Int32, Int32)Asynchronously writes a sequence of bytes to the current stream and advances the current position within this stream by the number of bytes written.
(Inherited from Stream)
Public methodWriteAsync(Byte, Int32, Int32, CancellationToken)Asynchronously writes a sequence of bytes to the current stream, advances the current position within this stream by the number of bytes written, and monitors cancellation requests.
(Inherited from Stream)
Public methodWriteByteWrites a byte to the current position in the stream and advances the position within the stream by one byte.
(Overrides StreamWriteByte(Byte))
Top
Extension Methods
 NameDescription
Public Extension MethodCopySize Copies the specified number of bytes from one stream to another using the default buffer size.
(Defined by StreamExtensions)
Public Extension MethodCopySize Copies the specified number of bytes from one stream to another using the specified buffer size.
(Defined by StreamExtensions)
Public Extension MethodCopyTo Copies one stream to another.
(Defined by StreamExtensions)
Public Extension MethodCopyTo Copies one stream to another using the specified buffer size.
(Defined by StreamExtensions)
Public Extension MethodCreateCompressor Creates a compressor for the specified stream.
(Defined by CompressionUtility)
Public Extension MethodCreateDecompressor Creates a decompressor for the specified stream.
(Defined by CompressionUtility)
Top
Thread Safety
Any public static (Shared in Visual Basic) members of this type are thread safe. Any instance members are not guaranteed to be thread safe.
See Also