Source code for the X Recommendation Algorithm

Apache Spark - A unified analytics engine for large-scale data processing

A platform to build and run apps that are elastic, agile, and resilient. SDK, libraries, and hosted environments.

PredictionIO, a machine learning server for developers and ML engineers.

CMAK is a tool for managing Apache Kafka clusters

A fault tolerant, protocol-agnostic RPC system

An open-source storage framework that enables building a Lakehouse architecture with compute engines including Spark, PrestoDB, Flink, Trino, and Hive and APIs

Code, exercises, answers, and hints to go along with the book "Functional Programming in Scala"

A machine learning package built for humans.

A Scala API for Cascading

Breeze is/was a numerical processing library for Scala.

A Scala API for Apache Beam and Google Cloud Dataflow.

Abstract Algebra for Scala

Fast, testable, Scala services built on TwitterServer and Finagle

Streaming MapReduce with Scalding and Storm

Twitter-Server defines a template from which services at Twitter are built

Cassovary is a simple big graph processing library for the JVM

A Thrift parser/generator

[PROJECT IS NO LONGER MAINTAINED] Code examples that show to integrate Apache Kafka 0.8+ with Apache Storm 0.9+ and Apache Spark Streaming 1.1+, while using Apache Avro as the data serialization fo…

A parser combinator library based on the GLL algorithm

Norbert is a cluster manager and networking layer built on top of Zookeeper.

Movie recommendations and more in MapReduce and Scalding

Stream-based Recommender Evaluation