kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Matthias J. Sax (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (KAFKA-3430) Allow users to set key in KTable.toStream() and KStream
Date Wed, 22 Feb 2017 01:06:44 GMT

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

Matthias J. Sax updated KAFKA-3430:
    Affects Version/s:

> Allow users to set key in KTable.toStream() and KStream
> -------------------------------------------------------
>                 Key: KAFKA-3430
>                 URL: https://issues.apache.org/jira/browse/KAFKA-3430
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: streams
>    Affects Versions:
>            Reporter: Guozhang Wang
>            Assignee: Bill Bejeck
>              Labels: api
>             Fix For:
> Currently KTable.toStream does not take any parameters and hence users who wants to set
the key need to do two steps:
> {code}table.toStream().map(...){code} in order to do so. We can make it in one step by
providing the mapper parameter in toStream.
> And similarly today users usually need to call {code} KStream.map() {code} in order to
select the key before aggregation-by-key operation if the original stream is does not contain
> We can consider adding a specific function in KStream to do so:
> {code}KStream.selectKey(mapper){code}
> which essential is the same as
> {code}KStream.map(/* mapper that does not change the value, but only the key */){code}

This message was sent by Atlassian JIRA

View raw message