Hungsiro506

Hungsiro506's Stars

• NashTech-Labs/spark-graphx-twitter

  An example of Spark and GraphX with Twitter as sample

  Language:Scala197

• mvogiatzis/probabilistic-counting

  Distributed Probabilistic Counting on ClickStream data

  Language:Java3

• jadianes/kdd-cup-99-spark

  PySpark solution to the KDDCup99

  Language:Jupyter Notebook9964

• kiwenlau/hadoop-cluster-docker

  Run Hadoop Custer within Docker Containers

  Language:Shell1.8k866

• brscrt/Vert.xKafkaConsumer

  Language:Java1

• keiraqz/anomaly-detection

  Anomaly Detection model uses Spark for training and Spark Streaming for testing

  Language:Scala6727

• mvogiatzis/spark-anomaly-detection

  Detecting outliers in a dataset using Spark

  Language:Scala4124

• NashTech-Labs/activator-kafka-spark-streaming.g8

  This is an activator project for showcasing integration of Kafka 0.10 with Spark Streaming.

  Language:Java42

• krasserm/akka-analytics

  Large-scale event processing with Akka Persistence and Apache Spark

  Language:Scala27436

• jaceklaskowski/spark-activator

  Spark Streaming with Scala and Akka Activator template

  Language:Scala4426

• eligosource/eventsourced

  A library for building reliable, scalable and distributed event-sourced applications in Scala

  Language:JavaScript82798

• scalanlp/breeze

  Breeze is/was a numerical processing library for Scala.

  Language:Scala3.4k689

• NashTech-Labs/scala-design-patterns

  Scala Design Patterns

  Language:Scala51

• joandre/MCL_spark

  An implementation of Markov Clustering algorithm for Spark in Scala

  Language:Scala3413

• killrweather/killrweather

  KillrWeather is a reference application (work in progress) showing how to easily integrate streaming and batch data processing with Apache Spark Streaming, Apache Cassandra, Apache Kafka and Akka for fast, streaming computations on time series data in asynchronous event-driven environments.

  Language:Scala1.2k395

• JerryLead/SparkInternals

  Notes talking about the design and implementation of Apache Spark

  5.3k1.8k

• linkedin/kafka-monitor

  Xinfra Monitor monitors the availability of Kafka clusters by producing synthetic workloads using end-to-end pipelines to obtain derived vital statistics - E2E latency, service produce/consume availability, offsets commit availability & latency, message loss rate and more.

  Language:Java2k447

• yahoo/CMAK

  CMAK is a tool for managing Apache Kafka clusters

  Language:Scala11.9k2.5k

• twitter/algebird

  Abstract Algebra for Scala

  Language:Scala2.3k346

• microsoft/PowerBI-Node

  Node SDK and client library for Power BI REST APIs.

  Language:JavaScript7928

• twitter/scalding

  A Scala API for Cascading

  Language:Scala3.5k707

• datastax/spark-cassandra-connector

  DataStax Connector for Apache Spark to Apache Cassandra

  Language:Scala1.9k922

• skrusche63/spark-elastic

  This project combines Apache Spark and Elasticsearch to enable mining & prediction for Elasticsearch.

  Language:Scala20972

• donnemartin/system-design-primer

  Learn how to design large-scale systems. Prep for the system design interview. Includes Anki flashcards.

  Language:Python284k47.5k

• nielsutrecht/kafka-serializer-example

  Example of how to create your own custom serializers for Kafka queues including JSON, Smile and Kryo

  Language:Java2515

• alexbudniy/lambda

  Spark Scala Kafka Course

  Language:Scala1

• Hurence/logisland

  Scalable stream processing platform for advanced realtime analytics on top of Kafka and Spark. LogIsland also supports MQTT and Kafka Streams (Flink being in the roadmap). The platform does complex event processing and is suitable for time series analysis. A large set of valuable ready to use processors, data sources and sinks are available.

  Language:Java10929

• tresata/spark-kafka

  Low level integration of Spark and Kafka

  Language:Scala13039

• NashTech-Labs/real-time-stream-processing-engine

  This is an example of real time stream processing using Spark Streaming, Kafka & Elasticsearch.

  Language:Scala4122

• Stratio/sparta

  Real Time Analytics and Data Pipelines based on Spark Streaming

  Language:Scala523196