This program runs a pipeline which gets streaming data from a custom data source.
Primary LanguageJava