public void handleStatement()

in src/main/java/com/amazonaws/services/neptune/io/RecordSplitter.java [238:272]


        public void handleStatement(Statement statement) throws RDFHandlerException {
            Value object = statement.getObject();
            if (object.isLiteral()) {
                String objectValue = object.stringValue();
                int maxObjectLength = calculateStringMaxLength(maxStatementLength, statementLength, objectValue.length());
                Collection<String> splitValues = splitByLength(objectValue, maxObjectLength);
                for (String splitValue : splitValues) {
                    StringWriter writer = new StringWriter();
                    new NQuadsWriter(writer).consumeStatement(new Statement() {
                        @Override
                        public Resource getSubject() {
                            return statement.getSubject();
                        }

                        @Override
                        public IRI getPredicate() {
                            return statement.getPredicate();
                        }

                        @Override
                        public Value getObject() {
                            return SimpleValueFactory.getInstance().createLiteral(splitValue);
                        }

                        @Override
                        public Resource getContext() {
                            return statement.getContext();
                        }
                    });
                    results.add(writer.toString());
                }
            } else {
                results.add(String.format("%s\n", statement.toString()));
            }
        }