Here are
68 public repositories
matching this topic...
酷玩 Spark: Spark 源代码解析、Spark 类库等
Updated
May 26, 2019
Scala
The Internals of Spark Structured Streaming
Spark Structured Streaming / Kafka / Cassandra / Elastic
Updated
Oct 1, 2018
Scala
Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs
Updated
Sep 1, 2020
Scala
This is the github repo for Learning Spark: Lightning-Fast Data Analytics [2nd Edition]
Updated
Sep 3, 2020
Scala
Custom state store providers for Apache Spark
Updated
Aug 31, 2020
Scala
Use Kafka and Apache Spark streaming to perform click stream analytics
Updated
Feb 29, 2020
Jupyter Notebook
How to build your first Spark application with MLlib, StructuredStreaming, GraphFrames, Datasets and so on? Answer is here!
Updated
Nov 5, 2019
Scala
When Apache Pulsar meets Apache Spark
Updated
Feb 27, 2020
Scala
Spark Structured Streaming State Tools
Updated
Jul 3, 2020
Scala
Spark structured streaming examples with using of version 3.0.0
Updated
Sep 2, 2019
Scala
Spark Streaming ETL jobs for Mozilla Telemetry
Updated
Dec 5, 2019
Scala
🔆 spark自学手册,包含了例如spark core、spark sql、spark streaming、spark-kafka、delta-lake,以及scala基础练习,还有一些例如master、shuffle源码分析,总结及翻译。
Updated
Jun 21, 2020
Scala
Binding the GDELT universe in a Spark environment
Updated
Aug 21, 2020
Scala
Spark 3.0.0 Structured Streaming Kafka Avro Demo
Updated
Jun 19, 2020
Java
Kafka offset committer for structured streaming query
Updated
Jun 28, 2020
Scala
Structured Streaming is a reference application showing how to easily integrate structured streaming Apache Spark Structured Streaming, Apache Cassandra and Apache Kafka for fast, structured streaming computations on data.
Updated
Nov 17, 2018
Scala
Astronomy Broker based on Apache Spark
Updated
Aug 27, 2020
Python
This test program uses structured streaming of spark, receive message that is json type from kafka, then get counts of DNS for every people In one minute. (I think one source Ip addr is one people). Finally, the result will insert to mysql database.
Updated
Aug 7, 2017
Scala
kafka + structured streaming + phoenix + elasticsearch 基于行为日志实现热门推荐,用户偏好推荐,召回融合策略实现。
Updated
Jan 21, 2020
Scala
An example of how to create and use Cassandra sink in Spark Structured Streaming application
Updated
Oct 6, 2018
Scala
A tutorial on how to use pulsar-spark-connector
Updated
Jul 19, 2019
Scala
Qubole Streaminglens tool for tuning Spark Structured Streaming Pipelines
Updated
Jan 21, 2020
Scala
Updated
Jul 2, 2020
Scala
Rocksdb state storage implementation for Structured Streaming.
Updated
May 15, 2020
Scala
spark-cassandra-sink is a Spark Structured Streaming Sink for cassandra
Updated
Jan 2, 2019
Scala
Efficiently tackle large datasets and perform big data analysis with Spark and Python
Updated
Jan 11, 2019
Python
Examples of Apache Spark Structured Streaming
Updated
Sep 23, 2018
Scala
Real-Time Financial Market Data Processing and Prediction application
Updated
May 31, 2020
Python
Improve this page
Add a description, image, and links to the
structured-streaming
topic page so that developers can more easily learn about it.
Curate this topic
Add this topic to your repo
To associate your repository with the
structured-streaming
topic, visit your repo's landing page and select "manage topics."
Learn more
You can’t perform that action at this time.
You signed in with another tab or window. Reload to refresh your session.
You signed out in another tab or window. Reload to refresh your session.
I am able to use consume the Kinesis stream using this jar as a normal consumer. When i updated the user account to Enhanced fan out consumer, i am unable to access the stream.
Do we have any way to access the stream as Enhanced fan out consumer?