container

Oct 31, 2017

Changes in this version

+ type AvroRecord interface

+ Schema func() string

+ Serialize func(io.Writer) error

+ type CloseableResettableWriter interface

+ Close func() error

+ Reset func(io.Writer)

+ type Codec string

+ const Deflate

+ const Null

+ const Snappy

+ type Writer struct

+ func NewWriter(writer io.Writer, codec Codec, recordsPerBlock int64, schema string) (*Writer, error)

+ func (avroWriter *Writer) Flush() error

+ func (avroWriter *Writer) WriteRecord(record AvroRecord) error