/flink-flux

This is a mirror repo for Uber's internal Flink plugins.

Primary LanguageJava

Streaming plugins for Apache Flink @Uber

Build Status ReadTheDocs

This is a repository contains all Apache Flink plugin libraries developed by the streaming analytics team @Uber.

Streaming plugins for Apache Flink

streaming-plugins is a plugin library used for various purposes including: Wrapped executor for interacting with deployment clusters; generalized wrapper for validating and explaining Flink job graphs by pulling in external upstream, downstream dependencies. etc.

This is especially useful for managing enormous amount of Flink applications together within a service-oriented architecture.

Streaming DSL for Apache Flink

streaming-dsl is a streaming DSL designed specifically for constructing Apache Flink applications through markup languages.