SpoutCollector extends AbstractStormCollector<OUT> implements ISpoutOutputCollector { @Override public void emitDirect(final int taskId, final String streamId, final List<Object> tuple, final Object messageId) { throw new UnsupportedOperationException("Direct emit is not supported by Flink"); } SpoutCollector(final HashMap<String, Integer> numberOfAttributes, final int taskId,
			final SourceContext<OUT> flinkContext); @Override void reportError(final Throwable error); @Override List<Integer> emit(final String streamId, final List<Object> tuple, final Object messageId); @Override void emitDirect(final int taskId, final String streamId, final List<Object> tuple, final Object messageId);  }
@SuppressWarnings("unchecked") @Test(expected = UnsupportedOperationException.class) public void testEmitDirect() { new SpoutCollector<Object>(mock(HashMap.class), -1, mock(SourceContext.class)).emitDirect( 0, null, null, (Object) null); }