[
https://issues.apache.org/jira/browse/FLINK-6035?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15923849#comment-15923849
]
Luke Hutchison edited comment on FLINK-6035 at 3/14/17 9:19 AM:
----------------------------------------------------------------
The name parameter shouldn't be required, just as calling .name() on an
operator is not required. Therefore it makes perfect sense to add a new method
that sets the name and then calls the regular namless sink method (i.e. this
doesn't need to break the API).
I'll change the name of this bug -- thanks!
was (Author: lukehutch):
The name parameter shouldn't be required, just as calling .name() on an
operator is not required. Therefore it makes perfect sense to add a new method
that sets the name and then calls the regular namless sink method (i.e. this
doesn't need to wait for Flink 2.0.0).
I'll change the name of this bug -- thanks!
> Sinks need optional name parameter: .collect(name), .count(name)
> ----------------------------------------------------------------
>
> Key: FLINK-6035
> URL: https://issues.apache.org/jira/browse/FLINK-6035
> Project: Flink
> Issue Type: Bug
> Components: DataSet API
> Affects Versions: 1.2.0
> Reporter: Luke Hutchison
> Priority: Trivial
>
> If I call
> {code}
> dataSet.groupBy(0).name("group by key")
> {code}
> I get an error message like
> {noformat}
> The method name(String) is undefined for the type
> UnsortedGrouping<Tuple4<String,String,String,Float>>
> {noformat}
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
