R/presto.R

In YTLogos/exploratory: R package for Exploratory

#' @export
queryPresto <- function(host, port, username, password, schema, catalog, numOfRows = -1, query){

  # read stored password
  pass = saveOrReadPassword("presto", username, password)
  drv <- RPresto::Presto()
  conn <- RPresto::dbConnect(drv, user = username,
                                password = pass, host = host, port = port, schema = schema, catalog = catalog, session.timezone = Sys.timezone(location = TRUE))
  resultSet <- RPresto::dbSendQuery(conn, GetoptLong::qq(query))
  df <- DBI::dbFetch(resultSet, n = numOfRows)
  RPresto::dbClearResult(resultSet)
  RPresto::dbDisconnect(conn)
  df
}