[ https://issues.apache.org/jira/browse/FLINK-553?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Flink Jira Bot updated FLINK-553: --------------------------------- Labels: github-import stale-major (was: github-import) > Add getGroupKey() method to group-at-time operators > --------------------------------------------------- > > Key: FLINK-553 > URL: https://issues.apache.org/jira/browse/FLINK-553 > Project: Flink > Issue Type: Improvement > Components: API / DataSet > Reporter: GitHub Import > Priority: Major > Labels: github-import, stale-major > > Group-at-a-time operators (Reduce & CoGroup) work on multiple records in one > UDF call. Often these UDFs need to access the key that is common to all > records of a group. > We could add a function to set a the key of a group before the UDF is called > (``setGroupKey()``) and a function to get the key (``getGroupKey()``) that > can be called from the UDF. > What do you think about this? > ---------------- Imported from GitHub ---------------- > Url: https://github.com/stratosphere/stratosphere/issues/553 > Created by: [fhueske|https://github.com/fhueske] > Labels: enhancement, java api, scala api, user satisfaction, > Assignee: [aalexandrov|https://github.com/aalexandrov] > Created at: Mon Mar 10 22:28:27 CET 2014 > State: open -- This message was sent by Atlassian Jira (v8.3.4#803005)