/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

0 vote132 views1 answer
Used by: java.time.format.DateTimeParseException: Text 'Fri Jan 07 13:37:48 EET 2022' could not be parsed at index 0
Java
0 vote128 views1 answer
Spring security default username
Java Spring
7 votes142 views2 answers
Convert arraylist of integers to array primitive
Java
0 vote148 views1 answer
Java print method
Java
0 vote187 views1 answer
Bukkit for every player
Java
0 vote124 views1 answer
How to add a command to a button java
Java
22 votes122 views6 answers
Height of Binary tree
Java
0 vote125 views1 answer
How to create a boolean list in java
Java
0 vote131 views1 answer
Linux daemon
Java
0 vote108 views1 answer
Can i call another function from main hava
Java