container

Nov 21, 2019

Changes in this version

type Writer

+ func (avroWriter *Writer) BlockBufferSize() int

Jun 12, 2019

Changes in this version

+ var LoggingEnabled = false

+ 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 Reader struct

+ func NewReader(r io.Reader) (*Reader, error)

+ func (r *Reader) AvroContainerSchema() []byte

+ func (r *Reader) Read(b []byte) (n int, err error)

+ 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