anchor.diff:  SparkContext cfg = ...
   JavaSparkContext jsc = new JavaSparkContext(cfg);
   
  -Map<String, ?> numbers = ImmutableMap.of("one", 1, "two", 2); <2>
  +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>
  
positive.code: 
  [source,java]
  ----
  import static org.elasticsearch.spark.java.api.JavaEsSpark.*;     <1>
  
  ...
  JavaRDD<Map<String, Object>> esRDD = esRDD(jsc, "radio/artists", "?me*"); <2>
  
negative.code: [source,scala]
  ----
  val sc = new SparkContext(...)
  sc.set("spark.serializer", classOf[KryoSerializer].getName) <1>
  ----
  
  <1> Enable the Kryo serialization support with Spark
  