Displaying 1 to 6 from 6 results

scio - A Scala API for Apache Beam and Google Cloud Dataflow.

  •    Scala

Verb: I can, know, understand, have knowledge.Scio is a Scala API for Apache Beam and Google Cloud Dataflow inspired by Apache Spark and Scalding.

datasplash - Clojure API for a more dynamic Google Dataflow

  •    Clojure

Clojure API for a more dynamic Google Cloud Dataflow and (not really battle tested) any other Apache Beam backend. For now, you can consult the API docs.

banias - Opinionated serverless event analytics pipeline

  •    Go

Banias (Arabic: بانياس الحولة‎; Hebrew: בניאס‬) is the Arabic and modern Hebrew name of an ancient site developed around a river once associated with the Greek god Pan. So, like the flow of the Banias, events are flowing into our system. So we decided to build a reference architecture and actual implementation of event analytics pipeline. You can take the code as it is and use it or use it a design reference.

DataflowTemplates - Big Data Apache Beam Templates

  •    Java

Cloud teleport is a collection of Apache Beam pipelines for common tasks, like data movements across databases or batch transforms on random datasets.

foxsec-pipeline - Log analysis pipeline utilizing Apache Beam

  •    Java

Apache Beam pipelines for analyzing log data. Tests can be executed locally using Docker.