block

Aug 1, 2023

Changes in this version

type Block

+ func FromRequestWithTable(request *talaria.IngestWithTableRequest, partitionBy string, ...) ([]Block, error)

Jun 7, 2022

Changes in this version

type Block

+ func Base() ([]Block, error)

type Row

+ func FromBlockBy(blk Block, schema typeof.Schema) ([]Row, error)

Mar 31, 2021

Changes in this version

type Block

+ func FromParquetBy(payload []byte, partitionBy string, filter *typeof.Schema, apply applyFunc) ([]Block, error)

Mar 17, 2021

Changes in this version

+ func Transform(filter *typeof.Schema, computed ...column.Computed) applyFunc

+ type Row struct

+ Schema typeof.Schema

+ Values map[string]interface{}

+ func NewRow(schema typeof.Schema, capacity int) Row

+ func (r Row) AppendTo(cols column.Columns) (size int)

+ func (r Row) Set(k string, v interface{})

Apr 20, 2020

Changes in this version

type Block

+ func FromCSVBy(input []byte, partitionBy string, filter *typeof.Schema, ...) ([]Block, error)

+ func FromURLBy(uri string, partitionBy string, filter *typeof.Schema, ...) ([]Block, error)

Apr 14, 2020

Changes in this version

+ func Read(buffer []byte, desiredSchema typeof.Schema) (column.Columns, error)

+ type Block struct

+ Columns nocopy.ByteMap

+ Data nocopy.Bytes

+ Expires int64

+ Key nocopy.String

+ Size int64

+ func FromBatchBy(batch *talaria.Batch, partitionBy string, filter *typeof.Schema, ...) ([]Block, error)

+ func FromBuffer(b []byte) (block Block, err error)

+ func FromColumns(key string, columns column.Columns) (blk Block, err error)

+ func FromOrcBy(payload []byte, partitionBy string, filter *typeof.Schema, ...) ([]Block, error)

+ func FromRequestBy(request *talaria.IngestRequest, partitionBy string, filter *typeof.Schema, ...) ([]Block, error)

+ func (b *Block) Encode() ([]byte, error)

+ func (b *Block) LastRow() (map[string]interface{}, error)

+ func (b *Block) Min(column string) (int64, bool)

+ func (b *Block) Schema() typeof.Schema

+ func (b *Block) Select(columns typeof.Schema) (column.Columns, error)