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 ¶
- type Redshift
- func (r *Redshift) CopyGzipCsvDataFromS3(schema, table, file, awsRegion string, ts postgres.TableSchema, delimiter rune) error
- func (r *Redshift) CopyJSONDataFromS3(schema, table, file, jsonpathsFile, awsRegion string) error
- func (r *Redshift) RefreshTables(tables map[string]postgres.TableSchema, ...) error
- func (r *Redshift) VacuumAnalyze() error
- func (r *Redshift) VacuumAnalyzeTable(schema, table string) 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 ¶
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 ¶
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 ¶
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 ¶
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