src/main/java/com/amazonaws/services/neptune/propertygraph/io/NeptuneStreamsJsonPropertyGraphPrinter.java [67:88]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void printProperties(String id, String streamOperation, Map<?, ?> properties) throws IOException {

        for (Map.Entry<?, ?> entry : properties.entrySet()) {
            String key = String.valueOf(entry.getKey());
            Object value = entry.getValue();

            if (isList(value)) {

                List<?> values = (List<?>) value;
                for (Object o : values) {
                    PropertySchema propertySchema = new PropertySchema(key);
                    propertySchema.accept(o, true);
                    printRecord(id, streamOperation, key, o, propertySchema.dataType());
                }

            } else {
                PropertySchema propertySchema = new PropertySchema(key);
                propertySchema.accept(value, true);
                printRecord(id, streamOperation, key, value, propertySchema.dataType());
            }
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/amazonaws/services/neptune/propertygraph/io/NeptuneStreamsSimpleJsonPropertyGraphPrinter.java [68:89]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    public void printProperties(String id, String streamOperation, Map<?, ?> properties) throws IOException {

        for (Map.Entry<?, ?> entry : properties.entrySet()) {
            String key = String.valueOf(entry.getKey());
            Object value = entry.getValue();

            if (isList(value)) {

                List<?> values = (List<?>) value;
                for (Object o : values) {
                    PropertySchema propertySchema = new PropertySchema(key);
                    propertySchema.accept(o, true);
                    printRecord(id, streamOperation, key, o, propertySchema.dataType());
                }

            } else {
                PropertySchema propertySchema = new PropertySchema(key);
                propertySchema.accept(value, true);
                printRecord(id, streamOperation, key, value, propertySchema.dataType());
            }
        }
    }
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -