@@ -19,14 +19,14 @@ ES-Hadoop 2.0.x and 2.1.x are compatible with Elasticsearch __1.X__ *only*
1919
2020## Installation
2121
22- ### Stable Release (currently ` 7.9.0 ` )
22+ ### Stable Release (currently ` 7.9.1 ` )
2323Available through any Maven-compatible tool:
2424
2525``` xml
2626<dependency >
2727 <groupId >org.elasticsearch</groupId >
2828 <artifactId >elasticsearch-hadoop</artifactId >
29- <version >7.9.0 </version >
29+ <version >7.9.1 </version >
3030</dependency >
3131```
3232or as a stand-alone [ ZIP] ( http://www.elastic.co/downloads/hadoop ) .
@@ -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.9.0 -SNAPSHOT</version >
41+ <version >7.9.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