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