Package org.apache.storm.loadgen
Class InputStream.Builder
java.lang.Object
org.apache.storm.loadgen.InputStream.Builder
- Enclosing class:
- InputStream
-
Constructor Summary
-
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
-