public class InputStream extends Object implements Serializable
A set of measurements about a stream so we can statistically reproduce it.
Modifier and Type | Class and Description |
---|---|
static class |
InputStream.Builder |
Modifier and Type | Field and Description |
---|---|
NormalDistStats |
execTime |
String |
fromComponent |
GroupingType |
groupingType |
String |
id |
NormalDistStats |
processTime |
String |
toComponent |
Constructor and Description |
---|
InputStream(String fromComponent,
String toComponent,
String id,
NormalDistStats execTime,
NormalDistStats processTime,
GroupingType groupingType)
Create a new input stream to a bolt.
|
Modifier and Type | Method and Description |
---|---|
static InputStream |
fromConf(Map<String,Object> conf)
Create an output stream from a config.
|
GlobalStreamId |
gsid()
Get the global stream id for this input stream.
|
InputStream |
remap(Map<String,String> remappedComponents,
Map<GlobalStreamId,GlobalStreamId> remappedStreams)
Remap the names of components.
|
InputStream |
replaceShuffleWithLocalOrShuffle()
Replace all SHUFFLE groupings with LOCAL_OR_SHUFFLE.
|
Map<String,Object> |
toConf()
Convert this to a conf.
|
public final String fromComponent
public final String toComponent
public final String id
public final NormalDistStats execTime
public final NormalDistStats processTime
public final GroupingType groupingType
public InputStream(String fromComponent, String toComponent, String id, NormalDistStats execTime, NormalDistStats processTime, GroupingType groupingType)
Create a new input stream to a bolt.
fromComponent
- the source component of the stream.id
- the id of the streamexecTime
- exec time statsprocessTime
- process time statspublic static InputStream fromConf(Map<String,Object> conf)
Create an output stream from a config.
conf
- the config to read from.public GlobalStreamId gsid()
Get the global stream id for this input stream.
public InputStream remap(Map<String,String> remappedComponents, Map<GlobalStreamId,GlobalStreamId> remappedStreams)
Remap the names of components.
remappedComponents
- old name to new name of components.remappedStreams
- old ID to new ID of streams.public InputStream replaceShuffleWithLocalOrShuffle()
Replace all SHUFFLE groupings with LOCAL_OR_SHUFFLE.
Copyright © 2022 The Apache Software Foundation. All rights reserved.