Chesnay Schepler created FLINK-6086:
---------------------------------------
Summary: Rework PythonSender/-Streamer generics
Key: FLINK-6086
URL: https://issues.apache.org/jira/browse/FLINK-6086
Project: Flink
Issue Type: Improvement
Components: Python API
Affects Versions: 1.3.0
Reporter: Chesnay Schepler
Assignee: Chesnay Schepler
Fix For: 1.3.0
The PythonSender/PythonStreamer classes make heavy use of raw-types or
wildcards. This is done since both classes deal with the cases of the operation
having 1 or 2 input types, the differentiation of which is done completely by
an int argument.
We can clean this rather insane code up a bit by creating dedicated sub-classes
for 1 or 2 inputs.
The PythonSender also contains multiple unused methods that we can remove while
we're at it.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
