AdlsInputStream Class

Reference

Definition

Namespace:: Microsoft.Azure.DataLake.Store

Assembly:: Microsoft.Azure.DataLake.Store.dll

Package:: Microsoft.Azure.DataLake.Store v1.1.24

Package:: Microsoft.Azure.DataLake.Store v1.2.5-alpha

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

ADLS Input stream that reads data from a file on Data lake. It reads data in bulk from server to a buffer and then provides buffered output to the client as per request. Data can be read asynchronously/synchronously. Data can be read serially or from arbitrary points in file. Read is fully synchronous till the transport layer. ReadAsync is fully asynchronous till the transport layer. AdlsInputStream is not threadsafe since it uses buffer (maintains state so not stateless).

public class AdlsInputStream : System.IO.Stream

type AdlsInputStream = class
    inherit Stream

Public Class AdlsInputStream
Inherits Stream

Inheritance: Stream
AdlsInputStream

Derived: Microsoft.Azure.DataLake.Store.MockAdlsFileSystem.MockAdlsInputStream

Constructors

AdlsInputStream()

Only for Mocking purpose. For mocking purpose you can inherit from this class and override your methods

Properties

CanRead	Whether stream can read data
CanSeek	Whether the stream can seek data
CanWrite	Whether the stream can write data
Length	total Length of the file
Position	Position of the stream from begining

Methods

Dispose(Boolean)	Releases the unmanaged resources used by the Stream and optionally releases the managed resources
Flush()	Not supported
Read(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 Synchronous operation.
Read(Int64, Byte[], Int32, Int32)	Reads a sequence of bytes directly from the server. It does not update anything in the stream.
ReadAsync(Byte[], Int32, Int32, CancellationToken)	Reads a sequence of bytes from the current stream and advances the position within the stream by the number of bytes read Asynchronous operation.
ReadAsync(Int64, Byte[], Int32, Int32)	Reads a sequence of bytes directly from the server. It does not update anything in the stream.
Seek(Int64, SeekOrigin)	Updates the position of the stream based on SeekOrigin
SetLength(Int64)	Not supported
Write(Byte[], Int32, Int32)	Not supported

Applies to

Share via