@Test @Ignore public void saveToEs() { Map<String, ?> numbers = ImmutableMap.of("one", 11, "two", 22); Map<String, ?> airports = ImmutableMap.of("OTP", "Otopeni1", "SFO", "San Fran1"); JavaRDD<Map<String, ?>> javaRDD = jsc.parallelize(ImmutableList.of(numbers, airports)); indexer.saveRDDToEs(javaRDD, "spark/docs"); }
void saveRDDToEs(JavaRDD javaRDD, String docName) { JavaEsSpark.saveToEs(javaRDD, docName); }
Indexer { void saveRDDToEs(JavaRDD javaRDD, String docName) { JavaEsSpark.saveToEs(javaRDD, docName); } }
Indexer { void saveRDDToEs(JavaRDD javaRDD, String docName) { JavaEsSpark.saveToEs(javaRDD, docName); }  }
Indexer { void saveRDDToEs(JavaRDD javaRDD, String docName) { JavaEsSpark.saveToEs(javaRDD, docName); }   }
Indexer { void saveRDDToEs(JavaRDD javaRDD, String docName) { JavaEsSpark.saveToEs(javaRDD, docName); }    }