/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

1 vote338 views1 answer
How to generate a random number in libgdx
Java
0 vote358 views1 answer
Java check palindrome with string builder
Java
2 votes385 views1 answer
Spigot how to make an inventory
Java
0 vote343 views1 answer
Java pause program until key pressed
Java
0 vote361 views1 answer
Nikita kaksharov
Java
0 vote305 views1 answer
Number to int java
Java
-2 votes364 views2 answers
No enclosing instance of type Foo is accessible. Must qualify the allocation with an enclosing instance of type Foo (e.g. x.new A() where x is an instance of Foo
Java
2 votes326 views2 answers
What is spring boot
Java
0 vote347 views1 answer
Array pocket in java
Java
0 vote329 views2 answers
Java print 2d array row and column
Java