class BoltCollector extends AbstractStormCollector<OUT> implements IOutputCollector {

	@Override
	public void emitDirect(final int taskId, final String streamId, final Collection<Tuple> anchors, final List<Object> tuple) {
		throw new UnsupportedOperationException("Direct emit is not supported by Flink");
	}

	  BoltCollector(final HashMap<String, Integer> numberOfAttributes, final int taskId,
			final Collector<OUT> flinkOutput);

}