Documentation
¶
Index ¶
- func CheckPKRecord(rec *record.Record, segCount int) error
- func InitColStoreCompactor()
- type ColStoreCompactor
- type CompactContext
- type FragmentIterator
- func (fi *FragmentIterator) AddRowIterator(ri *RowIterator)
- func (fi *FragmentIterator) AppendTo(dst *record.Record, batchSize int) error
- func (fi *FragmentIterator) BuildCompactedSchema(its []*immutable.CSFileIterator)
- func (fi *FragmentIterator) Len() int
- func (fi *FragmentIterator) Less(i, j int) bool
- func (fi *FragmentIterator) Pop() any
- func (fi *FragmentIterator) Push(v any)
- func (fi *FragmentIterator) Reset()
- func (fi *FragmentIterator) Swap(i, j int)
- type FragmentIteratorBuilder
- type RowIterator
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitColStoreCompactor ¶
func InitColStoreCompactor()
Types ¶
type ColStoreCompactor ¶
type ColStoreCompactor struct {
// contains filtered or unexported fields
}
func (*ColStoreCompactor) Compact ¶
func (c *ColStoreCompactor) Compact(ident util.MeasurementIdent, files []immutable.TSSPFile) ([]immutable.TSSPFile, error)
func (*ColStoreCompactor) WriteSegment ¶
func (c *ColStoreCompactor) WriteSegment(rec *record.Record) error
type CompactContext ¶
type CompactContext struct {
// contains filtered or unexported fields
}
type FragmentIterator ¶
type FragmentIterator struct {
// contains filtered or unexported fields
}
FragmentIterator used for iterating data in Fragment constructed through FragmentIteratorBuilder
func NewFragmentIterator ¶
func NewFragmentIterator(skSchema record.Schemas, unique bool) *FragmentIterator
func (*FragmentIterator) AddRowIterator ¶
func (fi *FragmentIterator) AddRowIterator(ri *RowIterator)
func (*FragmentIterator) AppendTo ¶
func (fi *FragmentIterator) AppendTo(dst *record.Record, batchSize int) error
func (*FragmentIterator) BuildCompactedSchema ¶
func (fi *FragmentIterator) BuildCompactedSchema(its []*immutable.CSFileIterator)
func (*FragmentIterator) Len ¶
func (fi *FragmentIterator) Len() int
func (*FragmentIterator) Less ¶
func (fi *FragmentIterator) Less(i, j int) bool
func (*FragmentIterator) Pop ¶
func (fi *FragmentIterator) Pop() any
func (*FragmentIterator) Push ¶
func (fi *FragmentIterator) Push(v any)
func (*FragmentIterator) Reset ¶
func (fi *FragmentIterator) Reset()
func (*FragmentIterator) Swap ¶
func (fi *FragmentIterator) Swap(i, j int)
type FragmentIteratorBuilder ¶
type FragmentIteratorBuilder struct {
colstore.KeySorter
// contains filtered or unexported fields
}
func NewFragmentIteratorBuilder ¶
func NewFragmentIteratorBuilder(its []*immutable.CSFileIterator, skSchema record.Schemas, unique bool) *FragmentIteratorBuilder
func (*FragmentIteratorBuilder) BuildNext ¶
func (b *FragmentIteratorBuilder) BuildNext() (*FragmentIterator, []byte, error)
func (*FragmentIteratorBuilder) Swap ¶
func (b *FragmentIteratorBuilder) Swap(i, j int)
type RowIterator ¶
type RowIterator struct {
// contains filtered or unexported fields
}
func NewRowIterator ¶
func NewRowIterator(ci *immutable.CSFileIterator, skSchema record.Schemas) *RowIterator
func (*RowIterator) AppendRecordRowTo ¶
func (ri *RowIterator) AppendRecordRowTo(dst *record.Record)
func (*RowIterator) HasRemainRow ¶
func (ri *RowIterator) HasRemainRow() bool
func (*RowIterator) NextFragment ¶
func (ri *RowIterator) NextFragment() bool
func (*RowIterator) NextSegment ¶
func (ri *RowIterator) NextSegment() error
func (*RowIterator) PrimaryKey ¶
func (ri *RowIterator) PrimaryKey() []byte
func (*RowIterator) ReplaceRecordRowTo ¶
func (ri *RowIterator) ReplaceRecordRowTo(dst *record.Record)
Source Files
Click to show internal directories.
Click to hide internal directories.