RedisLabs/spark-redis

Unable to create table using spark.sql

karthick30121990 opened this issue · 2 comments

karthick30121990 commented

image
image

var spark = SparkSession.Builder()
.AppName("Redis-cache")
.Master("local[*]")
.Config("spark.redis.host", "localhost")
.Config("spark.redis.port", "6379")
.GetOrCreate();

DataFrame sdf = spark.Sql("CREATE TABLE IF NOT EXISTS clicks(asset STRING, count INT) USING org.apache.spark.sql.redis OPTIONS(table 'clicks',key.column 'asset')");

fe2s commented

Hi @karthick30121990, it looks like something is wrong with your classpath, Scala is missing there. How do you run it?

sazzad16 commented

Closed due to inactivity.