Spark streaming supports direct join from stream DataFrame and batch
DataFrame , and it's
easy to implement an enrich pipeline that joins a stream and a dimension
table.

 I checked the doc of flink, seems that this feature is a jira ticket which
haven't been resolved yet.

So how can I implement such a pipeline easily in Flink?

Reply via email to