AdlsInputStream Classe

Référence

Définition

Espace de noms:: Microsoft.Azure.DataLake.Store

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

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

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

Important

Certaines informations portent sur la préversion du produit qui est susceptible d’être en grande partie modifiée avant sa publication. Microsoft exclut toute garantie, expresse ou implicite, concernant les informations fournies ici.

Flux d’entrée ADLS qui lit les données d’un fichier sur Data lake. Il lit les données en bloc du serveur vers une mémoire tampon, puis fournit une sortie mise en mémoire tampon au client en fonction de la demande. Les données peuvent être lues de manière asynchrone/synchrone. Les données peuvent être lues en série ou à partir de points arbitraires dans le fichier. La lecture est entièrement synchrone jusqu’à la couche de transport. ReadAsync est entièrement asynchrone jusqu’à la couche de transport. AdlsInputStream n’est pas threadsafe, car il utilise la mémoire tampon (maintient l’état donc pas sans état).

public class AdlsInputStream : System.IO.Stream

type AdlsInputStream = class
    inherit Stream

Public Class AdlsInputStream
Inherits Stream

Héritage: Stream
AdlsInputStream

Dérivé: Microsoft.Azure.DataLake.Store.MockAdlsFileSystem.MockAdlsInputStream

Constructeurs

AdlsInputStream()

Uniquement à des fins moqueurs. À des fins moqueurs, vous pouvez hériter de cette classe et remplacer vos méthodes

Propriétés

CanRead	Si le flux peut lire des données
CanSeek	Si le flux peut rechercher des données
CanWrite	Si le flux peut écrire des données
Length	longueur totale du fichier
Position	Position du flux à partir du début

Méthodes

Dispose(Boolean)	Libère les ressources non managées utilisées par le flux et libère éventuellement les ressources managées
Flush()	Non prise en charge
Read(Byte[], Int32, Int32)	Lit une séquence d’octets du flux actuel et avance la position dans le flux en fonction du nombre d’octets lus Opération synchrone.
Read(Int64, Byte[], Int32, Int32)	Lit une séquence d’octets directement à partir du serveur. Il ne met rien à jour dans le flux.
ReadAsync(Byte[], Int32, Int32, CancellationToken)	Lit une séquence d’octets du flux actuel et avance la position dans le flux en fonction du nombre d’octets lus opération asynchrone.
ReadAsync(Int64, Byte[], Int32, Int32)	Lit une séquence d’octets directement à partir du serveur. Il ne met rien à jour dans le flux.
Seek(Int64, SeekOrigin)	Mises à jour la position du flux en fonction de SeekOrigin
SetLength(Int64)	Non prise en charge
Write(Byte[], Int32, Int32)	Non prise en charge

S’applique à

Partager via