Click or drag to resize

DfsInputStream Class

Provides a stream for reading a block from the distributed file system.
Inheritance Hierarchy
SystemObject
  SystemMarshalByRefObject
    System.IOStream
      Ookii.Jumbo.DfsDfsInputStream

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

The DfsInputStream type exposes the following members.

Constructors
 NameDescription
Public methodDfsInputStream Initializes a new instance of the DfsInputStream with the specified name server and file.
Top
Properties
 NameDescription
Public propertyBlockSize Gets the size of the blocks of this file.
Public propertyBlocksRead Gets the number of blocks read.
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 propertyDataServerErrors Gets the number of errors encountered while reading data from the data servers.
Public propertyIsStopped Gets a value indicating whether this instance has stopped reading.
Public propertyLength Gets the length of the stream.
(Overrides StreamLength)
Public propertyPaddingBytesSkipped Gets the amount of padding skipped while reading from the stream.
Public propertyPosition Gets or sets 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 record options applied to this stream.
Public propertyStopReadingAtPosition Gets or sets the position in the stream after which no data will be read.
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 methodAreInsideSameBoundary Determines whether the range between two specified positions does not cross a structural boundary (e.g. a block boundary on the DFS).
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 DfsInputStream 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 Ensures that resources are freed and other cleanup operations are performed when the garbage collector reclaims the DfsInputStream.
(Overrides ObjectFinalize)
Public methodFlush This method is not used for this class; 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)
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 methodOffsetFromBoundary Determines the offset of the specified position from the directly preceding structural boundary (e.g. a block boundary on the DFS).
Public methodRead(SpanByte) Reads a sequence of bytes from the current stream and advances the position within the stream by the number of bytes read.
(Overrides StreamRead(SpanByte))
Public methodRead(Byte, Int32, Int32) Reads a sequence of bytes from the current stream and advances the position within the stream by the number of bytes read.
(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.
(Overrides StreamReadByte)
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 Sets the position within the current stream.
(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)When overridden in a derived class, 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 methodWrite(Byte, Int32, Int32) Not supported.
(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.
(Inherited from Stream)
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