Description Usage Arguments See Also Examples
See spark_jobj
for more details.
1 2 | ## S3 method for class 'ts_rdd'
spark_jobj(x, ...)
|
x |
An R object containing, or wrapping, a 'spark_jobj'. |
... |
Optional arguments; currently unused. |
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()
1 2 3 4 5 6 7 8 9 10 11 12 | 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!")
}
|
Add the following code to your website.
For more information on customizing the embed code, read Embedding Snippets.