awsathena

Documentation

Index

• func Results(client athenaiface.AthenaAPI, queryID string, nextToken *string, ...) (queryResult *athena.GetQueryResultsOutput, err error)
• func RunQuery(client athenaiface.AthenaAPI, database, sql string, s3Path *string) (*athena.GetQueryResultsOutput, error)
• func StartQuery(client athenaiface.AthenaAPI, database, sql string, s3Path *string) (*athena.StartQueryExecutionOutput, error)
• func Status(client athenaiface.AthenaAPI, queryExecutionID string) (executionOutput *athena.GetQueryExecutionOutput, err error)
• func StopQuery(client athenaiface.AthenaAPI, queryExecutionID string) (executionOutput *athena.StopQueryExecutionOutput, err error)
• func WaitForResults(client athenaiface.AthenaAPI, queryExecutionID string) (queryResult *athena.GetQueryResultsOutput, err error)
• func WorkgroupAssociateS3(sess *session.Session, name, s3Bucket string) (err error)

Functions

func Results

func Results(client athenaiface.AthenaAPI, queryID string, nextToken *string,
	maxResults *int64) (queryResult *athena.GetQueryResultsOutput, err error)

func RunQuery

func RunQuery(client athenaiface.AthenaAPI, database, sql string, s3Path *string) (*athena.GetQueryResultsOutput, error)

RunQuery executes query, blocking until done

func StartQuery

func StartQuery(client athenaiface.AthenaAPI, database, sql string, s3Path *string) (*athena.StartQueryExecutionOutput, error)

func Status

func Status(client athenaiface.AthenaAPI, queryExecutionID string) (executionOutput *athena.GetQueryExecutionOutput, err error)

func StopQuery

func StopQuery(client athenaiface.AthenaAPI, queryExecutionID string) (executionOutput *athena.StopQueryExecutionOutput, err error)

func WaitForResults

func WaitForResults(client athenaiface.AthenaAPI, queryExecutionID string) (queryResult *athena.GetQueryResultsOutput, err error)

func WorkgroupAssociateS3

func WorkgroupAssociateS3(sess *session.Session, name, s3Bucket string) (err error)

WorkgroupAssociateS3 associates the S3 bucket with named workgroup