starrocks

package
v0.11.689 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 20, 2026 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewColumnCheckOperator added in v0.11.681 

func NewColumnCheckOperator(manager config.ConnectionGetter) *ansisql.ColumnCheckOperator

func NewMaterializer added in v0.11.681 

func NewMaterializer(fullRefresh bool) *pipeline.Materializer

Types

type AcceptedValuesCheck added in v0.11.681 

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

func (*AcceptedValuesCheck) Check added in v0.11.681 

func (c *AcceptedValuesCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error

type BasicOperator added in v0.11.681 

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

func NewBasicOperator added in v0.11.681 

func NewBasicOperator(conn config.ConnectionGetter, extractor query.QueryExtractor, fullRefresh bool, hoister pipeline.DeclareHoister, parser *sqlparser.SQLParser) *BasicOperator

func (BasicOperator) Run added in v0.11.681 

func (o BasicOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error

func (BasicOperator) RunTask added in v0.11.681 

func (o BasicOperator) RunTask(ctx context.Context, p *pipeline.Pipeline, t *pipeline.Asset) error

type Client 

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

func NewClient 

func NewClient(c StarRocksConfig) (*Client, error)

func NewClientWithContext added in v0.11.681 

func NewClientWithContext(_ context.Context, c StarRocksConfig) (*Client, error)

func (*Client) BuildTableExistsQuery added in v0.11.681 

func (c *Client) BuildTableExistsQuery(tableName string) (string, error)

func (*Client) CreateSchemaIfNotExist added in v0.11.681 

func (c *Client) CreateSchemaIfNotExist(ctx context.Context, asset *pipeline.Asset) error

func (*Client) GetDatabaseSummary added in v0.11.681 

func (c *Client) GetDatabaseSummary(ctx context.Context) (*ansisql.DBDatabase, error)

func (*Client) GetIngestrURI 

func (c *Client) GetIngestrURI() (string, error)

func (*Client) Ping added in v0.11.681 

func (c *Client) Ping(ctx context.Context) error

func (*Client) RunQueryWithoutResult added in v0.11.681 

func (c *Client) RunQueryWithoutResult(ctx context.Context, query *query.Query) error

func (*Client) Select added in v0.11.681 

func (c *Client) Select(ctx context.Context, queryObj *query.Query) ([][]interface{}, error)

func (*Client) SelectWithSchema added in v0.11.681 

func (c *Client) SelectWithSchema(ctx context.Context, queryObj *query.Query) (*query.QueryResult, error)

type Config 

type Config struct {
	Username       string // Required
	Password       string // Optional
	Host           string // Required
	Port           int    // Optional - defaults to 9030 (FE MySQL protocol port)
	Database       string // Optional - default database for unqualified table names
	Catalog        string // Optional - external lakehouse catalog (Iceberg/Hudi/Hive/...)
	SSL            string // Optional - "true" or "skip-verify" to enable TLS
	HTTPPort       int    // Optional - FE HTTP port for Stream Load when used as a destination
	ReplicationNum int    // Optional - replica count for tables created as a destination
}

func (Config) GetIngestrURI 

func (c Config) GetIngestrURI() string

GetIngestrURI builds starrocks://user:pass@host:port/[catalog/]database?ssl=... A lone database maps to the internal catalog; catalog is prefixed only when a database is also set, matching ingestr's [catalog/]database path handling.

func (Config) ToDBConnectionURI added in v0.11.681 

func (c Config) ToDBConnectionURI() (string, error)

ToDBConnectionURI builds a go-sql-driver/mysql DSN for StarRocks, which speaks the MySQL wire protocol on its FE query port (9030 by default). The SSL field carries a driver-native tls mode ("true"/"skip-verify"/"preferred"), so it is forwarded straight to the driver's built-in tls parameter without registering a custom TLS config.

type DB added in v0.11.681 

type DB interface {
	Querier
	Selector
}

type PatternCheck added in v0.11.681 

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

func (*PatternCheck) Check added in v0.11.681 

func (c *PatternCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error

type Querier added in v0.11.681 

type Querier interface {
	RunQueryWithoutResult(ctx context.Context, query *query.Query) error
}

type SeedOperator added in v0.11.681 

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

func NewSeedOperator added in v0.11.681 

func NewSeedOperator(conn config.ConnectionGetter, renderer jinja.RendererInterface) *SeedOperator

func (SeedOperator) Run added in v0.11.681 

func (o SeedOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error

type Selector added in v0.11.681 

type Selector interface {
	Select(ctx context.Context, query *query.Query) ([][]interface{}, error)
	SelectWithSchema(ctx context.Context, queryObj *query.Query) (*query.QueryResult, error)
}

type StarRocksConfig added in v0.11.681 

type StarRocksConfig interface {
	GetIngestrURI() string
	ToDBConnectionURI() (string, error)
}

StarRocksConfig is the driver-level config the client depends on. It is implemented by the package-local Config (see config.go).

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.