public class StdinSpout extends LocalTweetSpout
LocalTweetSpout
fed from the stdincollector
Constructor and Description |
---|
StdinSpout() |
Modifier and Type | Method and Description |
---|---|
protected InputStream |
nextInputStream() |
ack, activate, addWaitingFor, close, deactivate, declareOutputFields, fail, getComponentConfiguration, isFinished, nextTuple, nextTweet, open
public StdinSpout()
protected InputStream nextInputStream() throws Exception
nextInputStream
in class LocalTweetSpout
Exception