@@ -38,7 +38,7 @@ Grab the latest nightly build from the [repository](http://oss.sonatype.org/cont
38
38
<dependency >
39
39
<groupId >org.elasticsearch</groupId >
40
40
<artifactId >elasticsearch-hadoop</artifactId >
41
- <version >7.8.0 -SNAPSHOT</version >
41
+ <version >7.8.1 -SNAPSHOT</version >
42
42
</dependency >
43
43
```
44
44
@@ -243,10 +243,10 @@ val playlist = df.filter(df("category").equalTo("pikes").and(df("year").geq(2016
243
243
Import the ` org.elasticsearch.spark._ ` package to gain ` savetoEs ` methods on your ` RDD ` s:
244
244
245
245
``` scala
246
- import org .elasticsearch .spark ._
246
+ import org .elasticsearch .spark ._
247
247
248
248
val conf = ...
249
- val sc = new SparkContext (conf)
249
+ val sc = new SparkContext (conf)
250
250
251
251
val numbers = Map (" one" -> 1 , " two" -> 2 , " three" -> 3 )
252
252
val 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
271
271
To read data from ES, create a dedicated ` RDD ` and specify the query as an argument.
272
272
273
273
``` java
274
- import org.apache.spark.api.java.JavaSparkContext ;
274
+ import org.apache.spark.api.java.JavaSparkContext ;
275
275
import org.elasticsearch.spark.rdd.api.java.JavaEsSpark ;
276
276
277
277
SparkConf conf = ...
278
- JavaSparkContext jsc = new JavaSparkContext (conf);
278
+ JavaSparkContext jsc = new JavaSparkContext (conf);
279
279
280
280
JavaPairRDD<String , Map<String , Object > > esRDD = JavaEsSpark . esRDD(jsc, " radio/artists" );
281
281
```
@@ -297,7 +297,7 @@ import org.elasticsearch.spark.rdd.api.java.JavaEsSpark;
297
297
SparkConf conf = ...
298
298
JavaSparkContext jsc = new JavaSparkContext (conf);
299
299
300
- Map<String , ?> numbers = ImmutableMap . of(" one" , 1 , " two" , 2 );
300
+ Map<String , ?> numbers = ImmutableMap . of(" one" , 1 , " two" , 2 );
301
301
Map<String , ?> airports = ImmutableMap . of(" OTP" , " Otopeni" , " SFO" , " San Fran" );
302
302
303
303
JavaRDD<Map<String , ?> > javaRDD = jsc. parallelize(ImmutableList . of(numbers, airports));
0 commit comments