Versions in this module Expand all Collapse all v10 v10.5.0-mm May 3, 2023 v10.2.1-mm Apr 27, 2023 v10.0.1 Apr 27, 2023 v10.0.0 Apr 27, 2023 Changes in this version + const UnionRecordAvroCRC64Fingerprint + func NewUnionRecordWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error) + type UnionNullInt struct + Int int32 + Null *types.NullVal + UnionType UnionNullIntTypeEnum + func DeserializeUnionNullInt(r io.Reader) (*UnionNullInt, error) + func DeserializeUnionNullIntFromSchema(r io.Reader, schema string) (*UnionNullInt, error) + func NewUnionNullInt() *UnionNullInt + func (_ *UnionNullInt) AppendArray() types.Field + func (_ *UnionNullInt) AppendMap(key string) types.Field + func (_ *UnionNullInt) Finalize() + func (_ *UnionNullInt) HintSize(i int) + func (_ *UnionNullInt) NullField(i int) + func (_ *UnionNullInt) SetBoolean(v bool) + func (_ *UnionNullInt) SetBytes(v []byte) + func (_ *UnionNullInt) SetDefault(i int) + func (_ *UnionNullInt) SetDouble(v float64) + func (_ *UnionNullInt) SetFloat(v float32) + func (_ *UnionNullInt) SetInt(v int32) + func (_ *UnionNullInt) SetString(v string) + func (r *UnionNullInt) Get(i int) types.Field + func (r *UnionNullInt) MarshalJSON() ([]byte, error) + func (r *UnionNullInt) Schema() string + func (r *UnionNullInt) Serialize(w io.Writer) error + func (r *UnionNullInt) SetLong(v int64) + func (r *UnionNullInt) UnmarshalJSON(data []byte) error + type UnionNullIntTypeEnum int + const UnionNullIntTypeEnumInt + type UnionNullString struct + Null *types.NullVal + String string + UnionType UnionNullStringTypeEnum + func DeserializeUnionNullString(r io.Reader) (*UnionNullString, error) + func DeserializeUnionNullStringFromSchema(r io.Reader, schema string) (*UnionNullString, error) + func NewUnionNullString() *UnionNullString + func (_ *UnionNullString) AppendArray() types.Field + func (_ *UnionNullString) AppendMap(key string) types.Field + func (_ *UnionNullString) Finalize() + func (_ *UnionNullString) HintSize(i int) + func (_ *UnionNullString) NullField(i int) + func (_ *UnionNullString) SetBoolean(v bool) + func (_ *UnionNullString) SetBytes(v []byte) + func (_ *UnionNullString) SetDefault(i int) + func (_ *UnionNullString) SetDouble(v float64) + func (_ *UnionNullString) SetFloat(v float32) + func (_ *UnionNullString) SetInt(v int32) + func (_ *UnionNullString) SetString(v string) + func (r *UnionNullString) Get(i int) types.Field + func (r *UnionNullString) MarshalJSON() ([]byte, error) + func (r *UnionNullString) Schema() string + func (r *UnionNullString) Serialize(w io.Writer) error + func (r *UnionNullString) SetLong(v int64) + func (r *UnionNullString) UnmarshalJSON(data []byte) error + type UnionNullStringTypeEnum int + const UnionNullStringTypeEnumString + type UnionRecord struct + A string + Id *UnionNullInt + Name *UnionNullString + func DeserializeUnionRecord(r io.Reader) (UnionRecord, error) + func DeserializeUnionRecordFromSchema(r io.Reader, schema string) (UnionRecord, error) + func NewUnionRecord() UnionRecord + func (_ UnionRecord) AppendArray() types.Field + func (_ UnionRecord) AppendMap(key string) types.Field + func (_ UnionRecord) AvroCRC64Fingerprint() []byte + func (_ UnionRecord) Finalize() + func (_ UnionRecord) HintSize(int) + func (_ UnionRecord) SetBoolean(v bool) + func (_ UnionRecord) SetBytes(v []byte) + func (_ UnionRecord) SetDouble(v float64) + func (_ UnionRecord) SetFloat(v float32) + func (_ UnionRecord) SetInt(v int32) + func (_ UnionRecord) SetLong(v int64) + func (_ UnionRecord) SetString(v string) + func (_ UnionRecord) SetUnionElem(v int64) + func (r *UnionRecord) Get(i int) types.Field + func (r *UnionRecord) NullField(i int) + func (r *UnionRecord) SetDefault(i int) + func (r *UnionRecord) UnmarshalJSON(data []byte) error + func (r UnionRecord) MarshalJSON() ([]byte, error) + func (r UnionRecord) Schema() string + func (r UnionRecord) SchemaName() string + func (r UnionRecord) Serialize(w io.Writer) error + type UnionRecordReader struct + func NewUnionRecordReader(r io.Reader) (*UnionRecordReader, error) + func (r UnionRecordReader) Read() (UnionRecord, error)
Go to main page