public interface StreamSinkProvider
Sink
for a specific format or system.
Modifier and Type | Method and Description |
---|---|
org.apache.spark.sql.execution.streaming.Sink |
createSink(SQLContext sqlContext,
scala.collection.immutable.Map<String,String> parameters,
scala.collection.Seq<String> partitionColumns,
OutputMode outputMode) |
org.apache.spark.sql.execution.streaming.Sink createSink(SQLContext sqlContext, scala.collection.immutable.Map<String,String> parameters, scala.collection.Seq<String> partitionColumns, OutputMode outputMode)