Awesome Open Source

Programming Languages

Search results for structured streaming

structured-streaming x

23 search results found

Coolplayspark ⭐ 3,447

酷玩 Spark: Spark 源代码解析、Spark 类库等

Learningsparkv2 ⭐ 570

This is the github repo for Learning Spark: Lightning-Fast Data Analytics [2nd Edition]

Azure Event Hubs Spark ⭐ 225

Enabling Continuous Data Processing with Apache Spark and Azure Event Hubs

Spark Structured Streaming Examples ⭐ 153

Spark Structured Streaming / Kafka / Cassandra / Elastic

Kinesis Sql ⭐ 135

Kinesis Connector for Structured Streaming

Pulsar Spark ⭐ 103

Spark Connector to read and write with Pulsar

Spark States ⭐ 88

Custom state store providers for Apache Spark

Fink Broker ⭐ 66

Astronomy Broker based on Apache Spark

Kafka Streaming Click Analysis ⭐ 56

Use Kafka and Apache Spark streaming to perform click stream analytics

Financial Market Data Analysis ⭐ 39

Real-Time Financial Market Data Processing and Prediction application

Pysparkcheatsheet ⭐ 30

PySpark Cheatsheet

Spark Structured Streaming Examples ⭐ 25

Spark structured streaming examples with using of version 3.4.0

Open Stream Processing Benchmark ⭐ 24

This repository contains the code base for the Open Stream Processing Benchmark.

Spark State Tools ⭐ 22

Spark Structured Streaming State Tools

Telemetry Streaming ⭐ 15

Spark Streaming ETL jobs for Mozilla Telemetry

Spark Gdelt ⭐ 15

Binding the GDELT universe in a Spark environment

Spark Sql Kafka Offset Committer ⭐ 15

Kafka offset committer for structured streaming query

Wow Spark ⭐ 13

🔆 spark自学手册，包含了例如spark core、spark sql、spark streaming、spark-kafka、delta-lake，以及scala基础练习，还有一些例

Structured Streaming Application ⭐ 10

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.

Spark State Store ⭐ 10

Rocksdb state storage implementation for Structured Streaming.

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.

Structured Streaming Cassandra Sink ⭐ 7

An example of how to create and use Cassandra sink in Spark Structured Streaming application

Spark Connector Test ⭐ 6

A tutorial on how to use pulsar-spark-connector

1-23 of 23 search results

Privacy | About | Terms | Follow Us On Twitter

Copyright 2018-2024 Awesome Open Source. All rights reserved.