azuresynapse

package
v1.8.0-preview.1 Latest Latest
Warning

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

Go to latest
Published: Apr 11, 2023 License: AGPL-3.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Init

func Init()

func WithConfig added in v1.7.0

func WithConfig(h *AzureSynapse, config *config.Config)

Types

type AzureSynapse added in v1.7.0

type AzureSynapse struct {
	DB                          *sql.DB
	Namespace                   string
	ObjectStorage               string
	Warehouse                   model.Warehouse
	Uploader                    warehouseutils.Uploader
	NumWorkersDownloadLoadFiles int
	Logger                      logger.Logger
	LoadFileDownLoader          downloader.Downloader
	ConnectTimeout              time.Duration
}

func NewAzureSynapse added in v1.7.0

func NewAzureSynapse() *AzureSynapse

func (*AzureSynapse) AddColumns added in v1.7.0

func (as *AzureSynapse) AddColumns(tableName string, columnsInfo []warehouseutils.ColumnInfo) (err error)

func (*AzureSynapse) AlterColumn added in v1.7.0

func (*AzureSynapse) AlterColumn(_, _, _ string) (model.AlterTableResponse, error)

func (*AzureSynapse) Cleanup added in v1.7.0

func (as *AzureSynapse) Cleanup()

func (*AzureSynapse) Connect added in v1.7.0

func (as *AzureSynapse) Connect(warehouse model.Warehouse) (client.Client, error)

func (*AzureSynapse) CrashRecover added in v1.7.0

func (as *AzureSynapse) CrashRecover(warehouse model.Warehouse) (err error)

func (*AzureSynapse) CreateSchema added in v1.7.0

func (as *AzureSynapse) CreateSchema() (err error)

func (*AzureSynapse) CreateTable added in v1.7.0

func (as *AzureSynapse) CreateTable(tableName string, columnMap model.TableSchema) (err error)

func (*AzureSynapse) DeleteBy added in v1.7.0

func (*AzureSynapse) DownloadIdentityRules added in v1.7.0

func (*AzureSynapse) DownloadIdentityRules(*misc.GZipWriter) (err error)

func (*AzureSynapse) DropTable added in v1.7.0

func (as *AzureSynapse) DropTable(tableName string) (err error)

func (*AzureSynapse) ErrorMappings added in v1.7.0

func (as *AzureSynapse) ErrorMappings() []model.JobError

func (*AzureSynapse) FetchSchema added in v1.7.0

func (as *AzureSynapse) FetchSchema(warehouse model.Warehouse) (schema, unrecognizedSchema model.Schema, err error)

FetchSchema queries SYNAPSE and returns the schema associated with provided namespace

func (*AzureSynapse) GetTotalCountInTable added in v1.7.0

func (as *AzureSynapse) GetTotalCountInTable(ctx context.Context, tableName string) (int64, error)

func (*AzureSynapse) IsEmpty added in v1.7.0

func (*AzureSynapse) IsEmpty(_ model.Warehouse) (empty bool, err error)

func (*AzureSynapse) LoadIdentityMappingsTable added in v1.7.0

func (*AzureSynapse) LoadIdentityMappingsTable() (err error)

func (*AzureSynapse) LoadIdentityMergeRulesTable added in v1.7.0

func (*AzureSynapse) LoadIdentityMergeRulesTable() (err error)

func (*AzureSynapse) LoadTable added in v1.7.0

func (as *AzureSynapse) LoadTable(tableName string) error

func (*AzureSynapse) LoadTestTable added in v1.7.0

func (as *AzureSynapse) LoadTestTable(_, tableName string, payloadMap map[string]interface{}, _ string) (err error)

func (*AzureSynapse) LoadUserTables added in v1.7.0

func (as *AzureSynapse) LoadUserTables() map[string]error

func (*AzureSynapse) SetConnectionTimeout added in v1.7.0

func (as *AzureSynapse) SetConnectionTimeout(timeout time.Duration)

func (*AzureSynapse) Setup added in v1.7.0

func (as *AzureSynapse) Setup(warehouse model.Warehouse, uploader warehouseutils.Uploader) (err error)

func (*AzureSynapse) TestConnection added in v1.7.0

func (as *AzureSynapse) TestConnection(warehouse model.Warehouse) (err error)

Jump to

Keyboard shortcuts

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