dataio

package
v0.4.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 5, 2022 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source 
const Version uint64 = 1

Variables

View Source 
var (
	ErrDupBlk = errors.New("duplicate blk")
	ErrDupSeg = errors.New("duplicate seg")
)
View Source 
var (
	ErrFileNotExist = errors.New("file not exist")
)

Functions

func CopyFile 

func CopyFile(src, dest string) (int64, error)

func CopyFromReader 

func CopyFromReader(r io.Reader, dest string) (int64, error)

func MakeTblockFileName 

func MakeTblockFileName(dir, tag string, count uint64, id common.ID, tmp bool) string

func NewMockSegmentFile 

func NewMockSegmentFile(dirname string, ft FileType, id common.ID) base.ISegmentFile

func NewSortedSegmentFile 

func NewSortedSegmentFile(dirname string, id common.ID) base.ISegmentFile

func NewUnsortedSegmentFile 

func NewUnsortedSegmentFile(dirname string, id common.ID) base.ISegmentFile

func ParseLogIndex 

func ParseLogIndex(str string) (index *metadata.LogIndex)

func ParseTBlockfileName 

func ParseTBlockfileName(name string) (count uint64, tag string, id common.ID, err error)

Types

type BlockFile 

type BlockFile struct {
	common.RefHelper
	os.File
	ID          common.ID
	Parts       map[base.Key]*base.Pointer
	Meta        *FileMeta
	SegmentFile base.ISegmentFile
	Info        common.FileInfo
	DataAlgo    int
	Idx         *metadata.LogIndex
	PrevIdx     *metadata.LogIndex
	Range       *metadata.LogRange
	Count       uint64
}

BlockFile file structure: algo | colCntlen | metaCnt | preIdxLen | preIdx | IdxLen | Idx col01 : coldata len | coldata originlen | col02 : coldata len | coldata originlen | ... col01 data | col02 data | ...

func NewBlockFile 

func NewBlockFile(segFile base.ISegmentFile, id common.ID, nameFactory FileNameFactory) *BlockFile

func (*BlockFile) CopyTo 

func (bf *BlockFile) CopyTo(dir string) error

func (*BlockFile) DataCompressAlgo 

func (bf *BlockFile) DataCompressAlgo(id common.ID) int

func (*BlockFile) Destroy 

func (bf *BlockFile) Destroy()

func (*BlockFile) GetDir 

func (bf *BlockFile) GetDir() string

func (*BlockFile) GetFileType 

func (bf *BlockFile) GetFileType() common.FileType

func (*BlockFile) GetIndicesMeta 

func (bf *BlockFile) GetIndicesMeta() *base.IndicesMeta

func (*BlockFile) LinkTo 

func (bf *BlockFile) LinkTo(dir string) error

func (*BlockFile) MakeVirtualIndexFile 

func (bf *BlockFile) MakeVirtualIndexFile(meta *base.IndexMeta) common.IVFile

func (*BlockFile) PartSize 

func (bf *BlockFile) PartSize(colIdx uint64, id common.ID, isOrigin bool) int64

func (*BlockFile) PrefetchPart 

func (bf *BlockFile) PrefetchPart(colIdx uint64, id common.ID) error

func (*BlockFile) ReadPart 

func (bf *BlockFile) ReadPart(colIdx uint64, id common.ID, buf []byte)

func (*BlockFile) ReadPoint 

func (bf *BlockFile) ReadPoint(ptr *base.Pointer, buf []byte)

func (*BlockFile) Stat 

func (bf *BlockFile) Stat() common.FileInfo

type BlockWriter 

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

BlockWriter writes memTable data into the created block file when memTable flush()

func NewBlockWriter 

func NewBlockWriter(data []*gvector.Vector, meta *metadata.Block, dir string) *BlockWriter

NewBlockWriter make a BlockWriter, which will be used when the memtable is full.

func NewIBatchWriter 

