[
https://issues.apache.org/jira/browse/FLINK-39131?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Salva updated FLINK-39131:
--------------------------
Description:
As a DataStream API user, I would like to have a built-in primitive that allows
me to process multiple (more than 2) inputs within a single operator. This
would make it easy to write multi-way joins, preventing the state-explosion
issue recently handled in
[FLIP-516|https://cwiki.apache.org/confluence/display/FLINK/FLIP-516%3A+Multi-Way+Join+Operator]
at the SQL level.
The Operator API already contains all the necessary building blocks, and some
users have reported successfully leveraging them. See, the replies in this
[thread|https://cwiki.apache.org/confluence/display/FLINK/FLIP-516%3A+Multi-Way+Join+Operator]
for example.
I'm personally doing this too, so I wonder whether something like this could be
officially supported out of the box.
was:
As a DataStream API user, I would like to have a built-in primitive that allows
me to process multiple (more than 2) inputs within a single operator. This
would make it easy to write multi-way joins, preventing the state-explosion
issue recently handled in
[FLIP-516|https://cwiki.apache.org/confluence/display/FLINK/FLIP-516%3A+Multi-Way+Join+Operator]
at the SQL level.
The Operator API already contains all the necessary building blocks, and some
users have reported successfully leveraging them. See, the replies in this
[thread|https://cwiki.apache.org/confluence/display/FLINK/FLIP-516%3A+Multi-Way+Join+Operator]
for example.
I'm personally doing this too, so I wonder whether something like this could be
supported out of the box.
> Multi-Input Processors
> ----------------------
>
> Key: FLINK-39131
> URL: https://issues.apache.org/jira/browse/FLINK-39131
> Project: Flink
> Issue Type: New Feature
> Components: API / DataStream
> Reporter: Salva
> Priority: Major
>
> As a DataStream API user, I would like to have a built-in primitive that
> allows me to process multiple (more than 2) inputs within a single operator.
> This would make it easy to write multi-way joins, preventing the
> state-explosion issue recently handled in
> [FLIP-516|https://cwiki.apache.org/confluence/display/FLINK/FLIP-516%3A+Multi-Way+Join+Operator]
> at the SQL level.
> The Operator API already contains all the necessary building blocks, and some
> users have reported successfully leveraging them. See, the replies in this
> [thread|https://cwiki.apache.org/confluence/display/FLINK/FLIP-516%3A+Multi-Way+Join+Operator]
> for example.
> I'm personally doing this too, so I wonder whether something like this could
> be officially supported out of the box.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
