public class GroupingDef extends Object
Bean representation of a Storm stream grouping.
Modifier and Type | Class and Description |
---|---|
static class |
GroupingDef.Type
Types 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.