Skip to content

Commit f1e94a6

Browse files
wypbjbaiera
authored andcommitted
Update spark.adoc (elastic#821)
Fix typo
1 parent 322117e commit f1e94a6

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

docs/src/reference/asciidoc/core/spark.adoc

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -314,7 +314,7 @@ val sfo = Map("iata" -> "SFO", "name" -> "San Fran")
314314
val sc = ...
315315
316316
val airportsRDD<1> = sc.makeRDD(Seq((1, otp), (2, muc), (3, sfo))) <2>
317-
pairRDD.saveToEsWithMeta<3>(airportsRDD, "airports/2015")
317+
airportsRDD.saveToEsWithMeta<3>("airports/2015")
318318
----
319319

320320
<1> +airportsRDD+ is a __key-value__ pair +RDD+; it is created from a +Seq+ of ++tuple++s
@@ -341,7 +341,7 @@ val sfoMeta = Map(ID -> 3) <4>
341341
val sc = ...
342342
343343
val airportsRDD = sc.makeRDD<5>(Seq((otpMeta, otp), (mucMeta, muc), (sfoMeta, sfo)))
344-
pairRDD.saveToEsWithMeta(airportsRDD, "airports/2015") <6>
344+
airportsRDD.saveToEsWithMeta("airports/2015") <6>
345345
----
346346

347347
<1> Import the +Metadata+ enum

0 commit comments

Comments
 (0)