/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

7 votes129 views4 answers
Date format in java
Java
0 vote134 views1 answer
Why to use serializable with java bean
Java
0 vote127 views1 answer
Print out whole array java
Java
20 votes134 views4 answers
Android java toast
Java
0 vote170 views2 answers
Single line comment in java
Java
1 vote137 views1 answer
Chemistry formula on Android
Java
2 votes144 views5 answers
True
Java
1 vote142 views1 answer
Java isolate the numbers from string
Java
1 vote147 views2 answers
Java compare char
Java
0 vote83 views1 answer
Java.lang.RuntimeException: Duplicate class com.google.common.util.concurrent.ListenableFuture found in modules guava-20.0.jar (com.google.guava:guava:20.0) and listenablefuture-1.0.jar (com.google.guava:listenablefuture:1.0)
Java