anchor.diff:  val conf = new JobConf()                                <1>
   conf.set("es.resource", "radio/artists")                <2>
   conf.set("es.query", "?q=me*")                          <3>
  -val esRDD = sc.hadoopRDD(conf, classOf[EsInputFormat[Text, MapWritable]],     <4>
  +val esRDD = sc.hadoopRDD(conf, classOf[EsInputFormat[Text, MapWritable]], <4>
                                  classOf[Text], classOf[MapWritable]))
   val docCount = esRDD.count();
   ----
  
positive.code: 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);    
  ----
  
  <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>
  