in src/main/java/com/amazonaws/kda/flink/benchmarking/util/KDSProducerUtil.java [63:82]
public static List<String> createEvents(List<String> eventList, int numEvents, String sessionId) {
// clear the eventList and build it up again!
eventList.clear();
long createTime = System.currentTimeMillis();
for (int i = 1; i < numEvents + 1; i++) {
Event event = new Event();
event.setAttr_1("my_attr_1_" + i);
event.setAttr_2("my_attr_2_" + i);
event.setAttr_3("my_attr_3_" + i);
event.setAttr_4("my_attr_4_" + i);
event.setAttr_5("my_attr_5_" + i);
event.setAttr_6(sessionId);
event.setAttr_7(createTime);
event.setSession_id(sessionId);
event.setTimestamp(createTime);
eventList.add(new Gson().toJson(event));
}
return eventList;
}