spark技术分享StreamSinkProvider
StreamSinkProvider is the contract for creating streaming sinks for a specific format or system.
StreamSinkProvider defines the one and only createSink method that creates a streaming sink.
|
1 2 3 4 5 6 7 8 9 10 11 12 13 |
package org.apache.spark.sql.sources trait StreamSinkProvider { def createSink( sqlContext: SQLContext, parameters: Map[String, String], partitionColumns: Seq[String], outputMode: OutputMode): Sink } |
