public class EsSparkSqlStreamingSink extends Object implements org.apache.spark.sql.execution.streaming.Sink
| Constructor and Description |
|---|
EsSparkSqlStreamingSink(SparkSession sparkSession,
Settings settings) |
public EsSparkSqlStreamingSink(SparkSession sparkSession, Settings settings)
public void addBatch(long batchId,
Dataset<Row> data)
addBatch in interface org.apache.spark.sql.execution.streaming.Sink