You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Underwood (Jira)" <ji...@apache.org> on 2022/04/13 12:30:00 UTC

[jira] [Created] (FLINK-27226) How to implement two partition methods for an operator at the same time?

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)