[
https://issues.apache.org/jira/browse/FLINK-11226?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16729620#comment-16729620
]
Hequn Cheng commented on FLINK-11226:
-------------------------------------
[[email protected]] Thanks for reporting the issue. As a workaround, you
can get the keyselector from scala KeyedStream with the following way:
{code:java}
scalaKeyedStream
.javaStream.asInstanceOf[org.apache.flink.streaming.api.datastream.KeyedStream]
.getKeySelector
{code}
I think it would be more convenient for users if we add {{getKeySelector()}}
method in scala {{KeyedStream}}.
> Lack of getKeySelector in Scala KeyedStream API unlike Java KeyedStream
> -----------------------------------------------------------------------
>
> Key: FLINK-11226
> URL: https://issues.apache.org/jira/browse/FLINK-11226
> Project: Flink
> Issue Type: Bug
> Components: DataStream API
> Affects Versions: 1.7.1
> Reporter: Albert Bikeev
> Priority: Major
>
> There is no simple way to access key via Scala KeyedStream API because there
> is no
> getKeySelector method, unlike in Java KeyedStream.
> Temporary workarounds are appreciated.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
