flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Márton Balassi (JIRA) <j...@apache.org>
Subject [jira] [Resolved] (FLINK-1104) Eliminate Tuple1 from flink-streaming-connectors
Date Wed, 24 Sep 2014 20:30:35 GMT

     [ https://issues.apache.org/jira/browse/FLINK-1104?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Márton Balassi resolved FLINK-1104.
-----------------------------------
    Resolution: Fixed
      Assignee: Márton Balassi

Resolved in the following commit:
https://github.com/apache/incubator-flink/commit/7cc24006a992d67cd3de54b867b38161f5b08d92

> Eliminate Tuple1 from flink-streaming-connectors
> ------------------------------------------------
>
>                 Key: FLINK-1104
>                 URL: https://issues.apache.org/jira/browse/FLINK-1104
>             Project: Flink
>          Issue Type: Task
>          Components: Streaming
>            Reporter: Márton Balassi
>            Assignee: Márton Balassi
>            Priority: Minor
>
> The streaming connectors contains unnecessary usage of Tuple1. E.g. in KafkaSource:
> @Override
> public Tuple1<String> deserialize(byte[] msg) {
> 	String s = new String(msg);
> 	if(s.equals("q")){
> 		closeWithoutSend();
> 	}
> 	return new Tuple1<String>(s);
> }
> Please adjust the underlying interfaces and update the documentation accordingly.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message