[jira] [Closed] (EAGLE-52) Eagle framework should support custom group by function in addition to group by fields

["Libin, Sun (JIRA)" <ji...@apache.org>]

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

Libin, Sun closed EAGLE-52.
---------------------------
       Resolution: Done
    Fix Version/s: 0.3.0

> Eagle framework should support custom group by function in addition to group by fields
> --------------------------------------------------------------------------------------
>
>                 Key: EAGLE-52
>                 URL: https://issues.apache.org/jira/browse/EAGLE-52
>             Project: Eagle
>          Issue Type: Improvement
>    Affects Versions: 0.3.0
>            Reporter: Libin, Sun
>            Assignee: Libin, Sun
>             Fix For: 0.3.0
>
>
> In some situation Like EAGLE-24, user need to define custom group by methods to do load balance
> storm support user to implement a custom stream grouping by implementing the CustomStreamGrouping interface and declare it in InputDeclarer, The following is InputDeclarer interface
> Eagle should add interface for passing custom group by methods in high level DSL
> {code}
> public interface InputDeclarer<T extends InputDeclarer>
> { 
> 	public T fieldsGrouping(String componentId, Fields fields); 
> 	public T fieldsGrouping(String componentId, String streamId, Fields fields); 
> 	public T globalGrouping(String componentId); public T globalGrouping(String componentId, String streamId); 
> 	public T shuffleGrouping(String componentId); public T shuffleGrouping(String componentId, String streamId); 
> 	public T localOrShuffleGrouping(String componentId); public T localOrShuffleGrouping(String componentId, 
> String streamId); 
> 	public T noneGrouping(String componentId); public T noneGrouping(String componentId, String streamId); 
> 	public T allGrouping(String componentId); public T allGrouping(String componentId, String streamId); 
> 	public T directGrouping(String componentId); public T directGrouping(String componentId, String streamId); 
> 	public T customGrouping(String componentId, CustomStreamGrouping grouping); 
> 	public T customGrouping(String componentId, String streamId, CustomStreamGrouping grouping); 
> 	public T grouping(GlobalStreamId id, Grouping grouping); 
> }
> {code}



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)