spi

Documentation

Index

• Variables
• func CopyBlocks(from []block.Block, srcPos int32, dest []block.Block, destPos int, ...)
• func CopyOfBlocks(original []block.Block, newLength int32) []block.Block
• type DictionaryBlockIndexes
  • func NewDictionaryBlockIndexes() *DictionaryBlockIndexes
  • func (ds *DictionaryBlockIndexes) AddBlock(block *block.DictionaryBlock, index int32)
  • func (ds *DictionaryBlockIndexes) GetBlocks() *util.ArrayList[*block.DictionaryBlock]
  • func (ds *DictionaryBlockIndexes) GetIndexes() *util.ArrayList[int32]
• type Page
  • func NewPage(blocks ...block.Block) *Page
  • func NewPage2(positionCount int32) *Page
  • func NewPage3(positionCount int32, blocks ...block.Block) *Page
  • func NewPage4(blocksCopyRequired bool, positionCount int32, blocks []block.Block) *Page
  • func (pe *Page) AppendColumn(block block.Block) *Page
  • func (pe *Page) Compact()
  • func (pe *Page) CopyPositions(retainedPositions []int32, offset int32, length int32) *Page
  • func (pe *Page) GetBlock(channel int32) block.Block
  • func (pe *Page) GetChannelCount() int32
  • func (pe *Page) GetColumns(column int32) *Page
  • func (pe *Page) GetColumns2(columns ...int32) *Page
  • func (pe *Page) GetLoadedPage() *Page
  • func (pe *Page) GetLoadedPage2(column int32) *Page
  • func (pe *Page) GetLoadedPage3(columns ...int32) *Page
  • func (pe *Page) GetLoadedPage4(columns []int32, eagerlyLoadedColumns []int32) *Page
  • func (pe *Page) GetLogicalSizeInBytes() int64
  • func (pe *Page) GetPositionCount() int32
  • func (pe *Page) GetPositions(retainedPositions []int32, offset int32, length int32) *Page
  • func (pe *Page) GetRegion(positionOffset int32, length int32) *Page
  • func (pe *Page) GetRetainedSizeInBytes() int64
  • func (pe *Page) GetSingleValuePage(position int32) *Page
  • func (pe *Page) GetSizeInBytes() int64
  • func (pe *Page) PrependColumn(column block.Block) *Page
  • func (pe *Page) ToString() string
• type PageBuilder
  • func NewPageBuilder(types *util.ArrayList[block.Type]) *PageBuilder
  • func NewPageBuilder2(initialExpectedEntries int32, types *util.ArrayList[block.Type]) *PageBuilder
  • func NewPageBuilder3(initialExpectedEntries int32, maxPageBytes int32, ...) *PageBuilder
  • func WithMaxPageSize(maxPageBytes int32, types *util.ArrayList[block.Type]) *PageBuilder
  • func (pr *PageBuilder) Build() *Page
  • func (pr *PageBuilder) DeclarePosition()
  • func (pr *PageBuilder) DeclarePositions(positions int32)
  • func (pr *PageBuilder) GetBlockBuilder(channel int32) block.BlockBuilder
  • func (pr *PageBuilder) GetPositionCount() int32
  • func (pr *PageBuilder) GetRetainedSizeInBytes() int64
  • func (pr *PageBuilder) GetSizeInBytes() int64
  • func (pr *PageBuilder) GetType(channel int32) block.Type
  • func (pr *PageBuilder) IsEmpty() bool
  • func (pr *PageBuilder) IsFull() bool
  • func (pr *PageBuilder) NewPageBuilderLike() *PageBuilder
  • func (pr *PageBuilder) Reset()

Variables

var (
	PAGE_INSTANCE_SIZE int32         = util.SizeOf(&Page{})
	PAGE_EMPTY_BLOCKS  []block.Block = make([]block.Block, 0)
)

var DEFAULT_INITIAL_EXPECTED_ENTRIES int32 = 8

Functions

func CopyBlocks

func CopyBlocks(from []block.Block, srcPos int32, dest []block.Block, destPos int, length int32)

func CopyOfBlocks

func CopyOfBlocks(original []block.Block, newLength int32) []block.Block

Types

type DictionaryBlockIndexes

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

func NewDictionaryBlockIndexes

func NewDictionaryBlockIndexes() *DictionaryBlockIndexes

func (*DictionaryBlockIndexes) AddBlock

func (ds *DictionaryBlockIndexes) AddBlock(block *block.DictionaryBlock, index int32)

func (*DictionaryBlockIndexes) GetBlocks

func (ds *DictionaryBlockIndexes) GetBlocks() *util.ArrayList[*block.DictionaryBlock]

