avro

Documentation

Overview

Code generated by Skaidus. DO NOT EDIT.

• SOURCES:
• parent.avsc
• child.avsc

Code generated by Skaidus. DO NOT EDIT.

• SOURCES:
• parent.avsc
• child.avsc

Code generated by Skaidus. DO NOT EDIT.

• SOURCES:
• parent.avsc
• child.avsc

Code generated by Skaidus. DO NOT EDIT.

• SOURCES:
• parent.avsc
• child.avsc

Code generated by Skaidus. DO NOT EDIT.

• SOURCES:
• parent.avsc
• child.avsc

Index

• Constants
• func NewChildWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• func NewParentWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
• type ArrayChildWrapper
  • func (r ArrayChildWrapper) AppendArray() types.Field
  • func (_ ArrayChildWrapper) AppendMap(key string) types.Field
  • func (_ ArrayChildWrapper) Finalize()
  • func (_ ArrayChildWrapper) Get(i int) types.Field
  • func (r ArrayChildWrapper) HintSize(s int)
  • func (r ArrayChildWrapper) NullField(i int)
  • func (_ ArrayChildWrapper) SetBoolean(v bool)
  • func (_ ArrayChildWrapper) SetBytes(v []byte)
  • func (_ ArrayChildWrapper) SetDefault(i int)
  • func (_ ArrayChildWrapper) SetDouble(v float64)
  • func (_ ArrayChildWrapper) SetFloat(v float32)
  • func (_ ArrayChildWrapper) SetInt(v int32)
  • func (_ ArrayChildWrapper) SetLong(v int64)
  • func (_ ArrayChildWrapper) SetString(v string)
  • func (_ ArrayChildWrapper) SetUnionElem(v int64)
• type Child
  • func DeserializeChild(r io.Reader) (Child, error)
  • func DeserializeChildFromSchema(r io.Reader, schema string) (Child, error)
  • func NewChild() Child
  • func (_ Child) AppendArray() types.Field
  • func (_ Child) AppendMap(key string) types.Field
  • func (_ Child) AvroCRC64Fingerprint() []byte
  • func (_ Child) Finalize()
  • func (r *Child) Get(i int) types.Field
  • func (_ Child) HintSize(int)
  • func (r Child) MarshalJSON() ([]byte, error)
  • func (r *Child) NullField(i int)
  • func (r Child) Schema() string
  • func (r Child) SchemaName() string
  • func (r Child) Serialize(w io.Writer) error
  • func (_ Child) SetBoolean(v bool)
  • func (_ Child) SetBytes(v []byte)
  • func (r *Child) SetDefault(i int)
  • func (_ Child) SetDouble(v float64)
  • func (_ Child) SetFloat(v float32)
  • func (_ Child) SetInt(v int32)
  • func (_ Child) SetLong(v int64)
  • func (_ Child) SetString(v string)
  • func (_ Child) SetUnionElem(v int64)
  • func (r *Child) UnmarshalJSON(data []byte) error
• type ChildReader
  • func NewChildReader(r io.Reader) (*ChildReader, error)
  • func (r ChildReader) Read() (Child, error)
• type Parent
  • func DeserializeParent(r io.Reader) (Parent, error)
  • func DeserializeParentFromSchema(r io.Reader, schema string) (Parent, error)
  • func NewParent() Parent
  • func (_ Parent) AppendArray() types.Field
  • func (_ Parent) AppendMap(key string) types.Field
  • func (_ Parent) AvroCRC64Fingerprint() []byte
  • func (_ Parent) Finalize()
  • func (r *Parent) Get(i int) types.Field
  • func (_ Parent) HintSize(int)
  • func (r Parent) MarshalJSON() ([]byte, error)
  • func (r *Parent) NullField(i int)
  • func (r Parent) Schema() string
  • func (r Parent) SchemaName() string
  • func (r Parent) Serialize(w io.Writer) error
  • func (_ Parent) SetBoolean(v bool)
  • func (_ Parent) SetBytes(v []byte)
  • func (r *Parent) SetDefault(i int)
  • func (_ Parent) SetDouble(v float64)
  • func (_ Parent) SetFloat(v float32)
  • func (_ Parent) SetInt(v int32)
  • func (_ Parent) SetLong(v int64)
  • func (_ Parent) SetString(v string)
  • func (_ Parent) SetUnionElem(v int64)
  • func (r *Parent) UnmarshalJSON(data []byte) error
• type ParentReader
  • func NewParentReader(r io.Reader) (*ParentReader, error)
  • func (r ParentReader) Read() (Parent, error)

Constants

const ChildAvroCRC64Fingerprint = "\x9c\xc0\xb2WF֤\xff"

const ParentAvroCRC64Fingerprint = "T\x88\xc0l-\xc3?\xca"

Functions

func NewChildWriter

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

func NewParentWriter

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

Types

type ArrayChildWrapper

type ArrayChildWrapper struct {
	Target *[]Child
}

func (ArrayChildWrapper) AppendArray

func (r ArrayChildWrapper) AppendArray() types.Field

func (ArrayChildWrapper) AppendMap

func (_ ArrayChildWrapper) AppendMap(key string) types.Field

func (ArrayChildWrapper) Finalize

func (_ ArrayChildWrapper) Finalize()

func (ArrayChildWrapper) Get

func (_ ArrayChildWrapper) Get(i int) types.Field

