org.elasticsearch.spark.sql.streaming

Class EsSparkSqlStreamingSink

java.lang.Object

org.elasticsearch.spark.sql.streaming.EsSparkSqlStreamingSink

All Implemented Interfaces:

org.apache.spark.sql.connector.catalog.Table, org.apache.spark.sql.execution.streaming.Sink

public class EsSparkSqlStreamingSink
extends java.lang.Object
implements org.apache.spark.sql.execution.streaming.Sink

Sink for writing Spark Structured Streaming Queries to an Elasticsearch cluster.

Constructor Summary

Constructors

Constructor and Description
EsSparkSqlStreamingSink(org.apache.spark.sql.SparkSession sparkSession, Settings settings)

Method Summary

Modifier and Type	Method and Description
void	addBatch(long batchId, org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> data)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.spark.sql.execution.streaming.Sink

$init$, capabilities, name, schema

Methods inherited from interface org.apache.spark.sql.connector.catalog.Table

columns, partitioning, properties

Constructor Detail

EsSparkSqlStreamingSink

public EsSparkSqlStreamingSink(org.apache.spark.sql.SparkSession sparkSession,
                               Settings settings)

Method Detail

addBatch

public void addBatch(long batchId,
                     org.apache.spark.sql.Dataset<org.apache.spark.sql.Row> data)

Specified by:

addBatch in interface org.apache.spark.sql.execution.streaming.Sink