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()));
}
}