tpch

package

v1.0.1 Latest Latest Go to latest Published: Mar 17, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Details

This section is empty.

This section is empty.

func NewWorkloader(db *sql.DB, cfg *Config) workload.Workloader

NewWorkloader new work loader

type Config struct {
	DBName            string
	RawQueries        string
	QueryNames        []string
	ScaleFactor       int
	EnableOutputCheck bool
}

Config is the configuration for tpch workload

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

Workloader is TPCH workload

func (w Workloader) Check(ctx context.Context, threadID int) error

Check checks data

func (w Workloader) CheckPrepare(ctx context.Context, threadID int) error

CheckPrepare checks prepare

func (w Workloader) Cleanup(ctx context.Context, threadID int) error

Cleanup cleans up workloader

func (w Workloader) CleanupThread(ctx context.Context, threadID int)

CleanupThread cleans up thread

func (w Workloader) DBName() string

DBName returns the name of test db.

func (w Workloader) DataGen() bool

DataGen returns a bool to represent whether to generate csv data or load data to db.

func (w Workloader) InitThread(ctx context.Context, threadID int) context.Context

InitThread inits thread

func (w Workloader) Name() string

Name return workloader name

func (w Workloader) Prepare(ctx context.Context, threadID int) error

Prepare prepares data

func (w Workloader) Run(ctx context.Context, threadID int) error

Run runs workload

Path	Synopsis
dbgen
dist