Documentation ¶
Index ¶
- Constants
- func BlockRead(ctx context.Context, info *pkgcatalog.BlockInfo, columns []string, ...) (*batch.Batch, error)
- func BlockReadInner(ctx context.Context, info *pkgcatalog.BlockInfo, schemaColCnt int, ...) (*containers.Batch, error)
- func DecodeCheckpointMetadataFileName(name string) (start, end types.TS)
- func DecodeGCMetadataFileName(name string) (start, end types.TS, ext string)
- func DecodeMetaLoc(metaLoc string) (string, objectio.Extent, uint32)
- func DecodeMetaLocToMetas(metaLoc string) (string, []objectio.Extent, error)
- func EncodeCheckpointMetadataFileName(dir, prefix string, start, end types.TS) string
- func EncodeGCMetadataFileName(dir, prefix string, start, end types.TS) string
- func EncodeMetaLocWithObject(extent objectio.Extent, rows uint32, blocks []objectio.BlockObject) (string, error)
- func EncodeMetalocFromMetas(name string, blks []objectio.BlockObject) string
- func EncodeObjectName() (name string)
- func GetObjectSizeWithBlocks(blocks []objectio.BlockObject) (uint32, error)
- type Delta
- type Meta
- type Reader
- func (r *Reader) BlkColumnByMetaLoadJob(colTypes []types.Type, colNames []string, nullables []bool, ...) *tasks.Job
- func (r *Reader) BlkColumnsByMetaAndIdxLoadJob(colTypes []types.Type, colNames []string, nullables []bool, ...) *tasks.Job
- func (r *Reader) GetDataObject(idx uint16, m *mpool.MPool) objectio.ColumnObject
- func (r *Reader) LoadBlkColumnsByMeta(colTypes []types.Type, colNames []string, nullables []bool, ...) (*containers.Batch, error)
- func (r *Reader) LoadBlkColumnsByMetaAndIdx(colTypes []types.Type, colNames []string, nullables []bool, ...) (*containers.Batch, error)
- func (r *Reader) ReadMeta(m *mpool.MPool) (objectio.BlockObject, error)
- func (r *Reader) ReadMetas(m *mpool.MPool) ([]objectio.BlockObject, error)
- type Writer
- func (w *Writer) GetWriter() objectio.Writer
- func (w *Writer) Sync() ([]objectio.BlockObject, error)
- func (w *Writer) WriteBlock(columns *containers.Batch) (block objectio.BlockObject, err error)
- func (w *Writer) WriteBlockAndZoneMap(batch *batch.Batch, idxs []uint16) (objectio.BlockObject, error)
- func (w *Writer) WriteIndex(block objectio.BlockObject, index objectio.IndexData) (err error)
Constants ¶
View Source
const ( CheckpointExt = "ckp" GCFullExt = "fgc" )
Variables ¶
This section is empty.
Functions ¶
func BlockRead ¶
func BlockRead( ctx context.Context, info *pkgcatalog.BlockInfo, columns []string, colIdxs []uint16, colTypes []types.Type, colNulls []bool, tableDef *plan.TableDef, ts timestamp.Timestamp, fs fileservice.FileService, pool *mpool.MPool) (*batch.Batch, error)
BlockRead read block data from storage and apply deletes according given timestamp. Caller make sure metaloc is not empty
func BlockReadInner ¶
func BlockReadInner( ctx context.Context, info *pkgcatalog.BlockInfo, schemaColCnt int, colNames []string, colIdxs []uint16, colTyps []types.Type, colNulls []bool, ts types.TS, fs fileservice.FileService, pool *mpool.MPool) (*containers.Batch, error)
func DecodeGCMetadataFileName ¶ added in v0.7.0
func DecodeMetaLocToMetas ¶
func EncodeGCMetadataFileName ¶ added in v0.7.0
func EncodeMetaLocWithObject ¶
func EncodeMetaLocWithObject( extent objectio.Extent, rows uint32, blocks []objectio.BlockObject) (string, error)
EncodeMetaLocWithObject Generate a metaloc from an object file
func EncodeMetalocFromMetas ¶
func EncodeMetalocFromMetas(name string, blks []objectio.BlockObject) string
func EncodeObjectName ¶
func EncodeObjectName() (name string)
EncodeObjectName Generate uuid as the file name of the block&segment
func GetObjectSizeWithBlocks ¶
func GetObjectSizeWithBlocks(blocks []objectio.BlockObject) (uint32, error)
Types ¶
type Delta ¶
type Delta struct {
// contains filtered or unexported fields
}
func DecodeDeltaLocToDelta ¶
func (*Delta) GetObjectSize ¶
type Meta ¶
type Meta struct {
// contains filtered or unexported fields
}
func DecodeMetaLocToMeta ¶
func (*Meta) GetObjectSize ¶
type Reader ¶
type Reader struct {
// contains filtered or unexported fields
}
func NewCheckpointReader ¶
func NewCheckpointReader(cxt context.Context, fs fileservice.FileService, key string) (*Reader, error)
func (*Reader) BlkColumnByMetaLoadJob ¶ added in v0.7.0
func (*Reader) BlkColumnsByMetaAndIdxLoadJob ¶ added in v0.7.0
func (*Reader) GetDataObject ¶
func (*Reader) LoadBlkColumnsByMeta ¶
func (r *Reader) LoadBlkColumnsByMeta( colTypes []types.Type, colNames []string, nullables []bool, block objectio.BlockObject) (*containers.Batch, error)
func (*Reader) LoadBlkColumnsByMetaAndIdx ¶
type Writer ¶
type Writer struct {
// contains filtered or unexported fields
}
func (*Writer) WriteBlock ¶
func (w *Writer) WriteBlock(columns *containers.Batch) (block objectio.BlockObject, err error)
func (*Writer) WriteBlockAndZoneMap ¶ added in v0.7.0
func (*Writer) WriteIndex ¶
Click to show internal directories.
Click to hide internal directories.