func NewIBatchWriter(bat batch.IBatch, meta *metadata.Block, dir string) *BlockWriter

NewIBatchWriter make a BlockWriter, which will be used when the memtable is not full but needs to be flush()

func (*BlockWriter) Execute 

func (bw *BlockWriter) Execute() error

func (*BlockWriter) GetFileName 

func (bw *BlockWriter) GetFileName() string

func (*BlockWriter) GetSize 

func (bw *BlockWriter) GetSize() int64

func (*BlockWriter) SetDataFlusher 

func (bw *BlockWriter) SetDataFlusher(f vecsSerializer)

func (*BlockWriter) SetFileGetter 

func (bw *BlockWriter) SetFileGetter(f func(string, *metadata.Block) (*os.File, error))

func (*BlockWriter) SetIndexFlusher 

func (bw *BlockWriter) SetIndexFlusher(f vecsIndexSerializer)

func (*BlockWriter) SetPostExecutor 

func (bw *BlockWriter) SetPostExecutor(f func())

func (*BlockWriter) SetPreExecutor 

func (bw *BlockWriter) SetPreExecutor(f func())

type ColPartFile 

type ColPartFile struct {

	// SegmentFile is UnsortedSegmentFile or SortedSegmentFile
	SegmentFile base.ISegmentFile

	// ID is block id
	ID *common.ID

	// Info is block fileinfo
	Info common.FileInfo
}

ColPartFile is a Reader instance of columnData in block, which provides external read services

func (*ColPartFile) GetFileType 

func (cpf *ColPartFile) GetFileType() common.FileType

func (*ColPartFile) Name 

func (cpf *ColPartFile) Name() string

func (*ColPartFile) Read 

func (cpf *ColPartFile) Read(buf []byte) (n int, err error)

func (*ColPartFile) Ref 

func (cpf *ColPartFile) Ref()

func (*ColPartFile) RefCount 

func (cpf *ColPartFile) RefCount() int64

func (*ColPartFile) Stat 

func (cpf *ColPartFile) Stat() common.FileInfo

func (*ColPartFile) Unref 

func (cpf *ColPartFile) Unref()

type EmbedBlockIndexFile 

type EmbedBlockIndexFile struct {
	EmbedIndexFile
	ID common.ID
}

func (*EmbedBlockIndexFile) Read 

func (bf *EmbedBlockIndexFile) Read(buf []byte) (n int, err error)

func (*EmbedBlockIndexFile) Ref 

func (bf *EmbedBlockIndexFile) Ref()

func (*EmbedBlockIndexFile) RefCount 

func (bf *EmbedBlockIndexFile) RefCount() int64

func (*EmbedBlockIndexFile) Stat 

func (bf *EmbedBlockIndexFile) Stat() common.FileInfo

func (*EmbedBlockIndexFile) Unref 

func (bf *EmbedBlockIndexFile) Unref()

type EmbedIndexFile 

type EmbedIndexFile struct {
	SegmentFile base.ISegmentFile
	Meta        *base.IndexMeta
	Info        *fileStat
}

func (*EmbedIndexFile) GetFileType 

func (f *EmbedIndexFile) GetFileType() common.FileType

func (*EmbedIndexFile) Read 

func (f *EmbedIndexFile) Read(buf []byte) (n int, err error)

func (*EmbedIndexFile) Ref 

func (f *EmbedIndexFile) Ref()

func (*EmbedIndexFile) RefCount 

func (f *EmbedIndexFile) RefCount() int64

func (*EmbedIndexFile) Stat 

func (f *EmbedIndexFile) Stat() common.FileInfo

func (*EmbedIndexFile) Unref 

func (f *EmbedIndexFile) Unref()

type FileDestoryer 

type FileDestoryer = func(string) error

type FileMeta 

type FileMeta struct {
	Indices *base.IndicesMeta
}

func NewFileMeta 

func NewFileMeta() *FileMeta

