flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Aljoscha Krettek <aljos...@apache.org>
Subject Re: Splitting Streams
Date Thu, 03 Sep 2015 10:20:26 GMT
Hi Martin,
maybe this is what you are looking for:
https://ci.apache.org/projects/flink/flink-docs-master/apis/streaming_guide.html#output-splitting

Regards,
Aljoscha

On Thu, 3 Sep 2015 at 12:02 Till Rohrmann <trohrmann@apache.org> wrote:

> Hi Martin,
>
> could grouping be a solution to your problem?
>
> Cheers,
> Till
>
> On Thu, Sep 3, 2015 at 11:56 AM, Martin Neumann <mneumann@sics.se> wrote:
>
>> Hej,
>>
>> I have a Stream of json objects of several different types. I want to
>> split this stream into several streams each of them dealing with one type.
>> (so its not partitioning)
>>
>> The only Way I found so far is writing a bunch of filters and connect
>> them to the source directly. This way I will have a lot of duplicated logic.
>> I'm basically looking for a single operator that can have multiple output
>> streams of different types.
>>
>> cheers Martin
>>
>
>

Mime
View raw message