Avro C#
|
Provides access to Avro data written using the DataFileWriter<T>. More...
Public Member Functions | |
delegate DatumReader< T > | CreateDatumReader (Schema writerSchema, Schema readerSchema) |
Defines the signature for a function that returns a new DatumReader<T> given a writer and reader schema. More... | |
Header | GetHeader () |
Return the header for the input file or stream. | |
Schema | GetSchema () |
Return the schema as read from the file or 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. This method assumes that the string is a UTF-8 encoded in the header. | |
void | Seek (long position) |
Move to a specific, known synchronization point, one returned from IFileWriter<T>.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 () |
Returns true if more entries remain in this file. | |
void | Reset () |
Resets this reader. More... | |
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 More... | |
static IFileReader< T > | OpenReader (string path, Schema readerSchema) |
Open a reader for a file using path and the reader's schema More... | |
static IFileReader< T > | OpenReader (Stream inStream) |
Open a reader for a stream More... | |
static IFileReader< T > | OpenReader (Stream inStream, Schema readerSchema) |
Open a reader for a stream using the reader's schema More... | |
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 More... | |
Protected Member Functions | |
virtual void | Dispose (bool disposing) |
Releases resources associated with this DataFileReader<T>. More... | |
Properties | |
IEnumerable< T > | NextEntries [get] |
![]() | |
IEnumerable< T > | NextEntries [get] |
Return an enumeration of the remaining entries in the file. More... | |
Provides access to Avro data written using the DataFileWriter<T>.
T | Type to deserialze data objects to. |
delegate DatumReader<T> Avro.File.DataFileReader< T >.CreateDatumReader | ( | Schema | writerSchema, |
Schema | readerSchema | ||
) |
|
inlineprotectedvirtual |
Releases resources associated with this DataFileReader<T>.
disposing | True if called from Dispose(); false otherwise. |
|
inlinestatic |
Open a reader for a file using path
path |
|
inlinestatic |
Open a reader for a file using path and the reader's schema
path | Path to the file |
readerSchema | Schema used to read data from the file |
|
inlinestatic |
Open a reader for a stream
inStream |
|
inlinestatic |
Open a reader for a stream using the reader's schema
inStream | Stream containing the file contents |
readerSchema | Schema used to read the file |
|
inlinestatic |
Open a reader for a stream using the reader's schema and a custom DatumReader
inStream | Stream of file contents |
readerSchema | Schema used to read the file |
datumReaderFactory | Factory to create datum readers given a reader an writer schema |
|
inline |
Resets this reader.