README

redshift

-- import "github.com/Clever/postgres-to-redshift/redshift"

Usage

type Redshift
type Redshift struct {
}

Redshift wraps a dbExecCloser and can be used to perform operations on a redshift database.

func NewRedshift
func NewRedshift() (*Redshift, error)

NewRedshift returns a pointer to a new redshift object using configuration values set in the flags.

func (*Redshift) CopyGzipCsvDataFromS3
func (r *Redshift) CopyGzipCsvDataFromS3(schema, table, file, awsRegion string, ts postgres.TableSchema, delimiter rune) error

CopyGzipCsvDataFromS3 copies gzipped CSV data from an S3 file into a redshift table.

func (*Redshift) CopyJSONDataFromS3
func (r *Redshift) CopyJSONDataFromS3(schema, table, file, jsonpathsFile, awsRegion string) error

CopyJSONDataFromS3 copies JSON data present in an S3 file into a redshift table.

func (*Redshift) RefreshTables
func (r *Redshift) RefreshTables(
	tables map[string]postgres.TableSchema, schema, tmpschema, s3prefix, awsRegion string, delim rune) error

RefreshTables refreshes multiple tables in parallel and returns an error if any of the copies fail.

func (*Redshift) VacuumAnalyze
func (r *Redshift) VacuumAnalyze() error

VacuumAnalyze performs VACUUM FULL; ANALYZE on the redshift database. This is useful for recreating the indices after a database has been modified and updating the query planner.

Expand ▾ Collapse ▴

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Redshift

type Redshift struct {
	// contains filtered or unexported fields
}

Redshift wraps a dbExecCloser and can be used to perform operations on a redshift database.

func NewRedshift

func NewRedshift() (*Redshift, error)

NewRedshift returns a pointer to a new redshift object using configuration values set in the flags.

func (*Redshift) CopyGzipCsvDataFromS3

func (r *Redshift) CopyGzipCsvDataFromS3(schema, table, file, awsRegion string, ts postgres.TableSchema, delimiter rune) error

CopyGzipCsvDataFromS3 copies gzipped CSV data from an S3 file into a redshift table.

func (*Redshift) CopyJSONDataFromS3

func (r *Redshift) CopyJSONDataFromS3(schema, table, file, jsonpathsFile, awsRegion string) error

CopyJSONDataFromS3 copies JSON data present in an S3 file into a redshift table.

func (*Redshift) RefreshTables

func (r *Redshift) RefreshTables(
	tables map[string]postgres.TableSchema, schema, tmpschema, s3prefix, awsRegion string, delim rune) error

RefreshTables refreshes multiple tables in parallel and returns an error if any of the copies fail.

func (*Redshift) VacuumAnalyze

func (r *Redshift) VacuumAnalyze() error

VacuumAnalyze performs VACUUM FULL; ANALYZE on the redshift database. This is useful for recreating the indices after a database has been modified and updating the query planner.

func (*Redshift) VacuumAnalyzeTable

func (r *Redshift) VacuumAnalyzeTable(schema, table string) error

VacuumAnalyzeTable performs VACUUM FULL; ANALYZE on a specific table. This is useful for recreating the indices after a database has been modified and updating the query planner.

Source Files