class Collect extends DataSetAnalyticBase<T, List<T>> {

	@Override
	public Collect<T> run(DataSet<T> input)
			throws Exception {
		super.run(input);

		serializer = input.getType().createSerializer(env.getConfig());

		collectHelper = new CollectHelper<>(serializer);

		input
			.output(collectHelper)
				.name("Collect");

		return this;
	}

}