Package org.apache.storm.loadgen
Class InputStream.Builder
- java.lang.Object
-
- org.apache.storm.loadgen.InputStream.Builder
-
- Enclosing class:
- InputStream
public static class InputStream.Builder extends Object
-
-
Constructor Summary
Constructors Constructor Description Builder()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description InputStreambuild()NormalDistStatsgetExecTime()StringgetFromComponent()GroupingTypegetGroupingType()StringgetId()NormalDistStatsgetProcessTime()StringgetToComponent()InputStream.BuilderwithExecTime(NormalDistStats execTime)InputStream.BuilderwithFromComponent(String fromComponent)InputStream.BuilderwithGroupingType(Grouping grouping)Add the grouping type based off of the thrift Grouping class.InputStream.BuilderwithGroupingType(GroupingType groupingType)InputStream.BuilderwithId(String id)InputStream.BuilderwithProcessTime(NormalDistStats processTime)InputStream.BuilderwithToComponent(String toComponent)
-
-
-
Method Detail
-
getFromComponent
public String getFromComponent()
-
withFromComponent
public InputStream.Builder withFromComponent(String fromComponent)
-
getToComponent
public String getToComponent()
-
withToComponent
public InputStream.Builder withToComponent(String toComponent)
-
getId
public String getId()
-
withId
public InputStream.Builder withId(String id)
-
getExecTime
public NormalDistStats getExecTime()
-
withExecTime
public InputStream.Builder withExecTime(NormalDistStats execTime)
-
getProcessTime
public NormalDistStats getProcessTime()
-
withProcessTime
public InputStream.Builder withProcessTime(NormalDistStats processTime)
-
getGroupingType
public GroupingType getGroupingType()
-
withGroupingType
public InputStream.Builder withGroupingType(GroupingType groupingType)
-
withGroupingType
public InputStream.Builder withGroupingType(Grouping grouping)
Add the grouping type based off of the thrift Grouping class.- Parameters:
grouping- the Grouping to extract the grouping type from- Returns:
- this
-
build
public InputStream build()
-
-