anchor.diff:  
   [source,java]
   ----
  -import static org.elasticsearch.spark.rdd.java.api.JavaEsSpark;                <1>
  +import static org.elasticsearch.spark.rdd.api.java.JavaEsSpark;                <1>
   ...
   
   TripBean upcoming = new TripBean("OTP", "SFO");
  
positive.code: 
  [source,java]
  ----
  import org.elasticsearch.spark.rdd.java.api.JavaEsSpark;
  
  // data to be saved
  Map<String, ?> otp = ImmutableMap.of("iata", "OTP", "name", "Otopeni");
  
negative.code: [source,java]
  ----
  import org.apache.spark.api.java.JavaSparkContext;               <1>
  import org.elasticsearch.spark.rdd.api.java.JavaEsSpark;             <2>
  ...
  
  SparkConf conf = ...
  