@@ -38,7 +38,7 @@ Grab the latest nightly build from the [repository](http://oss.sonatype.org/cont
3838<dependency >
3939 <groupId >org.elasticsearch</groupId >
4040 <artifactId >elasticsearch-hadoop</artifactId >
41- <version >7.8.0 -SNAPSHOT</version >
41+ <version >7.8.1 -SNAPSHOT</version >
4242</dependency >
4343```
4444
@@ -243,10 +243,10 @@ val playlist = df.filter(df("category").equalTo("pikes").and(df("year").geq(2016
243243Import the ` org.elasticsearch.spark._ ` package to gain ` savetoEs ` methods on your ` RDD ` s:
244244
245245``` scala
246- import org .elasticsearch .spark ._
246+ import org .elasticsearch .spark ._
247247
248248val conf = ...
249- val sc = new SparkContext (conf)
249+ val sc = new SparkContext (conf)
250250
251251val numbers = Map (" one" -> 1 , " two" -> 2 , " three" -> 3 )
252252val airports = Map (" OTP" -> " Otopeni" , " SFO" -> " San Fran" )
@@ -271,11 +271,11 @@ In a Java environment, use the `org.elasticsearch.spark.rdd.java.api` package, i
271271To read data from ES, create a dedicated ` RDD ` and specify the query as an argument.
272272
273273``` java
274- import org.apache.spark.api.java.JavaSparkContext ;
274+ import org.apache.spark.api.java.JavaSparkContext ;
275275import org.elasticsearch.spark.rdd.api.java.JavaEsSpark ;
276276
277277SparkConf conf = ...
278- JavaSparkContext jsc = new JavaSparkContext (conf);
278+ JavaSparkContext jsc = new JavaSparkContext (conf);
279279
280280JavaPairRDD<String , Map<String , Object > > esRDD = JavaEsSpark . esRDD(jsc, " radio/artists" );
281281```
@@ -297,7 +297,7 @@ import org.elasticsearch.spark.rdd.api.java.JavaEsSpark;
297297SparkConf conf = ...
298298JavaSparkContext jsc = new JavaSparkContext (conf);
299299
300- Map<String , ?> numbers = ImmutableMap . of(" one" , 1 , " two" , 2 );
300+ Map<String , ?> numbers = ImmutableMap . of(" one" , 1 , " two" , 2 );
301301Map<String , ?> airports = ImmutableMap . of(" OTP" , " Otopeni" , " SFO" , " San Fran" );
302302
303303JavaRDD<Map<String , ?> > javaRDD = jsc. parallelize(ImmutableList . of(numbers, airports));
0 commit comments