spark_jobj.ts_rdd {sparklyr.flint}

Retrieve a Spark JVM Object Reference

Description

See spark_jobj for more details.

Usage

## S3 method for class 'ts_rdd'
spark_jobj(x, ...)

Arguments

x

An R object containing, or wrapping, a 'spark_jobj'.

...

Optional arguments; currently unused.

See Also

Other Spark dataframe utility functions: collect.ts_rdd(), from_rdd(), from_sdf(), spark_connection.ts_rdd(), spark_dataframe.ts_rdd(), to_sdf(), ts_rdd_builder()

Examples

library(sparklyr)
library(sparklyr.flint)

sc <- try_spark_connect(master = "local")

if (!is.null(sc)) {
  sdf <- copy_to(sc, tibble::tibble(t = seq(10), v = seq(10)))
  ts <- fromSDF(sdf, is_sorted = TRUE, time_unit = "SECONDS", time_column = "t")
  print(spark_jobj(ts))
} else {
  message("Unable to establish a Spark connection!")
}