Hi Aljoscha,
Thanks for your explanation. I'll try what you suggests.
Best,
Xingcan
On Fri, Jun 16, 2017 at 5:19 PM, Aljoscha Krettek
wrote:
> Hi,
>
> I’m afraid that’s not possible out-of-box with the current APIs. I
> actually don’t know why the user-facing Partitioner only allows returning
Hi,
I’m afraid that’s not possible out-of-box with the current APIs. I actually
don’t know why the user-facing Partitioner only allows returning one target
because the internal StreamPartitioner (which extends ChannelSelector) allows
returning multiple target partitions.
You can hack around th
Hi all,
I want to duplicate records to multiple downstream tasks (not all of them
thus the
Broadcasting should not work) in stream environment.
However, it seems that the current custom partitioner can return only one
partition index.
Why this restriction exists or do I miss something?
Thanks,
Xi
