|
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] |
Properties inherited from Avro.File.IFileReader< T > | |
| 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.
1.8.13