package coderx

import "github.com/apache/beam/sdks/go/pkg/beam/core/runtime/coderx"

Package coderx contains coders for primitive types that aren't included in the beam model.

Index ¶

• Variables
• func NewFloat(t reflect.Type) (*coder.CustomCoder, error)
• func NewString() (*coder.CustomCoder, error)
• func NewVarIntZ(t reflect.Type) (*coder.CustomCoder, error)
• func NewVarUintZ(t reflect.Type) (*coder.CustomCoder, error)

Package Files ¶

coderx.shims.go doc.go float.go int.go string.go varint.go

Variables ¶

var (
    Uint32 *coder.CustomCoder
    Int32  *coder.CustomCoder
    Uint64 *coder.CustomCoder
    Int64  *coder.CustomCoder
)

Fixed-sized custom coders for integers.

func NewFloat ¶ Uses

func NewFloat(t reflect.Type) (*coder.CustomCoder, error)

NewFloat returns a coder for the given float type. It uses the same encoding scheme as the gob package.

func NewString ¶ Uses

func NewString() (*coder.CustomCoder, error)

NewString returns a coder for the string type. It uses the native []byte to string conversion.

Only for custom coder test use.

func NewVarIntZ ¶ Uses

func NewVarIntZ(t reflect.Type) (*coder.CustomCoder, error)

NewVarIntZ returns a varint coder for the given integer type. It uses a zig-zag scheme, which is _different_ from the Beam standard coding scheme.

func NewVarUintZ ¶ Uses

func NewVarUintZ(t reflect.Type) (*coder.CustomCoder, error)

NewVarUintZ returns a uvarint coder for the given integer type. It uses a zig-zag scheme, which is _different_ from the Beam standard coding scheme.