Versions in this module Expand all Collapse all v10 v10.5.0 Aug 4, 2022 v10.4.0 Aug 3, 2022 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) BlockBufferSize() int + func (avroWriter *Writer) Flush() error + func (avroWriter *Writer) WriteRecord(record AvroRecord) error
Go to main page