Hi Marke,
You can use split() and select() as is shown here[1].
Best, Hequn
[1]
https://ci.apache.org/projects/flink/flink-docs-master/dev/stream/operators/#datastream-transformations
On Sat, Nov 10, 2018 at 12:23 AM Marke Builder
wrote:
> Hi,
>
> what is the recommended way to implement the
Hi,
what is the recommended way to implement the following use-case for
DataStream:
One data sink, same map() functions for parsing and normalization and
different map() function for format and two different sinks for the output?
The (same)data must be stored in both sinks.
And I prefere one job