func (*DictionaryBlockIndexes) GetIndexes

func (ds *DictionaryBlockIndexes) GetIndexes() *util.ArrayList[int32]

type Page

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

func NewPage

func NewPage(blocks ...block.Block) *Page

func NewPage2

func NewPage2(positionCount int32) *Page

func NewPage3

func NewPage3(positionCount int32, blocks ...block.Block) *Page

func NewPage4

func NewPage4(blocksCopyRequired bool, positionCount int32, blocks []block.Block) *Page

func (*Page) AppendColumn

func (pe *Page) AppendColumn(block block.Block) *Page

func (*Page) Compact

func (pe *Page) Compact()

func (*Page) CopyPositions

func (pe *Page) CopyPositions(retainedPositions []int32, offset int32, length int32) *Page

func (*Page) GetBlock

func (pe *Page) GetBlock(channel int32) block.Block

func (*Page) GetChannelCount

func (pe *Page) GetChannelCount() int32

func (*Page) GetColumns

func (pe *Page) GetColumns(column int32) *Page

func (*Page) GetColumns2

func (pe *Page) GetColumns2(columns ...int32) *Page

func (*Page) GetLoadedPage

func (pe *Page) GetLoadedPage() *Page

func (*Page) GetLoadedPage2

func (pe *Page) GetLoadedPage2(column int32) *Page

func (*Page) GetLoadedPage3

func (pe *Page) GetLoadedPage3(columns ...int32) *Page

func (*Page) GetLoadedPage4

func (pe *Page) GetLoadedPage4(columns []int32, eagerlyLoadedColumns []int32) *Page

func (*Page) GetLogicalSizeInBytes

func (pe *Page) GetLogicalSizeInBytes() int64

func (*Page) GetPositionCount

func (pe *Page) GetPositionCount() int32

func (*Page) GetPositions

func (pe *Page) GetPositions(retainedPositions []int32, offset int32, length int32) *Page

func (*Page) GetRegion

func (pe *Page) GetRegion(positionOffset int32, length int32) *Page

func (*Page) GetRetainedSizeInBytes

func (pe *Page) GetRetainedSizeInBytes() int64

func (*Page) GetSingleValuePage

func (pe *Page) GetSingleValuePage(position int32) *Page

func (*Page) GetSizeInBytes

func (pe *Page) GetSizeInBytes() int64

func (*Page) PrependColumn

func (pe *Page) PrependColumn(column block.Block) *Page

func (*Page) ToString

func (pe *Page) ToString() string

@Override

type PageBuilder

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

func NewPageBuilder

func NewPageBuilder(types *util.ArrayList[block.Type]) *PageBuilder

func NewPageBuilder2

func NewPageBuilder2(initialExpectedEntries int32, types *util.ArrayList[block.Type]) *PageBuilder

func NewPageBuilder3

func NewPageBuilder3(initialExpectedEntries int32, maxPageBytes int32, types *util.ArrayList[block.Type], templateBlockBuilders *optional.Optional[[]block.BlockBuilder]) *PageBuilder

PageBuilder(int initialExpectedEntries, int maxPageBytes, *util.ArrayList[ ]<? extends block.Type> types, *optional.Optional[ ]<BlockBuilder[]> templateBlockBuilders)

func WithMaxPageSize

func WithMaxPageSize(maxPageBytes int32, types *util.ArrayList[block.Type]) *PageBuilder

func (*PageBuilder) Build

func (pr *PageBuilder) Build() *Page

func (*PageBuilder) DeclarePosition

func (pr *PageBuilder) DeclarePosition()

func (*PageBuilder) DeclarePositions

func (pr *PageBuilder) DeclarePositions(positions int32)

func (*PageBuilder) GetBlockBuilder

func (pr *PageBuilder) GetBlockBuilder(channel int32) block.BlockBuilder

func (*PageBuilder) GetPositionCount

func (pr *PageBuilder) GetPositionCount() int32

func (*PageBuilder) GetRetainedSizeInBytes

func (pr *PageBuilder) GetRetainedSizeInBytes() int64

func (*PageBuilder) GetSizeInBytes

func (pr *PageBuilder) GetSizeInBytes() int64

func (*PageBuilder) GetType

func (pr *PageBuilder) GetType(channel int32) block.Type

func (*PageBuilder) IsEmpty

func (pr *PageBuilder) IsEmpty() bool

func (*PageBuilder) IsFull

func (pr *PageBuilder) IsFull() bool

func (*PageBuilder) NewPageBuilderLike

func (pr *PageBuilder) NewPageBuilderLike() *PageBuilder

func (*PageBuilder) Reset

func (pr *PageBuilder) Reset()