标签：structured-streaming

2019-03-03admin阅读(6361)评论(0)赞(4)

spark 官方对 Spark Streaming 的维护可能越来越少，Spark 2.4 版本的 Release Note （http://spark.apache.org/releases/sp ...

2018-11-28admin阅读(4389)评论(0)赞(1)

 / 引言：Spark2 时代 /  Spark 1.x 时代里，以 SparkContext（及 RDD API）为基础，在 structured data 场景衍生出了 SQ ...

2018-02-09admin阅读(1630)评论(0)赞(1)

阅读本文前，请一定先阅读 Structured Streaming 实现思路与实现概述 一文，其中概述了 Structured Streaming 的实现思路， ...

2018-02-09admin阅读(2446)评论(2)赞(0)

阅读本文前，请一定先阅读 Structured Streaming 实现思路与实现概述 一文，其中概述了 Structured Streaming 的实现思路（ ...

2018-02-09admin阅读(2287)评论(0)赞(0)

阅读本文前，请一定先阅读 Structured Streaming 实现思路与实现概述 一文，其中概述了 Structured Streaming 的实现思路（ ...

2018-02-09admin阅读(1765)评论(0)赞(0)

阅读本文前，请一定先阅读 Structured Streaming 实现思路与实现概述 一文，其中概述了 Structured Streaming 的 ...

2015-11-23admin阅读(1807)赞(0)

WatermarkSupport Contract — Unary Physical Operators with Streaming Watermark Support

2015-11-22admin阅读(1276)赞(0)

InputProcessor Helper Class of FlatMapGroupsWithStateExec Physical Operator

2015-11-21admin阅读(1619)赞(0)

EventTimeStatsAccum Accumulator EventTimeStatsAccum is a Spark accumulator of EventTimeStats from Longs (i.e. Accu ...

2015-11-20admin阅读(1918)赞(0)

UnsupportedOperationChecker UnsupportedOperationChecker checks whether the logical plan of a streaming query uses ...