Underwood created FLINK-27226:
---------------------------------
Summary: How to implement two partition methods for an operator at
the same time?
Key: FLINK-27226
URL: https://issues.apache.org/jira/browse/FLINK-27226
Project: Flink
Issue Type: New Feature
Components: API / DataStream
Affects Versions: 1.14.3
Reporter: Underwood
For example, I'm counting letters. Each letter of A ~ Y corresponds to a
partition, and each partition records the number of times their letters appear,
but the letter of Z needs to be counted by each partition, that is, in a
stream, A ~ Y needs hash partition and Z needs broadcast partition. Is there
any method to realize this?
I want to use partitioncustom, but it seems that it can only be sent to one
partition.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
