public class FiniteInMemorySpout extends InMemorySpout<String> implements FiniteSpout
|Modifier and Type||Method and Description|
When returns true, the spout has reached the end of the stream.
ack, activate, close, deactivate, declareOutputFields, fail, getComponentConfiguration, open
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
ack, activate, close, deactivate, fail, nextTuple, open
public FiniteInMemorySpout(String source)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.