test_class.file: flink-contrib/flink-storm/src/test/java/org/apache/flink/storm/wrappers/SpoutCollectorTest.java
test_class.identifier: SpoutCollectorTest
test_class.superclass: extends AbstractTest
test_case.body: @SuppressWarnings({ "rawtypes", "unchecked" })
  	@Test
  	public void testSpoutStormCollectorWithTaskId() throws InstantiationException, IllegalAccessException {
  		for (int numberOfAttributes = 0; numberOfAttributes < 25; ++numberOfAttributes) {
  			final SourceContext flinkCollector = mock(SourceContext.class);
  			final int taskId = 42;
  			final String streamId = "streamId";
  
  			HashMap<String, Integer> attributes = new HashMap<String, Integer>();
  			attributes.put(streamId, numberOfAttributes);
  
  			SpoutCollector<?> collector = new SpoutCollector(attributes, taskId, flinkCollector);
  
  			final Values tuple = new Values();
  			final Tuple flinkTuple = Tuple.getTupleClass(numberOfAttributes + 1).newInstance();
  
  			for (int i = 0; i < numberOfAttributes; ++i) {
  				tuple.add(new Integer(this.r.nextInt()));
  				flinkTuple.setField(tuple.get(i), i);
  			}
  			flinkTuple.setField(taskId, numberOfAttributes);
  
  			final List<Integer> taskIds;
  			final Object messageId = new Integer(this.r.nextInt());
  
  			taskIds = collector.emit(streamId, tuple, messageId);
  
  			Assert.assertNull(taskIds);
  
  			verify(flinkCollector).collect(flinkTuple);
  		}
  	}
test_case.class_method_signature: SpoutCollectorTest.testSpoutStormCollectorWithTaskId()
test_case.full_signature: @SuppressWarnings({ "rawtypes", "unchecked" }) @Test public void testSpoutStormCollectorWithTaskId()
test_case.identifier: testSpoutStormCollectorWithTaskId
test_case.invocations: mock put newInstance getTupleClass add nextInt setField get setField nextInt emit assertNull collect verify
test_case.modifiers: @SuppressWarnings({ "rawtypes", "unchecked" }) @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testSpoutStormCollectorWithTaskId()
focal_class.declarator: flinkContext
focal_class.modifier: private final
focal_class.original_string: private final SourceContext<OUT> flinkContext;
focal_class.type: SourceContext<OUT>
focal_class.var_name: flinkContext
focal_class.file: flink-contrib/flink-storm/src/main/java/org/apache/flink/storm/wrappers/SpoutCollector.java
focal_class.identifier: SpoutCollector
focal_class.interfaces: implements ISpoutOutputCollector
focal_class.class_method_signature: SpoutCollector.SpoutCollector(final HashMap<String, Integer> numberOfAttributes, final int taskId,
  			final SourceContext<OUT> flinkContext)
focal_class.full_signature:   SpoutCollector(final HashMap<String, Integer> numberOfAttributes, final int taskId,
  			final SourceContext<OUT> flinkContext)
focal_class.identifier: SpoutCollector
focal_class.parameters: (final HashMap<String, Integer> numberOfAttributes, final int taskId,
  			final SourceContext<OUT> flinkContext)
focal_class.signature:  SpoutCollector(final HashMap<String, Integer> numberOfAttributes, final int taskId,
  			final SourceContext<OUT> flinkContext)
focal_class.class_method_signature: SpoutCollector.doEmit(final OUT flinkTuple)
focal_class.full_signature: @Override protected List<Integer> doEmit(final OUT flinkTuple)
focal_class.identifier: doEmit
focal_class.modifiers: @Override protected
focal_class.parameters: (final OUT flinkTuple)
focal_class.return: List<Integer>
focal_class.signature: List<Integer> doEmit(final OUT flinkTuple)
focal_class.class_method_signature: SpoutCollector.reportError(final Throwable error)
focal_class.full_signature: @Override public void reportError(final Throwable error)
focal_class.identifier: reportError
focal_class.modifiers: @Override public
focal_class.parameters: (final Throwable error)
focal_class.return: void
focal_class.signature: void reportError(final Throwable error)
focal_class.class_method_signature: SpoutCollector.emit(final String streamId, final List<Object> tuple, final Object messageId)
focal_class.full_signature: @Override public List<Integer> emit(final String streamId, final List<Object> tuple, final Object messageId)
focal_class.identifier: emit
focal_class.modifiers: @Override public
focal_class.parameters: (final String streamId, final List<Object> tuple, final Object messageId)
focal_class.return: List<Integer>
focal_class.signature: List<Integer> emit(final String streamId, final List<Object> tuple, final Object messageId)
focal_class.class_method_signature: SpoutCollector.emitDirect(final int taskId, final String streamId, final List<Object> tuple, final Object messageId)
focal_class.full_signature: @Override public void emitDirect(final int taskId, final String streamId, final List<Object> tuple, final Object messageId)
focal_class.identifier: emitDirect
focal_class.modifiers: @Override public
focal_class.parameters: (final int taskId, final String streamId, final List<Object> tuple, final Object messageId)
focal_class.return: void
focal_class.signature: void emitDirect(final int taskId, final String streamId, final List<Object> tuple, final Object messageId)
focal_class.superclass: extends AbstractStormCollector<OUT>
focal_method.body: @Override
  	public List<Integer> emit(final String streamId, final List<Object> tuple, final Object messageId) {
  		return this.tansformAndEmit(streamId, tuple);
  	}
focal_method.class_method_signature: SpoutCollector.emit(final String streamId, final List<Object> tuple, final Object messageId)
focal_method.full_signature: @Override public List<Integer> emit(final String streamId, final List<Object> tuple, final Object messageId)
focal_method.identifier: emit
focal_method.invocations: tansformAndEmit
focal_method.modifiers: @Override public
focal_method.parameters: (final String streamId, final List<Object> tuple, final Object messageId)
focal_method.return: List<Integer>
focal_method.signature: List<Integer> emit(final String streamId, final List<Object> tuple, final Object messageId)