test_class.file: flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/util/NullTerminatingSpoutTest.java
test_class.identifier: NullTerminatingSpoutTest
test_case.body: @Test
  	public void testReachedEnd() {
  		NullTerminatingSpout finiteSpout = new NullTerminatingSpout(new TestDummySpout());
  		finiteSpout.open(null, null, mock(SpoutOutputCollector.class));
  
  		Assert.assertFalse(finiteSpout.reachedEnd());
  
  		finiteSpout.nextTuple();
  		Assert.assertFalse(finiteSpout.reachedEnd());
  		finiteSpout.nextTuple();
  		Assert.assertTrue(finiteSpout.reachedEnd());
  	}
test_case.class_method_signature: NullTerminatingSpoutTest.testReachedEnd()
test_case.full_signature: @Test public void testReachedEnd()
test_case.identifier: testReachedEnd
test_case.invocations: open mock assertFalse reachedEnd nextTuple assertFalse reachedEnd nextTuple assertTrue reachedEnd
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testReachedEnd()
focal_class.declarator: serialVersionUID = -6976210409932076066L
focal_class.modifier: private static final
focal_class.original_string: private static final long serialVersionUID = -6976210409932076066L;
focal_class.type: long
focal_class.var_name: serialVersionUID
focal_class.declarator: spout
focal_class.modifier: private final
focal_class.original_string: private final IRichSpout spout;
focal_class.type: IRichSpout
focal_class.var_name: spout
focal_class.declarator: observer
focal_class.modifier: private
focal_class.original_string: private SpoutOutputCollectorObserver observer;
focal_class.type: SpoutOutputCollectorObserver
focal_class.var_name: observer
focal_class.file: flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/util/NullTerminatingSpout.java
focal_class.identifier: NullTerminatingSpout
focal_class.interfaces: implements FiniteSpout
focal_class.class_method_signature: NullTerminatingSpout.NullTerminatingSpout(IRichSpout spout)
focal_class.full_signature: public  NullTerminatingSpout(IRichSpout spout)
focal_class.identifier: NullTerminatingSpout
focal_class.modifiers: public
focal_class.parameters: (IRichSpout spout)
focal_class.signature:  NullTerminatingSpout(IRichSpout spout)
focal_class.class_method_signature: NullTerminatingSpout.open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector)
focal_class.full_signature: @Override public void open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector)
focal_class.identifier: open
focal_class.modifiers: @Override public
focal_class.parameters: (@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector)
focal_class.return: void
focal_class.signature: void open(@SuppressWarnings("rawtypes") Map conf, TopologyContext context, SpoutOutputCollector collector)
focal_class.class_method_signature: NullTerminatingSpout.close()
focal_class.full_signature: @Override public void close()
focal_class.identifier: close
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void close()
focal_class.class_method_signature: NullTerminatingSpout.activate()
focal_class.full_signature: @Override public void activate()
focal_class.identifier: activate
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void activate()
focal_class.class_method_signature: NullTerminatingSpout.deactivate()
focal_class.full_signature: @Override public void deactivate()
focal_class.identifier: deactivate
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void deactivate()
focal_class.class_method_signature: NullTerminatingSpout.nextTuple()
focal_class.full_signature: @Override public void nextTuple()
focal_class.identifier: nextTuple
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void nextTuple()
focal_class.class_method_signature: NullTerminatingSpout.ack(Object msgId)
focal_class.full_signature: @Override public void ack(Object msgId)
focal_class.identifier: ack
focal_class.modifiers: @Override public
focal_class.parameters: (Object msgId)
focal_class.return: void
focal_class.signature: void ack(Object msgId)
focal_class.class_method_signature: NullTerminatingSpout.fail(Object msgId)
focal_class.full_signature: @Override public void fail(Object msgId)
focal_class.identifier: fail
focal_class.modifiers: @Override public
focal_class.parameters: (Object msgId)
focal_class.return: void
focal_class.signature: void fail(Object msgId)
focal_class.class_method_signature: NullTerminatingSpout.declareOutputFields(OutputFieldsDeclarer declarer)
focal_class.full_signature: @Override public void declareOutputFields(OutputFieldsDeclarer declarer)
focal_class.identifier: declareOutputFields
focal_class.modifiers: @Override public
focal_class.parameters: (OutputFieldsDeclarer declarer)
focal_class.return: void
focal_class.signature: void declareOutputFields(OutputFieldsDeclarer declarer)
focal_class.class_method_signature: NullTerminatingSpout.getComponentConfiguration()
focal_class.full_signature: @Override public Map<String, Object> getComponentConfiguration()
focal_class.identifier: getComponentConfiguration
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: Map<String, Object>
focal_class.signature: Map<String, Object> getComponentConfiguration()
focal_class.class_method_signature: NullTerminatingSpout.reachedEnd()
focal_class.full_signature: @Override public boolean reachedEnd()
focal_class.identifier: reachedEnd
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean reachedEnd()
focal_method.body: @Override
  	public boolean reachedEnd() {
  		return this.observer.emitted == false;
  	}
focal_method.class_method_signature: NullTerminatingSpout.reachedEnd()
focal_method.full_signature: @Override public boolean reachedEnd()
focal_method.identifier: reachedEnd
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: boolean
focal_method.signature: boolean reachedEnd()