public class GroupingDef extends Object
Bean representation of a Storm stream grouping.
| Modifier and Type | Class and Description | 
|---|---|
| static class  | GroupingDef.TypeTypes of stream groupings Storm allows. | 
| Constructor and Description | 
|---|
| GroupingDef() | 
| Modifier and Type | Method and Description | 
|---|---|
| List<String> | getArgs() | 
| ObjectDef | getCustomClass() | 
| String | getStreamId() | 
| GroupingDef.Type | getType() | 
| void | setArgs(List<String> args) | 
| void | setCustomClass(ObjectDef customClass) | 
| void | setStreamId(String streamId) | 
| void | setType(GroupingDef.Type type) | 
public GroupingDef.Type getType()
public void setType(GroupingDef.Type type)
public String getStreamId()
public void setStreamId(String streamId)
public ObjectDef getCustomClass()
public void setCustomClass(ObjectDef customClass)
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.