rowcodec

package

v0.0.0-...-1338f1b Latest Latest Go to latest Published: Mar 15, 2024 License: Apache-2.0 Imports: 14 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pingcap-incubator/tinykv

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func IsRowKey(key []byte) bool
func IsRowKeyWithShardByte(key []byte) bool
type Decoder
- func NewDecoder(requestColIDs []int64, handleColID int64, tps []*types.FieldType, ...) (*Decoder, error)
type Encoder

Constants ¶

View Source

const (
	NilFlag          byte = 0
	BytesFlag        byte = 1
	CompactBytesFlag byte = 2
	IntFlag          byte = 3
	UintFlag         byte = 4
	VarintFlag       byte = 8
	VaruintFlag      byte = 9
)

First byte in the encoded value which specifies the encoding type.

View Source

const CodecVer = 128

CodecVer is the constant number that represent the new row format.

Variables ¶

This section is empty.

Functions ¶

func IsRowKey ¶

func IsRowKey(key []byte) bool

func IsRowKeyWithShardByte ¶

func IsRowKeyWithShardByte(key []byte) bool

Types ¶

func NewDecoder ¶

func NewDecoder(requestColIDs []int64, handleColID int64, tps []*types.FieldType, origDefaults [][]byte,
	loc *time.Location) (*Decoder, error)

NewDecoder creates a NewDecoder. requestColIDs is the columnIDs to decode. tps is the field types for request columns. origDefault is the original default value in old format, if the column ID is not found in the row, the origDefault will be used.

func (*Decoder) ColumnIsNull ¶

func (decoder *Decoder) ColumnIsNull(rowData []byte, colID int64, defaultVal []byte) (bool, error)

ColumnIsNull returns if the column value is null. Mainly used for count column aggregation.

func (*Decoder) Decode ¶

func (decoder *Decoder) Decode(rowData []byte, handle int64, chk *chunk.Chunk) error

Decode decodes a row to chunk.

func (Decoder) String ¶

func (r Decoder) String() string

String implements the strings.Stringer interface.

type Encoder ¶

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

Encoder is used to encode a row.

func (*Encoder) Encode ¶

func (encoder *Encoder) Encode(colIDs []int64, values []types.Datum, buf []byte) ([]byte, error)

Encode encodes a row from a datums slice.

func (*Encoder) EncodeFromOldRow ¶

func (encoder *Encoder) EncodeFromOldRow(oldRow, buf []byte) ([]byte, error)

EncodeFromOldRow encodes a row from an old-format row.

func (Encoder) String ¶

func (r Encoder) String() string