当前位置：spark技术分享 > structured-streaming > 正文

ConsoleSinkProvider

2015-08-26 分类：structured-streaming 阅读(1544) 评论(0)

ConsoleSinkProvider

ConsoleSinkProvider is a DataSourceV2 with StreamWriteSupport for [spark-sql-streaming-ConsoleSink#< ConsoleSink].

ConsoleSinkProvider is a DataSourceRegister that registers the ConsoleSink streaming sink as console format.


import org.apache.spark.sql.streaming.Trigger
val q = spark
  .readStream
  .format("rate")
  .load
  .writeStream
  .format("console") // <-- requests ConsoleSinkProvider for a sink
  .trigger(Trigger.Once)
  .start
scala> println(q.lastProgress.sink)
{
  "description" : "org.apache.spark.sql.execution.streaming.ConsoleSinkProvider@edde9bb"
}

import org.apache.spark.sql.streaming.Trigger

val q = spark

.readStream

.format("rate")

.load

.writeStream

.format("console") // <-- requests ConsoleSinkProvider for a sink

.trigger(Trigger.Once)

.start

scala> println(q.lastProgress.sink)

{

"description" : "org.apache.spark.sql.execution.streaming.ConsoleSinkProvider@edde9bb"

}

赞(0) 打赏

未经允许不得转载：spark技术分享 » ConsoleSinkProvider

标签：structured-streaming

关注公众号：spark技术分享

联系我们联系我们

QQ咨询
QQ咨询
回顶
回顶部

正在加载中...

ConsoleSinkProvider

ConsoleSinkProvider

相关推荐

欢迎关注：spark技术分享

热门标签

近期文章

分类目录

关注公众号：spark技术分享

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏

QQ咨询

回顶部

ConsoleSinkProvider

相关推荐

欢迎关注：spark技术分享

热门标签

近期文章

分类目录

关注公众号：spark技术分享

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

微信扫一扫打赏

QQ咨询

回顶部

切换注册登录

用户名或邮箱

密码

切换登录注册

昵称

邮箱