public Object toClass()

in src/main/java/com/amazonaws/services/kinesis/io/serializer/JsonSerializer.java [76:107]


    public Object toClass(final InputEvent event) throws IOException {
        // Return a class object from the json, or if we have no class then
        // return a String list
        List<String> jsonStringList = new ArrayList<>();

        if (this.clazz == null) {
            if (this.itemTerminator != null) {
                // break up the json items as separate lines
                String[] items = new String(event.getData(), this.charset).split(this.itemTerminator);

                for (String item : items) {
                    if (filterRegex == null || (filterRegex != null && p.matcher(item).matches())) {
                        jsonStringList.add(item);
                    }
                }

                return jsonStringList;
            } else {
                // single json object per record
                String item = new String(event.getData(), this.charset);

                if (filterRegex == null || (filterRegex != null && p.matcher(item).matches())) {
                    jsonStringList.add(item);
                }

                return jsonStringList;
            }
        } else {
            // use jackson to serialise a class instance
            return mapper.readValue(event.getData(), clazz);
        }
    }