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, openpublic StdinSpout()
protected InputStream nextInputStream() throws Exception
nextInputStream in class LocalTweetSpoutException