search

RedisLabs / spark-redis

A connector for Spark that allows reading and writing to/from Redis cluster
BSD 3-Clause "New" or "Revised" License
935 stars 368 forks source link

Unable to create table using spark.sql #330

Closed karthick30121990 closed 1 year ago

karthick30121990 commented 2 years ago

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 2 years ago

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

sazzad16 commented 1 year ago

Closed due to inactivity.