avro

Documentation

Index

• func NewDemoSchemaWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type ByteReader
• type ByteWriter
• type DemoSchema
  • func DeserializeDemoSchema(r io.Reader) (*DemoSchema, error)
  • func NewDemoSchema() *DemoSchema
  • func (r *DemoSchema) Schema() string
  • func (r *DemoSchema) Serialize(w io.Writer) error
• type StringWriter

Functions

func NewDemoSchemaWriter

func NewDemoSchemaWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)

Types

type ByteReader

type ByteReader interface {
	ReadByte() (byte, error)
}

type ByteWriter

type ByteWriter interface {
	Grow(int)
	WriteByte(byte) error
}

type DemoSchema

type DemoSchema struct {
	IntField    int32
	DoubleField float64
	StringField string
	BoolField   bool
	BytesField  []byte
}

func DeserializeDemoSchema

func DeserializeDemoSchema(r io.Reader) (*DemoSchema, error)

func NewDemoSchema

func NewDemoSchema() *DemoSchema

func (*DemoSchema) Schema

func (r *DemoSchema) Schema() string

func (*DemoSchema) Serialize

func (r *DemoSchema) Serialize(w io.Writer) error

type StringWriter

type StringWriter interface {
	WriteString(string) (int, error)
}