/Java/Adding new field in existing kibana index using spark java

Adding new field in existing kibana index using spark java

val game = Map(
  "media_type"->"game", 
      "title" -> "FF VI",
       "year" -> "1994")
val book = Map("media_type" -> "book","title" -> "Harry Potter","year" -> "2010")
val cd = Map("media_type" -> "music","title" -> "Surfing With The Alien")

sc.makeRDD(Seq(game, book, cd)).saveToEs("my-collection-{media_type}/doc")

Source: elastic.co

Adding new field in existing kibana index using spark java

String json1 = "{\"reason\" : \"business\",\"airport\" : \"SFO\"}";  
String json2 = "{\"participants\" : 5,\"airport\" : \"OTP\"}";

JavaSparkContext jsc = ...
JavaRDD<String> stringRDD = jsc.parallelize(ImmutableList.of(json1, json2)); 
JavaEsSpark.saveJsonToEs(stringRDD, "spark/json-trips");

Source: elastic.co

Similar codes

2 votes265 views1 answer
Edittext color
Java
0 vote272 views1 answer
How to install java on ubuntu 18.0.4
Java
1 vote292 views1 answer
Find Minimum in Rotated Sorted Array
Java
0 vote287 views1 answer
Https://www.baeldung.com/java-stream-findfirst-vs-findany
Java
1 vote264 views1 answer
Java 8 filter first
Java
1 vote287 views2 answers
How to use string variables with an if statement in java
Java
1 vote285 views1 answer
Java time type
Java
0 vote286 views1 answer
Build path specifies execution environment JavaSE-1.8. There are no JREs installed in the workspace that are strictly compatible with this environment.
Java
0 vote294 views1 answer
Java get file from url
Java
2 votes295 views1 answer
Java.lang.arrayindexoutofboundsexception: index 3 out of bounds for length 3
Java