public String add()

in src/main/java/com/amazonaws/kda/flink/starterkit/Aggregator.java [24:32]

• 9 lines of code
• 2 McCabe index (conditional complexity)

	public String add(Event value, String accumulator) {
		String newAccumulator = null;
		try {
			newAccumulator =  new String(accumulator).concat("$").concat(new ObjectMapper().writeValueAsString(value));
		} catch (JsonProcessingException e) {
			e.printStackTrace();
		}
		return newAccumulator;
	}