apache-beam
There are 245 repositories under apache-beam topic.
tensorflow/tfx
TFX is an end-to-end platform for deploying production ML pipelines
GoogleCloudPlatform/DataflowTemplates
Cloud Dataflow Google-provided templates for solving in-Cloud data tasks
nielsbasjes/yauaa
Yet Another UserAgent Analyzer
GoogleCloudPlatform/flink-on-k8s-operator
[DEPRECATED] Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.
blockchain-etl/bitcoin-etl
ETL scripts for Bitcoin, Litecoin, Dash, Zcash, Doge, Bitcoin Cash. Available in Google BigQuery https://goo.gl/oY5BCQ
google/weather-tools
Tools to make weather data accessible and useful.
spotify/flink-on-k8s-operator
Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.
google/tensorflow-recorder
TFRecorder makes it easy to create TensorFlow records (TFRecords) from Pandas DataFrames and CSVs files containing images or structured data.
google/fhir-data-pipes
A collection of tools for extracting FHIR resources and analytics services on top of that data.
ngrunwald/datasplash
Clojure API for a more dynamic Google Dataflow
mohaseeb/beam-nuggets
Collection of transforms for the Apache beam python SDK.
blockchain-etl/blockchain-etl-streaming
Streaming Ethereum and Bitcoin blockchain data to Google Pub/Sub or Postgres in Kubernetes
tosun-si/asgarde
Asgarde allows simplifying error handling with Apache Beam Java, with less code, more concise and expressive code.
Fematich/mlengine-boilerplate
Repository to quickly get you started with new Machine Learning projects on Google Cloud Platform. More info(slides):
mercari/DataflowTemplate
Mercari Dataflow Template
yu-iskw/bigquery-to-datastore
Export a whole BigQuery table to Google Datastore with Apache Beam/Google Dataflow
luisbelloch/data_processing_course
Some class materials for a data processing course using PySpark
xmlking/micro-apps
Microservices in Post-Kubernetes Era. A polyglot monorepo
blockchain-etl/blockchain-etl-architecture
Blockchain ETL Architecture
doitintl/banias
Opinionated serverless event analytics pipeline
asaharland/beam-pipeline-examples
Apache Beam examples for running on Google Cloud Dataflow.
tosun-si/pasgarde
Asgarde allows simplifying error handling with Apache Beam Python, with less code, more concise and expressive code.
NucleusEngineering/hack-your-pipe
Efficient streaming data ingestion, transformation & activation
mercari/DataflowTemplates
Convenient Dataflow pipelines for transforming data between cloud data sources
mozilla-services/foxsec-pipeline
Log analysis pipeline utilizing Apache Beam
sayakpaul/count-tokens-hf-datasets
This project shows how to derive the total number of training tokens from a large text dataset from 🤗 datasets with Apache Beam and Dataflow.
esakik/beam-mysql-connector
Apache Beam I/O connector designed for accessing MySQL databases.
google-parfait/dataset_grouper
Libraries for efficient and scalable group-structured dataset pipelines.
carted/processing-text-data
Presents an optimized Apache Beam pipeline for generating sentence embeddings (runnable on Cloud Dataflow).
datastacktv/apache-beam-explained
Source code for the YouTube video, Apache Beam Explained in 12 Minutes
cassiobolba/Data-Engineering
Projects and studies regarding Data Engineering Area
google/consent-based-conversion-adjustments
Code to statistically up-weight conversion values of consenting customers to feed up to 100% of the factual conversion values back into Google Ads.
O2-Czech-Republic/proxima-platform
The Proxima platform.
datastacktv/apache-beam-batch-processing
Public source code for the Batch Processing with Apache Beam (Python) online course
delftdata/stateflow
Prototype which extracts stateful dataflows by analysing Python code.