func (ArrayChildWrapper) HintSize

func (r ArrayChildWrapper) HintSize(s int)

func (ArrayChildWrapper) NullField

func (r ArrayChildWrapper) NullField(i int)

func (ArrayChildWrapper) SetBoolean

func (_ ArrayChildWrapper) SetBoolean(v bool)

func (ArrayChildWrapper) SetBytes

func (_ ArrayChildWrapper) SetBytes(v []byte)

func (ArrayChildWrapper) SetDefault

func (_ ArrayChildWrapper) SetDefault(i int)

func (ArrayChildWrapper) SetDouble

func (_ ArrayChildWrapper) SetDouble(v float64)

func (ArrayChildWrapper) SetFloat

func (_ ArrayChildWrapper) SetFloat(v float32)

func (ArrayChildWrapper) SetInt

func (_ ArrayChildWrapper) SetInt(v int32)

func (ArrayChildWrapper) SetLong

func (_ ArrayChildWrapper) SetLong(v int64)

func (ArrayChildWrapper) SetString

func (_ ArrayChildWrapper) SetString(v string)

func (ArrayChildWrapper) SetUnionElem

func (_ ArrayChildWrapper) SetUnionElem(v int64)

type Child

type Child struct {
	Name string `json:"name"`
}

func DeserializeChild

func DeserializeChild(r io.Reader) (Child, error)

func DeserializeChildFromSchema

func DeserializeChildFromSchema(r io.Reader, schema string) (Child, error)

func NewChild

func NewChild() Child

func (Child) AppendArray

func (_ Child) AppendArray() types.Field

func (Child) AppendMap

func (_ Child) AppendMap(key string) types.Field

func (Child) AvroCRC64Fingerprint

func (_ Child) AvroCRC64Fingerprint() []byte

func (Child) Finalize

func (_ Child) Finalize()

func (*Child) Get

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

func (Child) HintSize

func (_ Child) HintSize(int)

func (Child) MarshalJSON

func (r Child) MarshalJSON() ([]byte, error)

func (*Child) NullField

func (r *Child) NullField(i int)

func (Child) Schema

func (r Child) Schema() string

func (Child) SchemaName

func (r Child) SchemaName() string

func (Child) Serialize

func (r Child) Serialize(w io.Writer) error

func (Child) SetBoolean

func (_ Child) SetBoolean(v bool)

func (Child) SetBytes

func (_ Child) SetBytes(v []byte)

func (*Child) SetDefault

func (r *Child) SetDefault(i int)

func (Child) SetDouble

func (_ Child) SetDouble(v float64)

func (Child) SetFloat

func (_ Child) SetFloat(v float32)

func (Child) SetInt

func (_ Child) SetInt(v int32)

func (Child) SetLong

func (_ Child) SetLong(v int64)

func (Child) SetString

func (_ Child) SetString(v string)

func (Child) SetUnionElem

func (_ Child) SetUnionElem(v int64)

func (*Child) UnmarshalJSON

func (r *Child) UnmarshalJSON(data []byte) error

type ChildReader

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

container reader

func NewChildReader

func NewChildReader(r io.Reader) (*ChildReader, error)

func (ChildReader) Read

func (r ChildReader) Read() (Child, error)

type Parent

type Parent struct {
	Children []Child `json:"Children"`
}

func DeserializeParent

func DeserializeParent(r io.Reader) (Parent, error)

func DeserializeParentFromSchema

func DeserializeParentFromSchema(r io.Reader, schema string) (Parent, error)

func NewParent

func NewParent() Parent

func (Parent) AppendArray

func (_ Parent) AppendArray() types.Field

func (Parent) AppendMap

func (_ Parent) AppendMap(key string) types.Field

func (Parent) AvroCRC64Fingerprint

func (_ Parent) AvroCRC64Fingerprint() []byte

func (Parent) Finalize

func (_ Parent) Finalize()

func (*Parent) Get

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

func (Parent) HintSize

func (_ Parent) HintSize(int)

func (Parent) MarshalJSON

func (r Parent) MarshalJSON() ([]byte, error)

func (*Parent) NullField

func (r *Parent) NullField(i int)

func (Parent) Schema

func (r Parent) Schema() string

func (Parent) SchemaName

func (r Parent) SchemaName() string

func (Parent) Serialize

func (r Parent) Serialize(w io.Writer) error

func (Parent) SetBoolean

func (_ Parent) SetBoolean(v bool)

func (Parent) SetBytes

func (_ Parent) SetBytes(v []byte)

func (*Parent) SetDefault

func (r *Parent) SetDefault(i int)

func (Parent) SetDouble

func (_ Parent) SetDouble(v float64)

func (Parent) SetFloat

func (_ Parent) SetFloat(v float32)

func (Parent) SetInt

func (_ Parent) SetInt(v int32)

func (Parent) SetLong

func (_ Parent) SetLong(v int64)

func (Parent) SetString

func (_ Parent) SetString(v string)

func (Parent) SetUnionElem

func (_ Parent) SetUnionElem(v int64)

func (*Parent) UnmarshalJSON

func (r *Parent) UnmarshalJSON(data []byte) error

type ParentReader

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

container reader

func NewParentReader

func NewParentReader(r io.Reader) (*ParentReader, error)

func (ParentReader) Read

func (r ParentReader) Read() (Parent, error)