[
https://issues.apache.org/jira/browse/FLINK-2753?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14906399#comment-14906399
]
ASF GitHub Bot commented on FLINK-2753:
---------------------------------------
Github user aljoscha commented on the pull request:
https://github.com/apache/flink/pull/1175#issuecomment-142943745
I don't favor a particular style, I just think consistency is key here. The
google style guide, for example allows single char (T, E, K) and camel case
with an affixed T, i.e. ResultT, KeyT, and so on.
I'll adapt your code while finishing the windowing stuff based on what we
decide.
> Add new window API to streaming API
> -----------------------------------
>
> Key: FLINK-2753
> URL: https://issues.apache.org/jira/browse/FLINK-2753
> Project: Flink
> Issue Type: Sub-task
> Components: Streaming
> Affects Versions: 0.10
> Reporter: Stephan Ewen
> Assignee: Stephan Ewen
> Fix For: 0.10
>
>
> The API integration should follow the API design as documented here:
> https://cwiki.apache.org/confluence/display/FLINK/Streams+and+Operations+on+Streams
> This issue needs:
> - Add new {{KeyedWindowDataStream}}, created by calling{{window()}} on the
> {{KeyedDataStream}}.
> - Add a utility that converts Window Policies into concrete window
> implementations. This is important to realize special case implementations
> that do not directly use generic mechanisms implemented by window policies.
> - Instantiating the operators (dedicated and generic) from the window
> policies
> - I will add a stub for the new Window Policy classes, based on the
> existing policy classes.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
