datalake

package
v1.5.7 Latest Latest
Warning

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

Go to latest
Published: Feb 10, 2023 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Init added in v1.0.2

func Init()

Types

type HandleT

type HandleT struct {
	SchemaRepository schemarepository.SchemaRepository
	Warehouse        warehouseutils.Warehouse
	Uploader         warehouseutils.UploaderI
}

func (*HandleT) AddColumns added in v1.3.0

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

func (*HandleT) AlterColumn

func (wh *HandleT) AlterColumn(tableName, columnName, columnType string) (err error)

func (*HandleT) Cleanup

func (*HandleT) Cleanup()

func (*HandleT) Connect

func (*HandleT) CrashRecover

func (*HandleT) CrashRecover(_ warehouseutils.Warehouse) (err error)

func (*HandleT) CreateSchema

func (wh *HandleT) CreateSchema() (err error)

func (*HandleT) CreateTable

func (wh *HandleT) CreateTable(tableName string, columnMap map[string]string) (err error)

func (*HandleT) DeleteBy added in v1.2.0

func (*HandleT) DeleteBy([]string, warehouseutils.DeleteByParams) (err error)

func (*HandleT) DownloadIdentityRules

func (*HandleT) DownloadIdentityRules(*misc.GZipWriter) error

func (*HandleT) DropTable

func (*HandleT) DropTable(_ string) (err error)

func (*HandleT) FetchSchema

func (*HandleT) GetTotalCountInTable

func (*HandleT) GetTotalCountInTable(context.Context, string) (int64, error)

func (*HandleT) IsEmpty

func (*HandleT) IsEmpty(_ warehouseutils.Warehouse) (bool, error)

func (*HandleT) LoadIdentityMappingsTable

func (wh *HandleT) LoadIdentityMappingsTable() error

func (*HandleT) LoadIdentityMergeRulesTable

func (wh *HandleT) LoadIdentityMergeRulesTable() error

func (*HandleT) LoadTable

func (wh *HandleT) LoadTable(tableName string) error

func (*HandleT) LoadTestTable

func (*HandleT) LoadTestTable(_, _ string, _ map[string]interface{}, _ string) error

func (*HandleT) LoadUserTables

func (wh *HandleT) LoadUserTables() map[string]error

func (*HandleT) SetConnectionTimeout

func (*HandleT) SetConnectionTimeout(_ time.Duration)

func (*HandleT) Setup

func (wh *HandleT) Setup(warehouse warehouseutils.Warehouse, uploader warehouseutils.UploaderI) (err error)

func (*HandleT) TestConnection

func (*HandleT) TestConnection(_ warehouseutils.Warehouse) error

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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