Public Member Functions | |
bool | IsReservedMeta (string key) |
void | SetMeta (String key, byte[] value) |
Set meta data pair. | |
void | SetMeta (String key, long value) |
Set meta data pair (long value) | |
void | SetMeta (String key, string value) |
Set meta data pair (string value) | |
void | SetSyncInterval (int syncInterval) |
Set the synchronization interval for this file / stream, in bytes. Valid values range from 32 to 2^30. Suggested values are between 2K and 2M. | |
void | Append (T datum) |
Append datum to a file / stream. | |
void | Flush () |
Flush out any buffered data. | |
long | Sync () |
Forces the end of the current block, emitting a synchronization marker. | |
void | Close () |
Closes the file / stream. | |
void | Dispose () |
Static Public Member Functions | |
static IFileWriter< T > | OpenWriter (DatumWriter< T > writer, string path) |
Open a new writer instance to write to a file path, using a Null codec. | |
static IFileWriter< T > | OpenWriter (DatumWriter< T > writer, Stream outStream) |
Open a new writer instance to write to an output stream, using a Null codec. | |
static IFileWriter< T > | OpenWriter (DatumWriter< T > writer, string path, Codec codec) |
Open a new writer instance to write to a file path with a specified codec. | |
static IFileWriter< T > | OpenWriter (DatumWriter< T > writer, Stream outStream, Codec codec) |
Open a new writer instance to write to an output stream with a specified codec. |
void Avro.File.DataFileWriter< T >.Append | ( | T | datum | ) | [inline] |
void Avro.File.DataFileWriter< T >.Close | ( | ) | [inline] |
Closes the file / stream.
Implements Avro.File.IFileWriter< T >.
void Avro.File.DataFileWriter< T >.Flush | ( | ) | [inline] |
Flush out any buffered data.
Implements Avro.File.IFileWriter< T >.
bool Avro.File.DataFileWriter< T >.IsReservedMeta | ( | string | key | ) | [inline] |
Returns true if parameter is a reserved Avro meta data value
key |
Implements Avro.File.IFileWriter< T >.
static IFileWriter<T> Avro.File.DataFileWriter< T >.OpenWriter | ( | DatumWriter< T > | writer, |
string | path | ||
) | [inline, static] |
Open a new writer instance to write to a file path, using a Null codec.
writer | |
path |
static IFileWriter<T> Avro.File.DataFileWriter< T >.OpenWriter | ( | DatumWriter< T > | writer, |
Stream | outStream | ||
) | [inline, static] |
Open a new writer instance to write to an output stream, using a Null codec.
writer | |
outStream |
static IFileWriter<T> Avro.File.DataFileWriter< T >.OpenWriter | ( | DatumWriter< T > | writer, |
string | path, | ||
Codec | codec | ||
) | [inline, static] |
Open a new writer instance to write to a file path with a specified codec.
writer | |
path | |
codec |
static IFileWriter<T> Avro.File.DataFileWriter< T >.OpenWriter | ( | DatumWriter< T > | writer, |
Stream | outStream, | ||
Codec | codec | ||
) | [inline, static] |
Open a new writer instance to write to an output stream with a specified codec.
writer | |
outStream | |
codec |
void Avro.File.DataFileWriter< T >.SetMeta | ( | String | key, |
byte[] | value | ||
) | [inline] |
void Avro.File.DataFileWriter< T >.SetMeta | ( | String | key, |
long | value | ||
) | [inline] |
void Avro.File.DataFileWriter< T >.SetMeta | ( | String | key, |
string | value | ||
) | [inline] |
void Avro.File.DataFileWriter< T >.SetSyncInterval | ( | int | syncInterval | ) | [inline] |
Set the synchronization interval for this file / stream, in bytes. Valid values range from 32 to 2^30. Suggested values are between 2K and 2M.
syncInterval |
Implements Avro.File.IFileWriter< T >.
long Avro.File.DataFileWriter< T >.Sync | ( | ) | [inline] |
Forces the end of the current block, emitting a synchronization marker.
Implements Avro.File.IFileWriter< T >.