lib

Documentation

Index

• func AccountID() string
• func CleanCache(fileName string)
• func Partition(daysback int, databaseName, tableName, tmplate string, partitionsMap []string)
• func Region() string
• func RenderAsCSV(i interface{}) error
• func RenderAsJSON(i interface{}) error
• func RenderAsTable(i interface{}) error
• func RenderHistoryResults(h []HistoricalExecution, outputFormat string) error
• func RenderQueryResults(outputFormat string, query string, file *os.File) error
• type Format
• type HistoricalExecution
  • func ListHistory(maxResults int, historyCmdWorkgroup string) (h []HistoricalExecution, err error)
• type Query
  • func (q *Query) Execute() (*os.File, error)
  • func (q *Query) ExecuteToStdout() error

Functions

func AccountID

func AccountID() string

AccountID returns the current AWS Account ID

func CleanCache

func CleanCache(fileName string)

CleanCache deletes any tmp files used

func Partition

func Partition(daysback int, databaseName, tableName, tmplate string, partitionsMap []string)

Partition partitions the things

func Region

func Region() string

Region returns the current region

func RenderAsCSV

func RenderAsCSV(i interface{}) error

RenderAsCSV will render an interfact to table

func RenderAsJSON

func RenderAsJSON(i interface{}) error

RenderAsJSON will render an interface as json

func RenderAsTable

func RenderAsTable(i interface{}) error

RenderAsTable will render an interfact to table.

func RenderHistoryResults

func RenderHistoryResults(h []HistoricalExecution, outputFormat string) error

RenderHistoryResults ..

func RenderQueryResults

func RenderQueryResults(outputFormat string, query string, file *os.File) error

RenderQueryResults formats query results a in the desired format and sends to stdout

Types

type Format

type Format int

Format is an enumeration of available query output formats ENUM( json, csv, table )

type HistoricalExecution

type HistoricalExecution struct {
	Query                      string
	Catalog                    string
	Database                   string
	QueryExecutionID           string
	OutputLocation             string
	State                      string
	WorkGroup                  string
	TotalExecutionTimeInMillis int64
	DataScannedInBytes         int64
	Cost                       float64
	SubmissionDateTime         time.Time
}

HistoricalExecution ..

func ListHistory

func ListHistory(maxResults int, historyCmdWorkgroup string) (h []HistoricalExecution, err error)

ListHistory returns query results per workgroup

type Query

type Query struct {
	OutputBucket string
	OutputPrefix string
	Database     string
	SQL          string
	Format       string
	JMESPath     string
	Statistics   bool
}

Query ...

func (*Query) Execute

func (q *Query) Execute() (*os.File, error)

Execute a SQL query against Athena

func (*Query) ExecuteToStdout

func (q *Query) ExecuteToStdout() error

ExecuteToStdout executes the query and returns the results to stdout