This is a repository contains all Apache Flink plugin libraries developed by the streaming analytics team @Uber.
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
is a streaming DSL designed specifically for constructing
Apache Flink applications through markup languages.