type FileNameFactory 

type FileNameFactory = func(string, common.ID) string

type FileType 

type FileType uint8
const (
	UnsortedSegFile FileType = iota
	SortedSegFile
)

type IndexFile 

type IndexFile struct {
	os.File
	common.RefHelper
	ID   common.ID
	Meta *base.IndexMeta
	Info *fileStat
}

func (*IndexFile) GetFileType 

func (f *IndexFile) GetFileType() common.FileType

func (*IndexFile) Read 

func (f *IndexFile) Read(buf []byte) (n int, err error)

func (*IndexFile) Ref 

func (f *IndexFile) Ref()

func (*IndexFile) RefCount 

func (f *IndexFile) RefCount() int64

func (*IndexFile) Stat 

func (f *IndexFile) Stat() common.FileInfo

func (*IndexFile) Unref 

func (f *IndexFile) Unref()

type Manager 

type Manager struct {
	sync.RWMutex
	UnsortedFiles map[common.ID]base.ISegmentFile
	SortedFiles   map[common.ID]base.ISegmentFile
	Dir           string
	Mock          bool
}

func NewManager 

func NewManager(dir string, mock bool) *Manager

func (*Manager) Close 

func (mgr *Manager) Close() error

func (*Manager) GetSortedFile 

func (mgr *Manager) GetSortedFile(id common.ID) base.ISegmentFile

func (*Manager) GetUnsortedFile 

func (mgr *Manager) GetUnsortedFile(id common.ID) base.ISegmentFile

func (*Manager) RegisterSortedFiles 

func (mgr *Manager) RegisterSortedFiles(id common.ID) (base.ISegmentFile, error)

func (*Manager) RegisterUnsortedFiles 

func (mgr *Manager) RegisterUnsortedFiles(id common.ID) (base.ISegmentFile, error)

func (*Manager) String 

func (mgr *Manager) String() string

func (*Manager) UnregisterSortedFile 

func (mgr *Manager) UnregisterSortedFile(id common.ID)

func (*Manager) UnregisterUnsortedFile 

func (mgr *Manager) UnregisterUnsortedFile(id common.ID)

func (*Manager) UpgradeFile 

func (mgr *Manager) UpgradeFile(id common.ID) base.ISegmentFile

type MockColPartFile 

type MockColPartFile struct {
}

func (*MockColPartFile) Read 

func (cpf *MockColPartFile) Read(buf []byte) (n int, err error)

type MockSegmentFile 

type MockSegmentFile struct {
	common.RefHelper
	FileName string
	FileType FileType
	TypeName string
	Refs     int32
	ID       common.ID
	Info     *fileStat
}

func (*MockSegmentFile) Close 

func (msf *MockSegmentFile) Close() error

func (*MockSegmentFile) CopyTo 

func (msf *MockSegmentFile) CopyTo(dir string) error

func (*MockSegmentFile) DataCompressAlgo 

func (msf *MockSegmentFile) DataCompressAlgo(id common.ID) int

func (*MockSegmentFile) Destroy 

func (msf *MockSegmentFile) Destroy()

func (*MockSegmentFile) GetBlockIndicesMeta 

func (msf *MockSegmentFile) GetBlockIndicesMeta(id common.ID) *base.IndicesMeta

func (*MockSegmentFile) GetBlockSize 

func (msf *MockSegmentFile) GetBlockSize(_ common.ID) int64

func (*MockSegmentFile) GetDir 

func (msf *MockSegmentFile) GetDir() string

func (*MockSegmentFile) GetFileType 

func (msf *MockSegmentFile) GetFileType() common.FileType

func (*MockSegmentFile) GetIndicesMeta 

func (msf *MockSegmentFile) GetIndicesMeta() *base.IndicesMeta

func (*MockSegmentFile) LinkTo 

func (msf *MockSegmentFile) LinkTo(dir string) error

func (*MockSegmentFile) MakeVirtualBlkIndexFile 

