|
|
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 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...
|
| |
|
|
IEnumerable< T > | NextEntries [get] |
| |
| IEnumerable< T > | NextEntries [get] |
| | Return an enumeration of the remaining entries in the file More...
|
| |
| Header Avro.File.DataFileReader< T >.GetHeader |
( |
| ) |
|
|
inline |
| byte [] Avro.File.DataFileReader< T >.GetMeta |
( |
string |
key | ) |
|
|
inline |
| ICollection<string> Avro.File.DataFileReader< T >.GetMetaKeys |
( |
| ) |
|
|
inline |
| long Avro.File.DataFileReader< T >.GetMetaLong |
( |
string |
key | ) |
|
|
inline |
| string Avro.File.DataFileReader< T >.GetMetaString |
( |
string |
key | ) |
|
|
inline |
| Schema Avro.File.DataFileReader< T >.GetSchema |
( |
| ) |
|
|
inline |
| bool Avro.File.DataFileReader< T >.HasNext |
( |
| ) |
|
|
inline |
| T Avro.File.DataFileReader< T >.Next |
( |
| ) |
|
|
inline |
| static IFileReader<T> Avro.File.DataFileReader< T >.OpenReader |
( |
string |
path | ) |
|
|
inlinestatic |
Open a reader for a file using path
- Parameters
-
- Returns
| static IFileReader<T> Avro.File.DataFileReader< T >.OpenReader |
( |
string |
path, |
|
|
Schema |
readerSchema |
|
) |
| |
|
inlinestatic |
Open a reader for a file using path and the reader's schema
- Parameters
-
- Returns
| static IFileReader<T> Avro.File.DataFileReader< T >.OpenReader |
( |
Stream |
inStream | ) |
|
|
inlinestatic |
Open a reader for a stream
- Parameters
-
- Returns
| static IFileReader<T> Avro.File.DataFileReader< T >.OpenReader |
( |
Stream |
inStream, |
|
|
Schema |
readerSchema |
|
) |
| |
|
inlinestatic |
Open a reader for a stream using the reader's schema
- Parameters
-
- Returns
| static IFileReader<T> Avro.File.DataFileReader< T >.OpenReader |
( |
Stream |
inStream, |
|
|
Schema |
readerSchema, |
|
|
CreateDatumReader |
datumReaderFactory |
|
) |
| |
|
inlinestatic |
Open a reader for a stream using the reader's schema and a custom DatumReader
- Parameters
-
- Returns
| bool Avro.File.DataFileReader< T >.PastSync |
( |
long |
position | ) |
|
|
inline |
| long Avro.File.DataFileReader< T >.PreviousSync |
( |
| ) |
|
|
inline |
| void Avro.File.DataFileReader< T >.Seek |
( |
long |
position | ) |
|
|
inline |
Move to a specific, known synchronization point, one returned from IFileWriter.Sync() while writing
- Parameters
-
Implements Avro.File.IFileReader< T >.
| void Avro.File.DataFileReader< T >.Sync |
( |
long |
position | ) |
|
|
inline |
| long Avro.File.DataFileReader< T >.Tell |
( |
| ) |
|
|
inline |
The documentation for this class was generated from the following file:
- src/apache/main/File/DataFileReader.cs