/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

5 votes303 views4 answers
Java vs kotlin
Java
0 vote330 views1 answer
Quartz spring maven driver
Java Spring
1 vote291 views1 answer
How to sort a list of integers in java
Java
0 vote315 views1 answer
SpringBootStarter maven dependency
Java
0 vote269 views1 answer
[ERROR] Error executing Maven. java.io.FileNotFoundException: The specified user settings file does not exist: /usr/lib/jvm/java-1.8.0-openjdk-amd64
Java
0 vote306 views1 answer
Java convert LocalDateTime to long
Java
0 vote274 views1 answer
Polymorphism array with abstract class java
Java
0 vote281 views1 answer
2771270897
Java
1 vote340 views1 answer
Add text to jlable
Java
0 vote286 views1 answer
Count occurrences in seven integers using java single dimension arrays
Java