func (msf *MockSegmentFile) MakeVirtualBlkIndexFile(id common.ID, meta *base.IndexMeta) common.IVFile

func (*MockSegmentFile) MakeVirtualIndexFile 

func (msf *MockSegmentFile) MakeVirtualIndexFile(meta *base.IndexMeta) common.IVFile

func (*MockSegmentFile) MakeVirtualPartFile 

func (msf *MockSegmentFile) MakeVirtualPartFile(id *common.ID) common.IVFile

func (*MockSegmentFile) MakeVirtualSeparateIndexFile 

func (msf *MockSegmentFile) MakeVirtualSeparateIndexFile(file *os.File, id *common.ID, meta *base.IndexMeta) common.IVFile

func (*MockSegmentFile) PartSize 

func (msf *MockSegmentFile) PartSize(colIdx uint64, id common.ID, _ bool) int64

func (*MockSegmentFile) PrefetchPart 

func (msf *MockSegmentFile) PrefetchPart(colIdx uint64, id common.ID) error

func (*MockSegmentFile) ReadBlockPoint 

func (msf *MockSegmentFile) ReadBlockPoint(id common.ID, ptr *base.Pointer, buf []byte)

func (*MockSegmentFile) ReadPart 

func (msf *MockSegmentFile) ReadPart(colIdx uint64, id common.ID, buf []byte)

func (*MockSegmentFile) ReadPoint 

func (msf *MockSegmentFile) ReadPoint(ptr *base.Pointer, buf []byte)

func (*MockSegmentFile) Ref 

func (msf *MockSegmentFile) Ref()

func (*MockSegmentFile) RefBlock 

func (msf *MockSegmentFile) RefBlock(id common.ID)

func (*MockSegmentFile) RefTBlock 

func (msf *MockSegmentFile) RefTBlock(id common.ID) base.IBlockFile

func (*MockSegmentFile) RegisterTBlock 

func (msf *MockSegmentFile) RegisterTBlock(id common.ID) (base.IBlockFile, error)

func (*MockSegmentFile) Stat 

func (msf *MockSegmentFile) Stat() common.FileInfo

func (*MockSegmentFile) Unref 

func (msf *MockSegmentFile) Unref()

func (*MockSegmentFile) UnrefBlock 

func (msf *MockSegmentFile) UnrefBlock(id common.ID)

type SegmentWriter 

type SegmentWriter struct {
	// contains filtered or unexported fields
}
BlkCnt | Blk0 Pos | Blk1 Pos | ... | BlkEndPos | Blk0 Data | ...

SegmentWriter writes block data into the created segment file when flushSegEvent(.blk count == SegmentMaxBlocks) is triggered.

func NewSegmentWriter 

func NewSegmentWriter(data iface.BlockIterator, meta *metadata.Segment, dir string, post func()) *SegmentWriter

NewSegmentWriter make a SegmentWriter, which is used when (block file count) == SegmentMaxBlocks

func (*SegmentWriter) Execute 

func (sw *SegmentWriter) Execute() error

Execute steps as follows: 1. Create a temp segment file. 3. Flush indices. 4. Compress column data and flush them. 5. Rename .tmp file to .seg file.

func (*SegmentWriter) GetDestoryer 

func (sw *SegmentWriter) GetDestoryer() FileDestoryer

func (*SegmentWriter) GetSize 

func (sw *SegmentWriter) GetSize() int64

func (*SegmentWriter) SetFileGetter 

func (sw *SegmentWriter) SetFileGetter(f func(string, *metadata.Segment) (*os.File, error))

func (*SegmentWriter) SetFlusher 

func (sw *SegmentWriter) SetFlusher(f func(*os.File, iface.BlockIterator, *metadata.Segment) error)

func (*SegmentWriter) SetPostExecutor 

func (sw *SegmentWriter) SetPostExecutor(f func())

