redshift

package
Version: v0.0.0-...-4a195b2 Latest Latest
Warning

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

Go to latest
Published: Aug 16, 2018 License: Apache-2.0 Imports: 10 Imported by: 2

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.

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

Jump to

Keyboard shortcuts

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