Spark2.0 ������Redis������(scala)������redis5.0.3

          
       
        com.redislabs
           
       
        spark-redis
           
       
        2.3.1-RC1
       
      

import org.apache.spark.sql.types.{IntegerType,StringType,StructField,StructType}import org.apache.spark.sql.{SaveMode, SparkSession}object SparkReadRedis {  case class Person(name: String, age: Int)  def main(args: Array[String]): Unit = {    val spark = SparkSession.builder()      .appName("SparkReadRedis")      .master("local[*]")      .config("spark.redis.host","10.101.12.104")      .config("spark.redis.port", "6379")      .config("spark.redis.auth","aaron227") //������redis������      .config("spark.redis.db","0") //������redis���      .getOrCreate()    // ������������������redis���    val personSeq = Seq(Person("Aaron", 30), Person("Peter", 45))    val df = spark.createDataFrame(personSeq)    df.write      .format("org.apache.spark.sql.redis")      .option("table", "person")      .option("key.column", "name")      .mode(SaveMode.Overwrite)      .save()    // ���redis������������������������������������    val loadedDf = spark.read      .format("org.apache.spark.sql.redis")      .option("table", "person")      .option("key.column", "name")      .load()    loadedDf.show(false)    // ���redis������������������������������������    spark.sql(      s"""         |CREATE TEMPORARY VIEW person         |(name STRING, age INT,address STRING, salary DOUBLE)         |USING org.apache.spark.sql.redis         |OPTIONS (table 'person',key.column "name")""".stripMargin)    val loadedDf2 = spark.sql(s"SELECT * FROM person")    loadedDf2.show(false)    // ���redis������������������������������������    val loadedDf3 = spark.read      .format("org.apache.spark.sql.redis")      .schema(StructType(Array(StructField("id", IntegerType),        StructField("name", StringType), StructField("age", IntegerType))))      .option("keys.pattern", "person:*")      .option("key.column", "name")      .load()    loadedDf3.show(false)    spark.stop()  }}