datalake

Documentation

Index

• func Init()
• type HandleT
  • func (wh *HandleT) AddColumn(tableName, columnName, columnType string) (err error)
  • func (wh *HandleT) AlterColumn(tableName, columnName, columnType string) (err error)
  • func (wh *HandleT) Cleanup()
  • func (wh *HandleT) Connect(warehouse warehouseutils.WarehouseT) (client.Client, error)
  • func (wh *HandleT) CrashRecover(warehouse warehouseutils.WarehouseT) (err error)
  • func (wh *HandleT) CreateSchema() (err error)
  • func (wh *HandleT) CreateTable(tableName string, columnMap map[string]string) (err error)
  • func (wh *HandleT) DownloadIdentityRules(*misc.GZipWriter) error
  • func (wh *HandleT) DropTable(tableName string) (err error)
  • func (wh *HandleT) FetchSchema(warehouse warehouseutils.WarehouseT) (warehouseutils.SchemaT, error)
  • func (wh *HandleT) GetTotalCountInTable(tableName string) (int64, error)
  • func (wh *HandleT) IsEmpty(warehouse warehouseutils.WarehouseT) (bool, error)
  • func (wh *HandleT) LoadIdentityMappingsTable() error
  • func (wh *HandleT) LoadIdentityMergeRulesTable() error
  • func (wh *HandleT) LoadTable(tableName string) error
  • func (wh *HandleT) LoadTestTable(location, tableName string, payloadMap map[string]interface{}, format string) error
  • func (wh *HandleT) LoadUserTables() map[string]error
  • func (wh *HandleT) SetConnectionTimeout(timeout time.Duration)
  • func (wh *HandleT) Setup(warehouse warehouseutils.WarehouseT, uploader warehouseutils.UploaderI) (err error)
  • func (wh *HandleT) TestConnection(warehouse warehouseutils.WarehouseT) error

Functions

func Init

func Init()

Types

type HandleT

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

func (*HandleT) AddColumn

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

func (*HandleT) AlterColumn

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

func (*HandleT) Cleanup

func (wh *HandleT) Cleanup()

func (*HandleT) Connect

func (wh *HandleT) Connect(warehouse warehouseutils.WarehouseT) (client.Client, error)

func (*HandleT) CrashRecover

func (wh *HandleT) CrashRecover(warehouse warehouseutils.WarehouseT) (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) DownloadIdentityRules

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

func (*HandleT) DropTable

func (wh *HandleT) DropTable(tableName string) (err error)

func (*HandleT) FetchSchema

func (wh *HandleT) FetchSchema(warehouse warehouseutils.WarehouseT) (warehouseutils.SchemaT, error)

func (*HandleT) GetTotalCountInTable

func (wh *HandleT) GetTotalCountInTable(tableName string) (int64, error)

func (*HandleT) IsEmpty

func (wh *HandleT) IsEmpty(warehouse warehouseutils.WarehouseT) (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 (wh *HandleT) LoadTestTable(location, tableName string, payloadMap map[string]interface{}, format string) error

func (*HandleT) LoadUserTables

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

func (*HandleT) SetConnectionTimeout

func (wh *HandleT) SetConnectionTimeout(timeout time.Duration)

func (*HandleT) Setup

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

func (*HandleT) TestConnection

func (wh *HandleT) TestConnection(warehouse warehouseutils.WarehouseT) error