Documentation ¶
Index ¶
- func NewDemoSchemaWriter(writer io.Writer, codec container.Codec, recordsPerBlock int64) (*container.Writer, error)
- type ByteWriter
- type DemoSchema
- func (_ *DemoSchema) AppendArray() types.Field
- func (_ *DemoSchema) AppendMap(key string) types.Field
- func (_ *DemoSchema) Finalize()
- func (r *DemoSchema) Get(i int) types.Field
- func (r *DemoSchema) Schema() string
- func (r *DemoSchema) Serialize(w io.Writer) error
- func (_ *DemoSchema) SetBoolean(v bool)
- func (_ *DemoSchema) SetBytes(v []byte)
- func (_ *DemoSchema) SetDouble(v float64)
- func (_ *DemoSchema) SetFloat(v float32)
- func (_ *DemoSchema) SetInt(v int32)
- func (_ *DemoSchema) SetLong(v int64)
- func (_ *DemoSchema) SetString(v string)
- func (_ *DemoSchema) SetUnionElem(v int64)
- type DemoSchemaReader
- type StringWriter
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type ByteWriter ¶
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) Finalize ¶
func (_ *DemoSchema) Finalize()
func (*DemoSchema) Schema ¶
func (r *DemoSchema) Schema() string
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 ¶
Click to show internal directories.
Click to hide internal directories.