All functions

dbWriteTable(<AthenaConnection>,<character>,<data.frame>) dbWriteTable(<AthenaConnection>,<Id>,<data.frame>) dbWriteTable(<AthenaConnection>,<SQL>,<data.frame>)

Convenience functions for reading/writing DBMS tables

dbSendQuery(<AthenaConnection>,<character>) dbSendStatement(<AthenaConnection>,<character>) dbExecute(<AthenaConnection>,<character>)

Execute a query on Athena

RAthena-package

RAthena: a DBI interface into Athena using Boto3 SDK

RAthena_options()

A method to configure RAthena backend options.

assume_role()

Assume AWS ARN Role

athena()

Athena Driver

db_save_query.AthenaConnection() db_explain.AthenaConnection() db_query_fields.AthenaConnection()

Athena S3 implementation of dbplyr backend functions

dbClearResult(<AthenaResult>)

Clear Results

dbColumnInfo(<AthenaResult>)

Information about result types

dbConnect(<AthenaDriver>)

Connect to Athena using python's sdk boto3

dbConvertTable()

Simple wrapper to convert Athena backend file types

dbDataType(<AthenaDriver>,<ANY>) dbDataType(<AthenaDriver>,<list>) dbDataType(<AthenaConnection>,<ANY>) dbDataType(<AthenaConnection>,<data.frame>)

Determine SQL data type of object

dbDisconnect(<AthenaConnection>)

Disconnect (close) an Athena connection

dbExistsTable(<AthenaConnection>,<character>)

Does Athena table exist?

dbFetch(<AthenaResult>)

Fetch records from previously executed query

dbGetInfo(<AthenaConnection>) dbGetInfo(<AthenaResult>)

Get DBMS metadata

dbGetPartition()

Athena table partitions

dbGetQuery(<AthenaConnection>,<character>)

Send query, retrieve results and then clear result set

dbGetTables()

List Athena Schema, Tables and Table Types

dbHasCompleted(<AthenaResult>)

Completion status

dbIsValid(<AthenaConnection>) dbIsValid(<AthenaResult>)

Is this DBMS object still valid?

dbListFields(<AthenaConnection>,<character>)

List Field names of Athena table

dbListTables(<AthenaConnection>)

List Athena Tables

dbQuoteString(<AthenaConnection>,<character>) dbQuoteIdentifier(<AthenaConnection>,<SQL>)

Quote Identifiers

dbRemoveTable(<AthenaConnection>,<character>)

Remove table from Athena

dbShow()

Show Athena table's DDL

dbStatistics()

Show AWS Athena Statistics

db_compute.AthenaConnection()

S3 implementation of db_compute for Athena

db_copy_to.AthenaConnection()

S3 implementation of db_copy_to for Athena

db_desc.AthenaConnection()

S3 implementation of db_desc for Athena

install_boto()

Install Amazon SDK boto3 for Athena connection

get_session_token()

Get Session Tokens for Boto3 Connection

sqlCreateTable(<AthenaConnection>)

Creates query to create a simple Athena table

sqlData(<AthenaConnection>)

Converts data frame into suitable format to be uploaded to Athena

sql_translate_env.AthenaConnection() sql_escape_string.AthenaConnection()

AWS Athena backend dbplyr

create_work_group() tag_options() delete_work_group() list_work_groups() get_work_group() update_work_group()

Athena Work Groups