Hi Aarti,
I would imagine that the described approach (sharing the same object
instance with the API and the Flink runtime) would only work in toy
executions, such as executing the job within the IDE.
Moreover, you would not be able to have exactly-once semantics with this
source, which for most
Hi,
I have an API that emits output that I want to use as a data source for
Flink.
I have written a custom source function that is as follows -
public class DynamicRuleSource extends AlertingRuleSource {
private ArrayList rules = new ArrayList();
public void run(SourceContext ctx) thro