func (*SegmentWriter) SetPreExecutor 

func (sw *SegmentWriter) SetPreExecutor(f func())

type SortedSegmentFile 

type SortedSegmentFile struct {
	common.RefHelper
	ID common.ID
	os.File
	Refs       int32
	Parts      map[base.Key]*base.Pointer
	Meta       *FileMeta
	BlocksMeta map[common.ID]*FileMeta
	Info       *fileStat
	DataAlgo   int
}

SortedSegmentFile file structure: header | reserved | algo | datalen | colCntlen | blkId 01 | blkCount 01| blkPreIdx 01| blkIdx 01| blkId 02 | blkCount 02... col01 : blkdatalen 01 | blkdata originlen 01| blkdatalen 02 | blkdata originlen 02... col02 : blkdatalen 01 | blkdata originlen 01| blkdatalen 02 | blkdata originlen 02... ... startPos | endPos | col01Pos | col02Pos ... col01 : blkdata01 | blkdata02 | blkdata03 ... col02 : blkdata01 | blkdata02 | blkdata03 ... ...

func (*SortedSegmentFile) CopyTo 

func (sf *SortedSegmentFile) CopyTo(dir string) error

func (*SortedSegmentFile) DataCompressAlgo 

func (sf *SortedSegmentFile) DataCompressAlgo(id common.ID) int

func (*SortedSegmentFile) Destroy 

func (sf *SortedSegmentFile) Destroy()

func (*SortedSegmentFile) GetBlockIndicesMeta 

func (sf *SortedSegmentFile) GetBlockIndicesMeta(id common.ID) *base.IndicesMeta

func (*SortedSegmentFile) GetBlockSize 

func (sf *SortedSegmentFile) GetBlockSize(_ common.ID) int64

func (*SortedSegmentFile) GetDir 

func (sf *SortedSegmentFile) GetDir() string

func (*SortedSegmentFile) GetFileType 

func (sf *SortedSegmentFile) GetFileType() common.FileType

func (*SortedSegmentFile) GetIndicesMeta 

func (sf *SortedSegmentFile) GetIndicesMeta() *base.IndicesMeta

func (*SortedSegmentFile) LinkTo 

func (sf *SortedSegmentFile) LinkTo(dir string) error

func (*SortedSegmentFile) MakeVirtualBlkIndexFile 

func (sf *SortedSegmentFile) MakeVirtualBlkIndexFile(id common.ID, meta *base.IndexMeta) common.IVFile

func (*SortedSegmentFile) MakeVirtualIndexFile 

func (sf *SortedSegmentFile) MakeVirtualIndexFile(meta *base.IndexMeta) common.IVFile

func (*SortedSegmentFile) MakeVirtualPartFile 

func (sf *SortedSegmentFile) MakeVirtualPartFile(id *common.ID) common.IVFile

func (*SortedSegmentFile) MakeVirtualSeparateIndexFile 

func (sf *SortedSegmentFile) MakeVirtualSeparateIndexFile(file *os.File, id *common.ID, meta *base.IndexMeta) common.IVFile

func (*SortedSegmentFile) PartSize 

func (sf *SortedSegmentFile) PartSize(colIdx uint64, id common.ID, isOrigin bool) int64

func (*SortedSegmentFile) PrefetchPart 

func (sf *SortedSegmentFile) PrefetchPart(colIdx uint64, id common.ID) error

func (*SortedSegmentFile) ReadBlockPoint 

func (sf *SortedSegmentFile) ReadBlockPoint(id common.ID, ptr *base.Pointer, buf []byte)

func (*SortedSegmentFile) ReadPart 

func (sf *SortedSegmentFile) ReadPart(colIdx uint64, id common.ID, buf []byte)

func (*SortedSegmentFile) ReadPoint 

func (sf *SortedSegmentFile) ReadPoint(ptr *base.Pointer, buf []byte)

func (*SortedSegmentFile) RefBlock 

