|
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