anchor.diff:  SparkConf sc = new SparkConf(); //.setMaster("local");
   sc.set("spark.serializer", KryoSerializer.class.getName()); <1>
   
  -// needed only when using the Java API      
  -JavaSparkContext jsc = new JavaSparkContext(sc);    
  +// needed only when using the Java API
  +JavaSparkContext jsc = new JavaSparkContext(sc);
   ----
   
   <1> Enable the Kryo serialization support with Spark
  
positive.code: [source,scala]
  ----
  val sc = new SparkContext(...)
  sc.set("spark.serializer", classOf[KryoSerializer].getName)    <1>
  ----
  
  <1> Enable the Kryo serialization support with Spark
  
negative.code: SparkContext cfg = ...
  JavaSparkContext jsc = new JavaSparkContext(cfg);
  
  Map<String, ?> numbers = ImmutableMap.of("one", 1, "two", 2);     <2>
  Map<String, ?> airports = ImmutableMap.of("OTP", "Otopeni", "SFO", "San Fran");
  
  JavaRDD<Map<String, ?>> javaRDD = jsc.parallelize(ImmutableList.of(doc1, doc2)); <3>
  