[ 
https://issues.apache.org/jira/browse/STORM-1616?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15188675#comment-15188675
 ] 

ASF GitHub Bot commented on STORM-1616:
---------------------------------------

Github user arunmahadevan commented on a diff in the pull request:

    https://github.com/apache/storm/pull/1199#discussion_r55633878
  
    --- Diff: storm-core/src/jvm/org/apache/storm/trident/Stream.java ---
    @@ -124,6 +124,31 @@ public Stream parallelismHint(int hint) {
         }
     
         /**
    +     * Sets the CPU Load resource for the current node
    +     */
    +    public Stream setCPULoad(Number load) {
    --- End diff --
    
    A `Stream` should ideally have only streaming operations but it seems we 
are bringing the topology configuration into the stream api which does not look 
very clean. Cant this be part of the `TridentTopology` or passed during 
`submitTopology` ? If this should really be part of stream, can we have a 
single method like `nodeConfig(NodeConfig config)` and have all these methods 
as part of the `NodeConfig` so that we have only one extra method which is not 
really a stream operation?


> Add RAS API for Trident
> -----------------------
>
>                 Key: STORM-1616
>                 URL: https://issues.apache.org/jira/browse/STORM-1616
>             Project: Apache Storm
>          Issue Type: Bug
>            Reporter: Kyle Nusbaum
>            Assignee: Kyle Nusbaum
>




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

Reply via email to