R Client 2.0 - Table Ops

R/rdeephaven/.gitignore

@@ -2,4 +2,6 @@ lib/cpp-client/
 lib/cpp-examples/
 lib/cpp-dependencies/local
 lib/cpp-dependencies/src
-lib/cpp-dependencies/env.sh
+lib/cpp-dependencies/env.sh
+*.o
+*.so

R/rdeephaven/DESCRIPTION

@@ -1,7 +1,7 @@
 Package: rdeephaven
 Type: Package
 Title: R Client for Deephaven Core
-Version: 1.0
+Version: 0.27.1
 Date: 2023-05-12
 Author: Deephaven Data Labs
 Maintainer: Alex Peters <alexpeters@deephaven.io>
@@ -13,7 +13,7 @@ Description: The `rdeephaven` package provides an R API for communicating with t
              and bind it to a server-side variable so you can access it from any Deephaven client. Finally, you can run Python or Groovy
              scripts on the Deephaven server, so long as your server is equipped with that capability.
 License: Apache License (== 2.0)
-Depends: R (> 4.1.2), Rcpp (>= 1.0.10), arrow (>= 12.0.0), R6 (>= 2.5.0), dplyr (>= 1.1.0)
+Depends: R (> 4.1.2), Rcpp (>= 1.0.10), arrow (>= 12.0.0), dplyr (>= 1.1.0)
 Imports: Rcpp (>= 1.0.10), arrow (>= 12.0.0), R6 (>= 2.5.0), dplyr (>= 1.1.0)
 LinkingTo: Rcpp
 Suggests: testthat (>= 3.0.0)

R/rdeephaven/NAMESPACE

@@ -1,3 +1,79 @@
-useDynLib(rdeephaven, .registration=TRUE)
-importFrom(Rcpp, evalCpp)
-exportPattern("^[[:alpha:]]+")
+# Generated by roxygen2: do not edit by hand
+
+export(agg_abs_sum)
+export(agg_avg)
+export(agg_count)
+export(agg_first)
+export(agg_last)
+export(agg_max)
+export(agg_median)
+export(agg_min)
+export(agg_percentile)
+export(agg_std)
+export(agg_sum)
+export(agg_var)
+export(agg_w_avg)
+export(merge_tables)
+export(sort)
+exportClasses(Aggregation)
+exportClasses(Client)
+exportClasses(TableHandle)
+exportMethods(abs_sum_by)
+exportMethods(agg_by)
+exportMethods(as.data.frame)
+exportMethods(as_arrow_table)
+exportMethods(as_data_frame)
+exportMethods(as_record_batch_reader)
+exportMethods(as_tibble)
+exportMethods(avg_by)
+exportMethods(bind_to_variable)
+exportMethods(close)
+exportMethods(count_by)
+exportMethods(cross_join)
+exportMethods(dhConnect)
+exportMethods(dim)
+exportMethods(drop_columns)
+exportMethods(empty_table)
+exportMethods(exact_join)
+exportMethods(first_by)
+exportMethods(group_by)
+exportMethods(head)
+exportMethods(head_by)
+exportMethods(is_static)
+exportMethods(last_by)
+exportMethods(max_by)
+exportMethods(median_by)
+exportMethods(min_by)
+exportMethods(natural_join)
+exportMethods(ncol)
+exportMethods(nrow)
+exportMethods(open_table)
+exportMethods(percentile_by)
+exportMethods(import_table)
+exportMethods(run_script)
+exportMethods(select)
+exportMethods(sort)
+exportMethods(std_by)
+exportMethods(sum_by)
+exportMethods(tail)
+exportMethods(tail_by)
+exportMethods(time_table)
+exportMethods(ungroup)
+exportMethods(update)
+exportMethods(update_view)
+exportMethods(var_by)
+exportMethods(view)
+exportMethods(w_avg_by)
+exportMethods(where)
+import(Rcpp)
+importFrom(Rcpp,evalCpp)
+importFrom(arrow,RecordBatchReader)
+importFrom(arrow,RecordBatchStreamReader)
+importFrom(arrow,Table)
+importFrom(arrow,arrow_table)
+importFrom(arrow,as_arrow_table)
+importFrom(arrow,as_record_batch_reader)
+importFrom(dplyr,as_data_frame)
+importFrom(dplyr,as_tibble)
+importFrom(magrittr,"%>%")
+useDynLib(rdeephaven, .registration = TRUE)

