AdlsInputStream Classe

Definição

Namespace:

Microsoft.Azure.DataLake.Store

Assembly:

Microsoft.Azure.DataLake.Store.dll

Pacote:

Microsoft.Azure.DataLake.Store v1.1.24

Fluxo de entrada do ADLS que lê dados de um arquivo no Data lake. Ele lê dados em massa do servidor para um buffer e, em seguida, fornece saída em buffer para o cliente de acordo com a solicitação. Os dados podem ser lidos de forma assíncrona/síncrona. Os dados podem ser lidos em série ou de pontos arbitrários no arquivo. A leitura é totalmente síncrona até a camada de transporte. ReadAsync é totalmente assíncrono até a camada de transporte. AdlsInputStream não é threadsafe, pois usa buffer (mantém o estado para não ser sem estado).

public class AdlsInputStream : System.IO.Stream

type AdlsInputStream = class
    inherit Stream

Public Class AdlsInputStream
Inherits Stream

Herança

Stream

AdlsInputStream

Derivado

Microsoft.Azure.DataLake.Store.MockAdlsFileSystem.MockAdlsInputStream

Construtores

AdlsInputStream()

Só para fins de simulação. Para fins de simulação, você pode herdar dessa classe e substituir seus métodos

Propriedades

CanRead	Se o fluxo pode ler dados
CanSeek	Se o fluxo pode buscar dados
CanWrite	Se o fluxo pode gravar dados
Length	tamanho total do arquivo
Position	Posição do fluxo desde o início

Métodos

Dispose(Boolean)	Libera os recursos não gerenciados usados pelo Stream e, opcionalmente, libera os recursos gerenciados
Flush()	Sem suporte
Read(Byte[], Int32, Int32)	Lê uma sequência de bytes do fluxo atual e avança a posição dentro do fluxo pelo número de bytes lidos operação síncrona.
Read(Int64, Byte[], Int32, Int32)	Lê uma sequência de bytes diretamente do servidor. Ele não atualiza nada no fluxo.
ReadAsync(Byte[], Int32, Int32, CancellationToken)	Lê uma sequência de bytes do fluxo atual e avança a posição dentro do fluxo pelo número de bytes lidos operação assíncrona.
ReadAsync(Int64, Byte[], Int32, Int32)	Lê uma sequência de bytes diretamente do servidor. Ele não atualiza nada no fluxo.
Seek(Int64, SeekOrigin)	Atualizações a posição do fluxo com base em SeekOrigin
SetLength(Int64)	Sem suporte
Write(Byte[], Int32, Int32)	Sem suporte