import org.apache.spark.sql.{DataFrame, SaveMode, SparkSession}
import org.elasticsearch.spark.sql._
object ESDemoSqlConfigOptionSql {
def main(args: Array[String]):Unit = {
val spark = SparkSession.builder()
.appName("ESDemoSqlConfigOptionSql")
.getOrCreate()
val options =Map(
"es.index.auto.create" ->"false",
"es.nodes.wan.only" ->"false",
"es.nodes" ->"127.0.0.1:9200",
"es.net.http.user" ->"user",
"es.net.http.auth.pass" ->"pwd",
"es.mapping.id" ->"rowkey",
"es.resource" ->"targettb1/_doc"
)
val df1:DataFrame = spark.sql("select * from targettb1")
df1.saveToEs(options)
df1.write
.options(options)
.mode(SaveMode.Append)
.format("org.elasticsearch.spark.sql.DefaultSource15")
.save()
}
}
