Documentation ¶
Index ¶
- func Results(client athenaiface.AthenaAPI, queryID string, nextToken *string, ...) (queryResult *athena.GetQueryResultsOutput, err error)
- func RunQuery(client athenaiface.AthenaAPI, workgroup, database, sql string) (*athena.GetQueryResultsOutput, error)
- func StartQuery(client athenaiface.AthenaAPI, workgroup, database, sql 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)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Results ¶ added in v1.1.0
func Results(client athenaiface.AthenaAPI, queryID string, nextToken *string, maxResults *int64) (queryResult *athena.GetQueryResultsOutput, err error)
func RunQuery ¶ added in v1.1.0
func RunQuery(client athenaiface.AthenaAPI, workgroup, database, sql string) (*athena.GetQueryResultsOutput, error)
RunQuery executes query, blocking until done
func StartQuery ¶ added in v1.1.0
func StartQuery(client athenaiface.AthenaAPI, workgroup, database, sql string) (*athena.StartQueryExecutionOutput, error)
func Status ¶ added in v1.1.0
func Status(client athenaiface.AthenaAPI, queryExecutionID string) (executionOutput *athena.GetQueryExecutionOutput, err error)
func StopQuery ¶ added in v1.1.0
func StopQuery(client athenaiface.AthenaAPI, queryExecutionID string) (executionOutput *athena.StopQueryExecutionOutput, err error)
func WaitForResults ¶ added in v1.1.0
func WaitForResults(client athenaiface.AthenaAPI, queryExecutionID string) (queryResult *athena.GetQueryResultsOutput, err error)
Types ¶
This section is empty.
Click to show internal directories.
Click to hide internal directories.