SparkR Process sampledata 2/20

sc = sparkR.init()
sqlContext = sparkRSQL.init(sc)

//Rstudio

if (nchar(Sys.getenv("SPARK_HOME")) 1) {
Sys.setenv(SPARK_HOME = "/home/hadoop/work/spark-1.6.0-bin-hadoop2.6")
}
library(SparkR, lib.loc = c(file.path(Sys.getenv("SPARK_HOME"), "R", "lib")))
sc = sparkR.init(master = "local[*]", sparkEnvir = list(spark.driver.memory="2g"))
sqlContext = sparkRSQL.init(sc)

data()
head(faithful)
df = createDataFrame(sqlContext, faithful)
head(df)
registerTempTable(df, "dftable")
s = sql(sqlContext, "SELECT * FROM dftable")

Видео SparkR Process sampledata 2/20 канала Sreyobhilashi IT