README.Rmd

---
title: "sparkworker: R Worker for Apache Spark"
output:
  github_document:
    fig_width: 9
    fig_height: 5
---

```{r}
library(sparkworker)
library(sparklyr)

sc <- spark_connect(master = "local", version = "2.0.1")
iris_tbl <- copy_to(sc, iris)

spark_lapply(iris_tbl, function(rows) {
  rows$Petal_Width <- rows$Petal_Width + 1
  rows
})

spark_disconnect(sc)
```