class StormStreamSelector implements OutputSelector<SplitStreamType<T>> {

	@Override
	public Iterable<String> select(SplitStreamType<T> value) {
		String sid = value.streamId;
		List<String> streamId = this.streams.get(sid);
		if (streamId == null) {
			streamId = new ArrayList<String>(1);
			streamId.add(sid);
			this.streams.put(sid, streamId);
		}
		return streamId;
	}

}