jlafall

import org.apache.spark.sql.SparkSession
import org.apache.spark.sql.functions._

object WordCountKafkaCouchbase {
  def main(args: Array[String]) {
    // create spark session with settings
    val spark = SparkSession
      .builder
      .appName("Word Count Test")
      .config("spark.couchbase.username", "[username goes here]")