Documentation
¶
Index ¶
- type Driver
- func (d Driver) HasAnonymousSourceAccess(ctx context.Context, src map[string]any, logger *zap.Logger) (bool, error)
- func (d Driver) Open(instanceID string, cfgMap map[string]any, st *storage.Client, ...) (drivers.Handle, error)
- func (d Driver) Spec() drivers.Spec
- func (d Driver) TertiarySourceConnectors(ctx context.Context, src map[string]any, logger *zap.Logger) ([]string, error)
- type InsertTableOptions
- type ModelInputProperties
- type ModelOutputProperties
- type ModelResultProperties
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Driver ¶
type Driver struct {
// contains filtered or unexported fields
}
func (Driver) HasAnonymousSourceAccess ¶ added in v0.30.0
type InsertTableOptions ¶ added in v0.60.7
type InsertTableOptions struct {
InitQueries []string
BeforeInsert string
AfterInsert string
ByName bool
Strategy drivers.IncrementalStrategy
UniqueKey []string
// PartitionBy is a SQL expression to use for dropping/replacing partitions with the partition_overwrite incremental strategy.
PartitionBy string
}
type ModelInputProperties ¶ added in v0.45.0
type ModelInputProperties struct {
SQL string `mapstructure:"sql"`
Args []any `mapstructure:"args"`
// InitQueries are queries that are run during initialisation of write handle before model is created of any pre_exec queries are run.
InitQueries string `mapstructure:"init_queries"`
PreExec string `mapstructure:"pre_exec"`
PostExec string `mapstructure:"post_exec"`
// Database is set if sql is to be run against an external database
Database string `mapstructure:"db"`
}
func (*ModelInputProperties) Validate ¶ added in v0.45.0
func (p *ModelInputProperties) Validate() error
type ModelOutputProperties ¶ added in v0.45.0
type ModelOutputProperties struct {
Table string `mapstructure:"table"`
Materialize *bool `mapstructure:"materialize"`
UniqueKey []string `mapstructure:"unique_key"`
IncrementalStrategy drivers.IncrementalStrategy `mapstructure:"incremental_strategy"`
PartitionBy string `mapstructure:"partition_by"`
}
func (*ModelOutputProperties) Validate ¶ added in v0.45.0
func (p *ModelOutputProperties) Validate(opts *drivers.ModelExecuteOptions) error
type ModelResultProperties ¶ added in v0.45.0
Source Files
¶
- catalog.go
- config.go
- context.go
- crud.go
- duckdb.go
- information_schema.go
- model_executor_https_self.go
- model_executor_localfile_self.go
- model_executor_motherduck_self.go
- model_executor_objectstore_self.go
- model_executor_self.go
- model_executor_self_file.go
- model_executor_sqlstore_self.go
- model_executor_warehouse_self.go
- model_manager.go
- olap.go
- utils.go
Click to show internal directories.
Click to hide internal directories.