File tree Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Expand file tree Collapse file tree 1 file changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -281,7 +281,7 @@ To read data from ES, create a dedicated `RDD` and specify the query as an argum
281
281
282
282
``` java
283
283
import org.apache.spark.api.java.JavaSparkContext ;
284
- import org.elasticsearch.spark.rdd.java. api.JavaEsSpark ;
284
+ import org.elasticsearch.spark.rdd.api.java .JavaEsSpark ;
285
285
286
286
SparkConf conf = ...
287
287
JavaSparkContext jsc = new JavaSparkContext (conf);
@@ -301,7 +301,7 @@ DataFrame playlist = df.filter(df.col("category").equalTo("pikes").and(df.col("y
301
301
302
302
Use ` JavaEsSpark ` to index any ` RDD ` to Elasticsearch:
303
303
``` java
304
- import org.elasticsearch.spark.java .api.JavaEsSpark ;
304
+ import org.elasticsearch.spark.rdd .api.java .JavaEsSpark ;
305
305
306
306
SparkConf conf = ...
307
307
JavaSparkContext jsc = new JavaSparkContext (conf);
@@ -316,7 +316,7 @@ JavaEsSpark.saveToEs(javaRDD, "spark/docs");
316
316
#### Spark SQL
317
317
318
318
``` java
319
- import org.elasticsearch.spark.sql.java. api.JavaEsSparkSQL ;
319
+ import org.elasticsearch.spark.sql.api.java .JavaEsSparkSQL ;
320
320
321
321
DataFrame df = sqlContext. read. json(" examples/people.json" )
322
322
JavaEsSparkSQL . saveToES(df, " spark/docs" )
You can’t perform that action at this time.
0 commit comments