Package org.apache.spark.sql.sources

Interface StreamSinkProvider

public interface StreamSinkProvider
::Experimental:: Implemented by objects that can produce a streaming Sink for a specific format or system.

Since:
2.0.0

  • Method Summary

    Modifier and Type
    Method
    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)
     

  • Method Details

    • createSink

      org.apache.spark.sql.execution.streaming.Sink createSink(SQLContext sqlContext, scala.collection.immutable.Map<String,String> parameters, scala.collection.Seq<String> partitionColumns, OutputMode outputMode)