knaufk / demo-beam-summit-2018
Python Streaming Pipelines with Beam on Flink - Demo
☆14Updated last year
Related projects: ⓘ
- Docker compose files for various kafka stacks☆33Updated 6 years ago
- Get started with Apache Beam and Flink☆42Updated 7 years ago
- A proof of concept using Divolte, Kafka, Druid and Superset☆61Updated 4 years ago
- A plugin to Apache Airflow to allow you to run Spark Submit Commands as an Operator☆75Updated 5 years ago
- A cookiecutter template for Apache Spark applications written in Scala☆10Updated 5 years ago
- Flink Examples☆39Updated 8 years ago
- Invoke Pandas plotting by piping in SQL output via PSQL (Can be used with Postgres or Greenplum or any SQL engine).☆16Updated 9 years ago
- Example project which simulates an interesting analytics use case using MemSQL Pipelines.☆14Updated 7 years ago
- Real-time anomaly detection using Kafka, KSQL User Defined Function and a pre-trained model☆30Updated 9 months ago
- Example code for building your own MemSQL Streamliner Pipelines☆23Updated 7 years ago
- Docker image for Apache Hive running on Tez☆7Updated 9 years ago
- Airflow workflow management platform chef cookbook.☆67Updated 5 years ago
- ☆47Updated 4 years ago
- Pachyderm/MLeap team up to provide versioned datasets + models☆10Updated 7 years ago
- ☆47Updated this week
- ☆23Updated 7 years ago
- Deploy your Spark Production Cluster on Kubernetes☆47Updated 4 years ago
- ☆14Updated this week
- An Integrated and collaborative cloud environment for building and running Spark applications on PKS/Kubernetes☆81Updated 4 years ago
- Dremio Flight connector. Access Dremio using Arrow flight☆40Updated 3 years ago
- Python client for Spark Jobserver Rest API☆39Updated 4 years ago
- VoltDB Click Stream Processing Example.☆16Updated 6 years ago
- Spark UDFs to deserialize Avro messages with schemas stored in Schema Registry.☆18Updated 6 years ago
- A Real-Time Analytical Processing (RTAP) example using Spark/Shark☆51Updated 10 years ago
- Apache Spark on Kubernetes☆19Updated 7 years ago
- A collection of datasets and databases☆24Updated 6 years ago
- A light Kafka to HDFS/S3 ETL library based on Apache Spark☆41Updated 7 years ago
- Stratosphere is now Apache Flink.☆197Updated 9 months ago
- A plugin for Airflow that create and manage your DAG with web UI.☆20Updated 6 years ago
- UI for ZenQuery - Enterprise Backend as a Service☆10Updated 7 years ago