Public Member Functions | |
delegate DatumReader< T > | CreateDatumReader (Schema writerSchema, Schema readerSchema) |
Header | GetHeader () |
Return the header for the input file / stream. | |
Schema | GetSchema () |
Return the schema as read from the input file / stream. | |
ICollection< string > | GetMetaKeys () |
Return the list of keys in the metadata. | |
byte[] | GetMeta (string key) |
Return the byte value of a metadata property. | |
long | GetMetaLong (string key) |
Return the long value of a metadata property. | |
string | GetMetaString (string key) |
Return the string value of a metadata property. | |
void | Seek (long position) |
Move to a specific, known synchronization point, one returned from IFileWriter.Sync() while writing. | |
void | Sync (long position) |
Move to the next synchronization point after a position. | |
bool | PastSync (long position) |
Return true if past the next synchronization point after a position. | |
long | PreviousSync () |
Return the last synchronization point before our current position. | |
long | Tell () |
Return the current position in the input. | |
bool | HasNext () |
True if more entries remain in this file. | |
void | Reset () |
void | Dispose () |
T | Next () |
Read the next datum from the file. | |
Static Public Member Functions | |
static IFileReader< T > | OpenReader (string path) |
Open a reader for a file using path. | |
static IFileReader< T > | OpenReader (string path, Schema readerSchema) |
Open a reader for a file using path and the reader's schema. | |
static IFileReader< T > | OpenReader (Stream inStream) |
Open a reader for a stream. | |
static IFileReader< T > | OpenReader (Stream inStream, Schema readerSchema) |
Open a reader for a stream using the reader's schema. | |
static IFileReader< T > | OpenReader (Stream inStream, Schema readerSchema, CreateDatumReader datumReaderFactory) |
Open a reader for a stream using the reader's schema and a custom DatumReader. | |
Properties | |
IEnumerable< T > | NextEntries [get] |
Return an enumeration of the remaining entries in the file. |
Header Avro.File.DataFileReader< T >.GetHeader | ( | ) | [inline] |
byte [] Avro.File.DataFileReader< T >.GetMeta | ( | string | key | ) | [inline] |
Return the byte value of a metadata property.
key |
Implements Avro.File.IFileReader< T >.
ICollection<string> Avro.File.DataFileReader< T >.GetMetaKeys | ( | ) | [inline] |
long Avro.File.DataFileReader< T >.GetMetaLong | ( | string | key | ) | [inline] |
Return the long value of a metadata property.
key |
Implements Avro.File.IFileReader< T >.
string Avro.File.DataFileReader< T >.GetMetaString | ( | string | key | ) | [inline] |
Return the string value of a metadata property.
key |
Implements Avro.File.IFileReader< T >.
Schema Avro.File.DataFileReader< T >.GetSchema | ( | ) | [inline] |
Return the schema as read from the input file / stream.
Implements Avro.File.IFileReader< T >.
bool Avro.File.DataFileReader< T >.HasNext | ( | ) | [inline] |
True if more entries remain in this file.
Implements Avro.File.IFileReader< T >.
T Avro.File.DataFileReader< T >.Next | ( | ) | [inline] |
Read the next datum from the file.
Implements Avro.File.IFileReader< T >.
static IFileReader<T> Avro.File.DataFileReader< T >.OpenReader | ( | string | path | ) | [inline, static] |
Open a reader for a file using path.
path |
static IFileReader<T> Avro.File.DataFileReader< T >.OpenReader | ( | string | path, |
Schema | readerSchema | ||
) | [inline, static] |
Open a reader for a file using path and the reader's schema.
path |
static IFileReader<T> Avro.File.DataFileReader< T >.OpenReader | ( | Stream | inStream | ) | [inline, static] |
Open a reader for a stream.
inStream |
static IFileReader<T> Avro.File.DataFileReader< T >.OpenReader | ( | Stream | inStream, |
Schema | readerSchema | ||
) | [inline, static] |
Open a reader for a stream using the reader's schema.
inStream |
static IFileReader<T> Avro.File.DataFileReader< T >.OpenReader | ( | Stream | inStream, |
Schema | readerSchema, | ||
CreateDatumReader | datumReaderFactory | ||
) | [inline, static] |
Open a reader for a stream using the reader's schema and a custom DatumReader.
inStream |
bool Avro.File.DataFileReader< T >.PastSync | ( | long | position | ) | [inline] |
Return true if past the next synchronization point after a position.
position |
Implements Avro.File.IFileReader< T >.
long Avro.File.DataFileReader< T >.PreviousSync | ( | ) | [inline] |
Return the last synchronization point before our current position.
Implements Avro.File.IFileReader< T >.
void Avro.File.DataFileReader< T >.Seek | ( | long | position | ) | [inline] |
Move to a specific, known synchronization point, one returned from IFileWriter.Sync() while writing.
position |
Implements Avro.File.IFileReader< T >.
void Avro.File.DataFileReader< T >.Sync | ( | long | position | ) | [inline] |
Move to the next synchronization point after a position.
position |
Implements Avro.File.IFileReader< T >.
long Avro.File.DataFileReader< T >.Tell | ( | ) | [inline] |
IEnumerable<T> Avro.File.DataFileReader< T >.NextEntries [get] |
Return an enumeration of the remaining entries in the file.
Implements Avro.File.IFileReader< T >.