tpch

package

v1.0.8 Latest Latest Go to latest Published: Jan 12, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/pingcap/go-tpc

Links

Open Source Insights

Documentation ¶

Index ¶

func NewCustLoader(ctx context.Context, db *sql.DB) *custLoader
func NewLineItemLoader(ctx context.Context, db *sql.DB) *lineItemloader
func NewNationLoader(ctx context.Context, db *sql.DB) *nationLoader
func NewOrderLoader(ctx context.Context, db *sql.DB) *orderLoader
func NewPartLoader(ctx context.Context, db *sql.DB) *partLoader
func NewPartSuppLoader(ctx context.Context, db *sql.DB) *partSuppLoader
func NewRegionLoader(ctx context.Context, db *sql.DB) *regionLoader
func NewSuppLoader(ctx context.Context, db *sql.DB) *suppLoader
func NewWorkloader(db *sql.DB, cfg *Config) workload.Workloader
type Config
type Workloader

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewCustLoader ¶ added in v1.0.4

func NewCustLoader(ctx context.Context, db *sql.DB) *custLoader

func NewLineItemLoader ¶ added in v1.0.4

func NewLineItemLoader(ctx context.Context, db *sql.DB) *lineItemloader

func NewNationLoader ¶ added in v1.0.4

func NewNationLoader(ctx context.Context, db *sql.DB) *nationLoader

func NewOrderLoader ¶ added in v1.0.4

func NewOrderLoader(ctx context.Context, db *sql.DB) *orderLoader

func NewPartLoader ¶ added in v1.0.4

func NewPartLoader(ctx context.Context, db *sql.DB) *partLoader

func NewPartSuppLoader ¶ added in v1.0.4

func NewPartSuppLoader(ctx context.Context, db *sql.DB) *partSuppLoader

func NewRegionLoader ¶ added in v1.0.4

func NewRegionLoader(ctx context.Context, db *sql.DB) *regionLoader

func NewSuppLoader ¶ added in v1.0.4

func NewSuppLoader(ctx context.Context, db *sql.DB) *suppLoader

func NewWorkloader ¶

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

NewWorkloader new work loader

Types ¶

type Config ¶

type Config struct {
	DBName               string
	RawQueries           string
	QueryNames           []string
	ScaleFactor          int
	EnableOutputCheck    bool
	CreateTiFlashReplica bool
	AnalyzeTable         analyzeConfig
	ExecExplainAnalyze   bool

	// for prepare command only
	OutputType string
	OutputDir  string
}

Config is the configuration for tpch workload

type Workloader ¶

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

Workloader is TPCH workload

func (Workloader) Check ¶

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

Check checks data

func (Workloader) CheckPrepare ¶

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

CheckPrepare checks prepare

func (Workloader) Cleanup ¶

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

Cleanup cleans up workloader

func (Workloader) CleanupThread ¶

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

CleanupThread cleans up thread

func (Workloader) DBName ¶

func (w Workloader) DBName() string

DBName returns the name of test db.

func (Workloader) InitThread ¶

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

InitThread inits thread

func (Workloader) Name ¶

func (w Workloader) Name() string

Name return workloader name

func (Workloader) OutputStats ¶ added in v1.0.4

func (w Workloader) OutputStats(ifSummaryReport bool)

func (Workloader) Prepare ¶

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

Prepare prepares data

func (Workloader) Run ¶

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

Run runs workload

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
dbgen
dist

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL