README
¶
redshift
-- import "github.com/Clever/redshifter/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(table, file, awsRegion string, delimiter rune) error
CopyGzipCsvDataFromS3 copies gzipped CSV data from an S3 file into a redshift table.
func (*Redshift) CopyJSONDataFromS3
func (r *Redshift) CopyJSONDataFromS3(table, file, jsonpathsFile, awsRegion string) error
CopyJSONDataFromS3 copies JSON data present in an S3 file into a redshift table.
func (*Redshift) RefreshTable
func (r *Redshift) RefreshTable(name, prefix, file, awsRegion string, ts postgres.TableSchema, delim rune) error
RefreshTable refreshes a single table by first copying gzipped CSV data into a temporary table and later renaming the temporary table to the original one.
func (*Redshift) RefreshTables
func (r *Redshift) RefreshTables(
tables map[string]postgres.TableSchema, 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 ¶
- type Redshift
- func (r *Redshift) CopyGzipCsvDataFromS3(table, file, awsRegion string, delimiter rune) error
- func (r *Redshift) CopyJSONDataFromS3(table, file, jsonpathsFile, awsRegion string) error
- func (r *Redshift) RefreshTable(name, prefix, file, awsRegion string, ts postgres.TableSchema, delim rune) error
- func (r *Redshift) RefreshTables(tables map[string]postgres.TableSchema, s3prefix, awsRegion string, delim rune) error
- func (r *Redshift) VacuumAnalyze() error
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 ¶
NewRedshift returns a pointer to a new redshift object using configuration values set in the flags.
func (*Redshift) CopyGzipCsvDataFromS3 ¶
CopyGzipCsvDataFromS3 copies gzipped CSV data from an S3 file into a redshift table.
func (*Redshift) CopyJSONDataFromS3 ¶
CopyJSONDataFromS3 copies JSON data present in an S3 file into a redshift table.
func (*Redshift) RefreshTable ¶
func (r *Redshift) RefreshTable(name, prefix, file, awsRegion string, ts postgres.TableSchema, delim rune) error
RefreshTable refreshes a single table by first copying gzipped CSV data into a temporary table and later renaming the temporary table to the original one.
func (*Redshift) RefreshTables ¶
func (r *Redshift) RefreshTables( tables map[string]postgres.TableSchema, 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 ¶
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.
Source Files