databricks

Documentation

Index

• Constants
• type Config
  • func (c *Config) Parse(configJson json.RawMessage) error
• type DB
  • func NewDB(configJson json.RawMessage) (*DB, error)
  • func (db *DB) RenameTable(ctx context.Context, oldRef, newRef sqlconnect.RelationRef) error

Constants

const (
	DatabaseType = "databricks"
)

Types

type Config

type Config struct {
	Host    string `json:"host"`
	Port    int    `json:"port"`
	Path    string `json:"path"`
	Token   string `json:"token"`
	Catalog string `json:"catalog"`

	RetryAttempts    int           `json:"retryAttempts"`
	MinRetryWaitTime time.Duration `json:"minRetryWaitTime"`
	MaxRetryWaitTime time.Duration `json:"maxRetryWaitTime"`
	MaxConnIdleTime  time.Duration `json:"maxConnIdleTime"`

	UseLegacyMappings bool `json:"useLegacyMappings"`
}

func (*Config) Parse

func (c *Config) Parse(configJson json.RawMessage) error

type DB

type DB struct {
	*base.DB
}

func NewDB

func NewDB(configJson json.RawMessage) (*DB, error)

NewDB creates a new databricks db client

func (*DB) RenameTable

func (db *DB) RenameTable(ctx context.Context, oldRef, newRef sqlconnect.RelationRef) error

RenameTable in databricks falls back to MoveTable if rename is not supported