class JsonIngestHelper extends ContentBaseIngestHelper {

    @Override
    public Multimap<String,NormalizedContentInterface> getEventFields(RawRecordContainer event) {
        
        if (null == flattener) {
            throw new IllegalStateException("JsonObjectFlattener was not initialized. Method 'setup' must be invoked first");
        }
        
        HashMultimap<String,String> fields = HashMultimap.create();
        String jsonString = new String(event.getRawData());
        
        JsonParser parser = new JsonParser();
        JsonElement jsonElement = parser.parse(jsonString);
        flattener.flatten(jsonElement.getAsJsonObject(), fields);
        
        return normalizeMap(getGroupNormalizedMap(fields));
    }

}