CODE EXAMPLE FOR JAVA

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");