avro

package
v6.1.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jul 13, 2019 License: MIT Imports: 6 Imported by: 55

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewDemoSchemaWriter

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

Types

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) AppendArray

func (_ *DemoSchema) AppendArray() types.Field

func (*DemoSchema) AppendMap

func (_ *DemoSchema) AppendMap(key string) types.Field

func (*DemoSchema) Finalize

func (_ *DemoSchema) Finalize()

func (*DemoSchema) Get

func (r *DemoSchema) Get(i int) types.Field

func (*DemoSchema) Schema

func (r *DemoSchema) Schema() string

func (*DemoSchema) Serialize

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

func (*DemoSchema) SetBoolean

func (_ *DemoSchema) SetBoolean(v bool)

func (*DemoSchema) SetBytes

func (_ *DemoSchema) SetBytes(v []byte)

func (*DemoSchema) SetDouble

func (_ *DemoSchema) SetDouble(v float64)

func (*DemoSchema) SetFloat

func (_ *DemoSchema) SetFloat(v float32)

func (*DemoSchema) SetInt

func (_ *DemoSchema) SetInt(v int32)

func (*DemoSchema) SetLong

func (_ *DemoSchema) SetLong(v int64)

func (*DemoSchema) SetString

func (_ *DemoSchema) SetString(v string)

func (*DemoSchema) SetUnionElem

func (_ *DemoSchema) SetUnionElem(v int64)

type DemoSchemaReader

type DemoSchemaReader struct {
	// contains filtered or unexported fields
}

func NewDemoSchemaReader

func NewDemoSchemaReader(r io.Reader) (*DemoSchemaReader, error)

func (*DemoSchemaReader) Read

func (r *DemoSchemaReader) Read() (*DemoSchema, error)

type StringWriter

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL