Awesome Open Source

Programming Languages

Search results for scala streaming

282 search results found

Sparklearning_nodata ⭐ 10

SparkLearning_NoData, including code,pom and so on

Sparkstr ⭐ 10

Spark Streaming jobs.

Circe Iteratee ⭐ 10

Streaming JSON processing for circe with iteratees

Gihyo Spark Book Example ⭐ 10

技術評論社「詳解Apache Spark」のサンプルコード

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.

Streaming algorithms for a data-driven age.

Confluent Platform Spark Streaming ⭐ 10

Working example of consuming Avro data from Kafka with Spark Streaming

Twittertrends ⭐ 10

Get Twitter trends with twitter4j, stream it to a Kafka topic, save it to MongoDB and visualize in Google Maps

All Aboard ⭐ 9

Almost-realtime streaming APIs for train departure statuses

Spark Streaming Mqtts ⭐ 9

Spark Streaming receiver that supports MQTT over TLS v1.2 with X.509 client certificate based authentication.

Json Parser ⭐ 9

Cassandra Summit Demo ⭐ 9

Hadoop integration demo for the Cassandra Summit

Streaming Ocr ⭐ 9

A look at OCR within Akka Streams

Akka Stream Full Project ⭐ 9

Complete project using Akka Stream with Error Handling and ~100% Test Coverage

Proteus Engine ⭐ 9

Proteus engine contains an overhauled version of Apache Flink supporting hybrid computation on batch datasets and data streams. Please refer to wiki for further details.

Streaming With Chunked Responses ⭐ 9

streaming via chunked responses without the 'Throbber of Doom'

Cassandra Sink Spark Structured Streaming ⭐ 8

Unoffical sink for cassandra for spark structured streaming

Twitch Streamer ⭐ 8

Spark Streaming library for reading chat messages from Twitch.tv

Pro Spark Streaming ⭐ 8

Source code for 'Pro Spark Streaming' by Zubair Nabi

Adtech Dash ⭐ 8

A Scalable Ad Classification Pipeline, REST API, and Visualization, using Apache Spark, Apache Kafka, Apache HBase, Scalatra, Amazon Web Services, Highcharts

Mapr Es Db Spark Payment ⭐ 8

Sparkstreamingetl ⭐ 8

Project to create configurable ETL via lightbend configuration using Spark 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.

Kafka Scala Api ⭐ 8

Samples for using Kafka within Spark Streaming and Akka Actors, Akka Streams

Iot Trucking App Spark Structured Streaming ⭐ 8

IoT Trucking App with Spark Structured Streaming

streaming XML transformations

Kafkaoffshore ⭐ 7

Kafka, CouchDB and Friends: A test flight beyond the shore

Openmrs Etl ⭐ 7

openmrs - mysql - debezium - kafka - spark - scala

Bigdata Essentials ⭐ 7

All big data related tools/frameworks in once central repo.

Divolte Spark ⭐ 7

Utilities for using data created by Divolte collector in Spark, Spark Streaming and PySpark

Spark Streaming Kafka Cassandra Starter ⭐ 7

Application built on Spark Streaming, Kafka and Cassandra.

Streaming Pipeline ⭐ 7

A real-time text classification based on Kafka and Spark.

Spark Streaming Mqtt With Security_2.10 1.3.0 ⭐ 7

This is a fork of Spark streaming mqtt receiver from http://repo1.maven.org/maven2/org/apache/spark/spa with a security support

My solution to a coding challenge

Spark Alarm ⭐ 7

Alerting and monitoring tool for Apache Spark

Bullet Spark ⭐ 7

The Apache Spark Streaming implementation of the Bullet backend

Sensoranalytics ⭐ 7

Spark Streaming Kafka 010 Demo ⭐ 7

Structured Streaming Cassandra Sink ⭐ 7

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

Insight18b Sparksql Array ⭐ 6

Repo of my Insight project. Extended SparkSQL functionality internally and tested its performance against UDFs. Additionally, implemented a batch pipeline HDFS->SparkSQL->MySQL->Flask and a streaming pipeline Kafka->Spark Streaming->MySQL->Flask to analyze Amazon User Data.

Stock_stream_processing ⭐ 6

Stock Trade Analytics leveraging Spark Structured Stream Processing

Kamu Engine Spark ⭐ 6

Spark application for streaming transactional transformations between datasets

Rdbc Examples ⭐ 6

Examples of rdbc usage

Mezzanine ⭐ 6

Mezzanine is a library built on Spark Streaming used to consume data from Kafka and store it into Hadoop.

Errorsnrt ⭐ 6

NRT detection of web-traffic anomalies using Flume, Spark Streaming and Impala

Spark Streaming Hbase Workshop ⭐ 6

Odsc West Streaming Trends ⭐ 6

All Data, Relevant Information, Scripts, and Applications for the Open Data Science Conference (2018)

Spark Streaming Gnip ⭐ 6

An Apache Spark utility for pulling Tweets from Gnip's PowerTrack in realtime

A simple service for streaming session aggregation

Spark Social ⭐ 6

Reactive Social Trending

Flink Speculative Modelserver ⭐ 6

Speculative model serving with Flink

Spark_codebase ⭐ 6

Collection of Spark core, streaming, sql, mllib examples & applications with base line unit tests

Spark Streaming ⭐ 6

The official repository for the Rock the JVM Spark Streaming course

Streamline Platform ⭐ 6

This repository contains the Streamlin platform. It is a fork of Apache Flink featuring side input implementation, which enables hybrid computation between data-at-rest and data-in-motion.

Spark Kafka Rules Engine ⭐ 6

Business rules engine for Apache spark streaming

Streaming Gmm ⭐ 5

This repository contains my MSc dissertation project. Iti s an implementation of a streaming GMM algorithm in Spark.

Batch streaming extension (and scalaz.stream integration) for Apache Spark.

Spark Streaming Kafka 0 10 Connector ⭐ 5

A Kafka 0.10 connector for Spark 1.x Streaming

Raspi Spark Streaming Mqtt ⭐ 5

The basic purpose of this project is that the raspberryPi sends the temperature event to the server and spark streams the data using the spark streaming

Tweetstreamingandprocessing ⭐ 5

Sample app to stream twitter tweet and process them using akka and akka-streams

Gnip Consumer ⭐ 5

Consuming Gnip streaming API using Akka HTTP / Streams 2.4.2

Spark Streaming Kafka Example ⭐ 5

Apache Spark Streaming & Apache Kafka

Vsl4oracle ⭐ 5

Spark Streaming Kafka for Oracle Database (SQL) demo example

Awesome Spark Cn ⭐ 5

专注spark学习资源收集，不定时更新

Streaming Data Pipeline ⭐ 5

Streaming pipeline repo for data engineering training program

Taming Big Data With Spark Streaming And Scala Hands On ⭐ 5

Taming Big Data with Spark Streaming and Scala – Hands On, published by Packt

Twitter Realtime Websocket ⭐ 5

analyze twitter data using spark streaming, report update using Play and webSocket by Akka actor

Spark Streaming Example ⭐ 5

Spark Kafka Example ⭐ 5

Example for Data Reading from and Writing to from Kafka Topic using Apache Spark DataFrame and DataSet

Physonline ⭐ 5

PhysOnline: An Open Source Machine Learning Pipeline for Real-Time Analysis of Waveform Data

Streaming State Machine ⭐ 5

This code refers to a blog post I made about using Scala case classes to implement states within a state machine

Flink Onnx Pytorch ⭐ 5

Streaming machine learning using PyTorch, Flink, and ONNX

Spark Streaming Example ⭐ 5

Example for a spark-streaming application using Kafka, Cassandra and Stateful Stream Processing

Live Video Stream ⭐ 5

Live self-built video streaming using akka-http

Akka Http Streaming Client And Server ⭐ 5

Examples showing how to perform streaming requests and responses using Akka HTTP along with some bonuses

Odsc East 2020 Decision Intelligence ⭐ 5

This is the home of the 2020 Open Data Science Conference workshop (Creating Streaming Predictive Analytics and Decision Intelligence Systems with Apache Spark)

Dynamic Streaming ⭐ 5

Interactive data analysis with Spark streaming session code repo

Spark Structured Datasource ⭐ 5

Custom datasource about spark structure streaming

Odsc East Realish Predictions ⭐ 5

Material for the 2019 ODSC East Workshop (Realish Time Predictive Analytics with Spark Structured Streaming)

Spark Streaming ⭐ 5

Example of spark streaming listening on socket for data push from client

Twitter Stream Metrics ⭐ 5

Framework to aggregate metrics from Twitter Stream in real-time

Spark Algebird ⭐ 5

Spark with probabilistic algortighmts - Bloom filter, HLL, QTree and Count-min sketch

Related Searches

Scala Sbt (4,178)

Scala Spark (3,279)

Scala Akka (2,120)

Javascript Streaming (2,085)

Java Scala (1,794)

Stream Streaming (1,696)

Python Streaming (1,407)

Scala Play Framework (1,309)

Java Streaming (1,103)

Plugin Scala (1,079)

201-282 of 282 search results

Privacy | About | Terms | Follow Us On Twitter

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