class SamplerImpl implements Sampler {

	@Timed
	@Override
	public Set<SimilaritySet> processRecommendations(Collection<IntArrayPair> recommendations) {
		return StreamUtils.stream(recommendations, parallel)
			.map(this::calculateSimilaritySet)
			.collect(Collectors.toSet());
	}

}