💥 🚀 封装sparkstreaming动态调节batch time(有数据就执行计算);🚀 支持运行过程中增删topic;🚀 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。
-
Updated
Apr 15, 2021 - Scala
💥 🚀 封装sparkstreaming动态调节batch time(有数据就执行计算);🚀 支持运行过程中增删topic;🚀 封装sparkstreaming 1.6 - kafka 010 用以支持 SSL。
SparkStreaming中利用MySQL保存Kafka偏移量保证0数据丢失
Real-time Machine Learning with Apache Spark on Twitter Public Stream
Spark in Action, 2e - chapter 10 - Ingestion through structured streaming
💥 👽 ♨️🚀Encapsulated spark 与其他组件的结合api,方便使用,例如 es,hbase,kudu,kafka,mq等
A Simple Real-Time Detector of DDOS Attacks with Apache Kafka And Spark Streaming
Full poc on spark 2, Spark RDD, Spark DStream, Spark SQL, Spark Datasets & DataFrames & Spark Structured Streaming [SCALA][SPARK]
Apache Spark machine learning project using pyspark
SparkStreaming新手友好向模板,简化SparkStreaming开发
Big Data Project - SSML - Spark Streaming for Machine Learning
A Realtime Stock Portfolio Manager built using Apache Distributed Technologies!
This is a repository i have created to put up some of the knowledge i have gained around Big Data Technologies especially Spark, GraphX etc.
Add a description, image, and links to the sparkstreaming topic page so that developers can more easily learn about it.
To associate your repository with the sparkstreaming topic, visit your repo's landing page and select "manage topics."