func (sf *SortedSegmentFile) RefBlock(id common.ID)

func (*SortedSegmentFile) RefTBlock 

func (sf *SortedSegmentFile) RefTBlock(id common.ID) base.IBlockFile

func (*SortedSegmentFile) RegisterTBlock 

func (sf *SortedSegmentFile) RegisterTBlock(id common.ID) (base.IBlockFile, error)

func (*SortedSegmentFile) Stat 

func (sf *SortedSegmentFile) Stat() common.FileInfo

func (*SortedSegmentFile) UnrefBlock 

func (sf *SortedSegmentFile) UnrefBlock(id common.ID)

type TransientBlockFile 

type TransientBlockFile struct {
	common.RefHelper
	// contains filtered or unexported fields
}

TransientBlockFile file structure: algo | colCntlen | metaCnt | preIdxLen | preIdx | IdxLen | Idx col01 : coldata len | coldata originlen | col02 : coldata len | coldata originlen | ... col01 data | col02 data | ...

func NewTBlockFile 

func NewTBlockFile(host base.ISegmentFile, id common.ID) *TransientBlockFile

func (*TransientBlockFile) Close 

func (f *TransientBlockFile) Close() error

func (*TransientBlockFile) CopyTo 

func (f *TransientBlockFile) CopyTo(path string) (err error)

func (*TransientBlockFile) DataCompressAlgo 

func (f *TransientBlockFile) DataCompressAlgo(common.ID) int

func (*TransientBlockFile) Destroy 

func (f *TransientBlockFile) Destroy()

func (*TransientBlockFile) GetDir 

func (f *TransientBlockFile) GetDir() string

func (*TransientBlockFile) GetIndicesMeta 

func (f *TransientBlockFile) GetIndicesMeta() *base.IndicesMeta

func (*TransientBlockFile) InitMeta 

func (f *TransientBlockFile) InitMeta(meta *metadata.Block)

func (*TransientBlockFile) LinkTo 

func (f *TransientBlockFile) LinkTo(path string) (err error)

func (*TransientBlockFile) LoadBatch 

func (f *TransientBlockFile) LoadBatch(meta *metadata.Block) batch.IBatch

func (*TransientBlockFile) MakeVirtualIndexFile 

func (f *TransientBlockFile) MakeVirtualIndexFile(*base.IndexMeta) common.IVFile

func (*TransientBlockFile) PartSize 

func (f *TransientBlockFile) PartSize(colIdx uint64, id common.ID, isOrigin bool) int64

func (*TransientBlockFile) PreSync 

func (f *TransientBlockFile) PreSync(pos uint32) bool

func (*TransientBlockFile) PrefetchPart 

func (f *TransientBlockFile) PrefetchPart(colIdx uint64, id common.ID) error

func (*TransientBlockFile) ReadPart 

func (f *TransientBlockFile) ReadPart(colIdx uint64, id common.ID, buf []byte)

func (*TransientBlockFile) ReadPoint 

func (f *TransientBlockFile) ReadPoint(ptr *base.Pointer, buf []byte)

func (*TransientBlockFile) Stat 

func (f *TransientBlockFile) Stat() common.FileInfo

func (*TransientBlockFile) Sync 

func (f *TransientBlockFile) Sync(data batch.IBatch, meta *metadata.Block) error

type UnsortedSegmentFile 

type UnsortedSegmentFile struct {
	sync.RWMutex
	common.RefHelper
	ID      common.ID
	Blocks  map[common.ID]base.IBlockFile
	TBlocks map[common.ID]base.IBaseFile
	Dir     string
	Info    *fileStat
}

UnsortedSegmentFile is a logical file containing some block(.blk) files

func (*UnsortedSegmentFile) AddBlock 

func (sf *UnsortedSegmentFile) AddBlock(id common.ID, bf base.IBlockFile)

func (*UnsortedSegmentFile) Close 

