class FlinkOutputFieldsDeclarer implements OutputFieldsDeclarer {

	int[] getGroupingFieldIndexes(final String streamId, final List<String> groupingFields) {
		final int[] fieldIndexes = new int[groupingFields.size()];

		for (int i = 0; i < fieldIndexes.length; ++i) {
			fieldIndexes[i] = this.outputStreams.get(streamId).fieldIndex(groupingFields.get(i));
		}

		return fieldIndexes;
	}

}