Documentation
¶
Index ¶
- func NewColumnCheckOperator(manager config.ConnectionGetter) *ansisql.ColumnCheckOperator
- func NewMaterializer(fullRefresh bool) *pipeline.Materializer
- type AcceptedValuesCheck
- type BasicOperator
- type Client
- func (c *Client) BuildTableExistsQuery(tableName string) (string, error)
- func (c *Client) CreateSchemaIfNotExist(ctx context.Context, asset *pipeline.Asset) error
- func (c *Client) GetDatabaseSummary(ctx context.Context) (*ansisql.DBDatabase, error)
- func (c *Client) GetIngestrURI() (string, error)
- func (c *Client) Ping(ctx context.Context) error
- func (c *Client) RunQueryWithoutResult(ctx context.Context, query *query.Query) error
- func (c *Client) Select(ctx context.Context, queryObj *query.Query) ([][]interface{}, error)
- func (c *Client) SelectWithSchema(ctx context.Context, queryObj *query.Query) (*query.QueryResult, error)
- type Config
- type DB
- type DorisConfig
- type PatternCheck
- type Querier
- type SeedOperator
- type Selector
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewColumnCheckOperator ¶
func NewColumnCheckOperator(manager config.ConnectionGetter) *ansisql.ColumnCheckOperator
func NewMaterializer ¶
func NewMaterializer(fullRefresh bool) *pipeline.Materializer
Types ¶
type AcceptedValuesCheck ¶
type AcceptedValuesCheck struct {
// contains filtered or unexported fields
}
func (*AcceptedValuesCheck) Check ¶
func (c *AcceptedValuesCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
type BasicOperator ¶
type BasicOperator struct {
// contains filtered or unexported fields
}
func NewBasicOperator ¶
func NewBasicOperator(conn config.ConnectionGetter, extractor query.QueryExtractor, fullRefresh bool, hoister pipeline.DeclareHoister, parser *sqlparser.SQLParser) *BasicOperator
func (BasicOperator) Run ¶
func (o BasicOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient(c DorisConfig) (*Client, error)
func NewClientWithContext ¶
func NewClientWithContext(_ context.Context, c DorisConfig) (*Client, error)
func (*Client) BuildTableExistsQuery ¶
func (*Client) CreateSchemaIfNotExist ¶
func (*Client) GetDatabaseSummary ¶
func (*Client) GetIngestrURI ¶
func (*Client) RunQueryWithoutResult ¶
func (*Client) SelectWithSchema ¶
type Config ¶
type Config struct {
Username string
Password string
Host string
Port int
Database string
Driver string
SslCaPath string
SslCertPath string
SslKeyPath string
}
func (Config) GetIngestrURI ¶
func (Config) ToDBConnectionURI ¶
type DorisConfig ¶
type PatternCheck ¶
type PatternCheck struct {
// contains filtered or unexported fields
}
func (*PatternCheck) Check ¶
func (c *PatternCheck) Check(ctx context.Context, ti *scheduler.ColumnCheckInstance) error
type SeedOperator ¶
type SeedOperator struct {
// contains filtered or unexported fields
}
func NewSeedOperator ¶
func NewSeedOperator(conn config.ConnectionGetter, renderer jinja.RendererInterface) *SeedOperator
func (SeedOperator) Run ¶
func (o SeedOperator) Run(ctx context.Context, ti scheduler.TaskInstance) error
Click to show internal directories.
Click to hide internal directories.