app

Documentation

Index

• func BuildTable1() *elements.Table
• func BuildTable2() *elements.Table
• func BuildTableRegistry(ctx context.Context, logger *slog.Logger) (*operations.TableRegistry, error)
• func BuildWarehouse(ctx context.Context, logger *slog.Logger) (*warehouse.Warehouse, error)
• func Table1Transformer(ctx context.Context, mem *memory.GoAllocator, logger *slog.Logger, ...) (arrow.Record, error)
• func Table2Transformer(ctx context.Context, mem *memory.GoAllocator, logger *slog.Logger, ...) (arrow.Record, error)
• type Dataset
• type RandomTable1Dataset
  • func NewMediumRandomTable1Dataset() *RandomTable1Dataset
  • func NewRandomTable1Dataset(rowsPerRecord, maxIdValue, maxIterations int) *RandomTable1Dataset
  • func (obj *RandomTable1Dataset) BuildRecord(mem *memory.GoAllocator) arrow.Record
  • func (obj *RandomTable1Dataset) Done() bool
• type RandomTable2Dataset
  • func NewMediumRandomTable2Dataset() *RandomTable2Dataset
  • func NewRandomTable2Dataset(rowsPerRecord, maxIdValue, maxIterations int) *RandomTable2Dataset
  • func (obj *RandomTable2Dataset) BuildRecord(mem *memory.GoAllocator) arrow.Record
  • func (obj *RandomTable2Dataset) Done() bool

Functions

func BuildTable1

func BuildTable1() *elements.Table

func BuildTable2

func BuildTable2() *elements.Table

func BuildTableRegistry

func BuildTableRegistry(ctx context.Context, logger *slog.Logger) (*operations.TableRegistry, error)

func BuildWarehouse

func BuildWarehouse(ctx context.Context, logger *slog.Logger) (*warehouse.Warehouse, error)

func Table1Transformer

func Table1Transformer(
	ctx context.Context,
	mem *memory.GoAllocator,
	logger *slog.Logger,
	record arrow.Record,
) (arrow.Record, error)

func Table2Transformer

func Table2Transformer(
	ctx context.Context,
	mem *memory.GoAllocator,
	logger *slog.Logger,
	record arrow.Record,
) (arrow.Record, error)

Types

type Dataset

type Dataset interface {
	Done() bool
	BuildRecord(mem *memory.GoAllocator) arrow.Record
}

type RandomTable1Dataset

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

func NewMediumRandomTable1Dataset

func NewMediumRandomTable1Dataset() *RandomTable1Dataset

func NewRandomTable1Dataset

func NewRandomTable1Dataset(rowsPerRecord, maxIdValue, maxIterations int) *RandomTable1Dataset

func (*RandomTable1Dataset) BuildRecord

func (obj *RandomTable1Dataset) BuildRecord(mem *memory.GoAllocator) arrow.Record

func (*RandomTable1Dataset) Done

func (obj *RandomTable1Dataset) Done() bool

type RandomTable2Dataset

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

func NewMediumRandomTable2Dataset

func NewMediumRandomTable2Dataset() *RandomTable2Dataset

func NewRandomTable2Dataset

func NewRandomTable2Dataset(rowsPerRecord, maxIdValue, maxIterations int) *RandomTable2Dataset

func (*RandomTable2Dataset) BuildRecord

func (obj *RandomTable2Dataset) BuildRecord(mem *memory.GoAllocator) arrow.Record

func (*RandomTable2Dataset) Done

func (obj *RandomTable2Dataset) Done() bool