func (sf *UnsortedSegmentFile) Close() error

func (*UnsortedSegmentFile) CopyTo 

func (sf *UnsortedSegmentFile) CopyTo(dir string) error

func (*UnsortedSegmentFile) DataCompressAlgo 

func (sf *UnsortedSegmentFile) DataCompressAlgo(id common.ID) int

func (*UnsortedSegmentFile) Destroy 

func (sf *UnsortedSegmentFile) Destroy()

func (*UnsortedSegmentFile) GetBlock 

func (sf *UnsortedSegmentFile) GetBlock(id common.ID) base.IBlockFile

func (*UnsortedSegmentFile) GetBlockIndicesMeta 

func (sf *UnsortedSegmentFile) GetBlockIndicesMeta(id common.ID) *base.IndicesMeta

func (*UnsortedSegmentFile) GetBlockSize 

func (sf *UnsortedSegmentFile) GetBlockSize(id common.ID) int64

func (*UnsortedSegmentFile) GetDir 

func (sf *UnsortedSegmentFile) GetDir() string

func (*UnsortedSegmentFile) GetFileType 

func (sf *UnsortedSegmentFile) GetFileType() common.FileType

func (*UnsortedSegmentFile) GetIndicesMeta 

func (sf *UnsortedSegmentFile) GetIndicesMeta() *base.IndicesMeta

func (*UnsortedSegmentFile) LinkTo 

func (sf *UnsortedSegmentFile) LinkTo(dir string) error

func (*UnsortedSegmentFile) MakeVirtualBlkIndexFile 

func (sf *UnsortedSegmentFile) MakeVirtualBlkIndexFile(id common.ID, meta *base.IndexMeta) common.IVFile

func (*UnsortedSegmentFile) MakeVirtualIndexFile 

func (sf *UnsortedSegmentFile) MakeVirtualIndexFile(meta *base.IndexMeta) common.IVFile

func (*UnsortedSegmentFile) MakeVirtualPartFile 

func (sf *UnsortedSegmentFile) MakeVirtualPartFile(id *common.ID) common.IVFile

func (*UnsortedSegmentFile) MakeVirtualSeparateIndexFile 

func (sf *UnsortedSegmentFile) MakeVirtualSeparateIndexFile(file *os.File, id *common.ID, meta *base.IndexMeta) common.IVFile

func (*UnsortedSegmentFile) PartSize 

func (sf *UnsortedSegmentFile) PartSize(colIdx uint64, id common.ID, isOrigin bool) int64

func (*UnsortedSegmentFile) PrefetchPart 

func (sf *UnsortedSegmentFile) PrefetchPart(colIdx uint64, id common.ID) error

func (*UnsortedSegmentFile) ReadBlockPoint 

func (sf *UnsortedSegmentFile) ReadBlockPoint(id common.ID, ptr *base.Pointer, buf []byte)

func (*UnsortedSegmentFile) ReadPart 

func (sf *UnsortedSegmentFile) ReadPart(colIdx uint64, id common.ID, buf []byte)

func (*UnsortedSegmentFile) ReadPoint 

func (sf *UnsortedSegmentFile) ReadPoint(ptr *base.Pointer, buf []byte)

func (*UnsortedSegmentFile) RefBlock 

func (sf *UnsortedSegmentFile) RefBlock(id common.ID)

func (*UnsortedSegmentFile) RefTBlock 

func (sf *UnsortedSegmentFile) RefTBlock(id common.ID) base.IBlockFile

func (*UnsortedSegmentFile) RegisterTBlock 

func (sf *UnsortedSegmentFile) RegisterTBlock(id common.ID) (base.IBlockFile, error)

func (*UnsortedSegmentFile) Stat 

func (sf *UnsortedSegmentFile) Stat() common.FileInfo

func (*UnsortedSegmentFile) UnrefBlock 

func (sf *UnsortedSegmentFile) UnrefBlock(id common.ID)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.