Skip to content
This repository was archived by the owner on Jul 29, 2024. It is now read-only.

Commit 4779217

Browse files
committed
replaced StringBuilder and StringBuffer with String
replaced StringBuilder and StringBuffer based on aggregation operations with String
1 parent c466bc5 commit 4779217

File tree

1 file changed

+4
-6
lines changed

1 file changed

+4
-6
lines changed

src/main/java/com/amazonaws/kda/flink/starterkit/Aggregator.java

Lines changed: 4 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -22,13 +22,13 @@ public String createAccumulator() {
2222

2323
@Override
2424
public String add(Event value, String accumulator) {
25-
StringBuffer acc = new StringBuffer();
25+
String newAccumulator = null;
2626
try {
27-
acc.append(accumulator).append("$").append(new ObjectMapper().writeValueAsString(value));
27+
newAccumulator = new String(accumulator).concat("$").concat(new ObjectMapper().writeValueAsString(value));
2828
} catch (JsonProcessingException e) {
2929
e.printStackTrace();
3030
}
31-
return acc.toString();
31+
return newAccumulator;
3232
}
3333

3434
@Override
@@ -38,9 +38,7 @@ public String getResult(String accumulator) {
3838

3939
@Override
4040
public String merge(String a, String b) {
41-
StringBuilder acc = new StringBuilder();
42-
acc.append(a).append("$").append(b);
43-
return acc.toString();
41+
return new String(a).concat("$").concat(b);
4442
}
4543

4644
}

0 commit comments

Comments
 (0)