Package org.apache.storm.loadgen
Class InputStream.Builder
java.lang.Object
org.apache.storm.loadgen.InputStream.Builder
- Enclosing class:
- InputStream
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionbuild()getId()withExecTime(NormalDistStats execTime) withFromComponent(String fromComponent) withGroupingType(Grouping grouping) Add the grouping type based off of the thrift Grouping class.withGroupingType(GroupingType groupingType) withProcessTime(NormalDistStats processTime) withToComponent(String toComponent)
-
Constructor Details
-
Builder
public Builder()
-
-
Method Details
-
getFromComponent
-
withFromComponent
-
getToComponent
-
withToComponent
-
getId
-
withId
-
getExecTime
-
withExecTime
-
getProcessTime
-
withProcessTime
-
getGroupingType
-
withGroupingType
-
withGroupingType
Add the grouping type based off of the thrift Grouping class.- Parameters:
grouping- the Grouping to extract the grouping type from- Returns:
- this
-
build
-