R/rdeephaven/R/aggregate_wrapper.R

@@ -0,0 +1,89 @@
+#' @export
+setClass(
+  "Aggregation",
+  representation(
+    .internal_rcpp_object = "Rcpp_INTERNAL_Aggregate"
+  )
+)
+
+### All of the functions below return an instance of the above class
+
+#' @export
+agg_first <- function(cols = character()) {
+  verify_string("cols", cols, FALSE)
+  return(new("Aggregation", .internal_rcpp_object = INTERNAL_agg_first(cols)))
+}
+
+#' @export
+agg_last <- function(cols = character()) {
+  verify_string("cols", cols, FALSE)
+  return(new("Aggregation", .internal_rcpp_object = INTERNAL_agg_last(cols)))
+}
+
+#' @export
+agg_min <- function(cols = character()) {
+  verify_string("cols", cols, FALSE)
+  return(new("Aggregation", .internal_rcpp_object = INTERNAL_agg_min(cols)))
+}
+
+#' @export
+agg_max <- function(cols = character()) {
+  verify_string("cols", cols, FALSE)
+  return(new("Aggregation", .internal_rcpp_object = INTERNAL_agg_max(cols)))
+}
+
+#' @export
+agg_sum <- function(cols = character()) {
+  verify_string("cols", cols, FALSE)
+  return(new("Aggregation", .internal_rcpp_object = INTERNAL_agg_sum(cols)))
+}
+
+#' @export
+agg_abs_sum <- function(cols = character()) {
+  verify_string("cols", cols, FALSE)
+  return(new("Aggregation", .internal_rcpp_object = INTERNAL_agg_abs_sum(cols)))
+}
+
+#' @export
+agg_avg <- function(cols = character()) {
+  verify_string("cols", cols, FALSE)
+  return(new("Aggregation", .internal_rcpp_object = INTERNAL_agg_avg(cols)))
+}
+
+#' @export
+agg_w_avg <- function(wcol, cols = character()) {
+  verify_string("wcol", wcol, TRUE)
+  verify_string("cols", cols, FALSE)
+  return(new("Aggregation", .internal_rcpp_object = INTERNAL_agg_w_avg(wcol, cols)))
+}
+
+#' @export
+agg_median <- function(cols = character()) {
+  verify_string("cols", cols, FALSE)
+  return(new("Aggregation", .internal_rcpp_object = INTERNAL_agg_median(cols)))
+}
+
+#' @export
+agg_var <- function(cols = character()) {
+  verify_string("cols", cols, FALSE)
+  return(new("Aggregation", .internal_rcpp_object = INTERNAL_agg_var(cols)))
+}
+
+#' @export
+agg_std <- function(cols = character()) {
+  verify_string("cols", cols, FALSE)
+  return(new("Aggregation", .internal_rcpp_object = INTERNAL_agg_std(cols)))
+}
+
+#' @export
+agg_percentile <- function(percentile, cols = character()) {
+  verify_in_unit_interval("percentile", percentile, TRUE)
+  verify_string("cols", cols, FALSE)
+  return(new("Aggregation", .internal_rcpp_object = INTERNAL_agg_percentile(percentile, cols)))
+}
+
+#' @export
+agg_count <- function(col) {
+  verify_string("col", col, TRUE)
+  return(new("Aggregation", .internal_rcpp_object = INTERNAL_agg_count(col)))
+}