}
public static ImportResult importGraph1(Session session, VirtualGraph vg, final TransferableGraphSource tg, IImportAdvisor advisor_, TGStatusMonitor monitor) throws DatabaseException {
+ return importGraph1(session, vg, tg, advisor_, monitor, null);
+ }
+
+ public static ImportResult importGraph1(Session session, VirtualGraph vg, final TransferableGraphSource tg, IImportAdvisor advisor_, TGStatusMonitor monitor, Boolean failOnMissing) throws DatabaseException {
final IImportAdvisor2 advisor = (advisor_ instanceof IImportAdvisor2) ? ((IImportAdvisor2)advisor_) : new WrapperAdvisor(advisor_);
- final StreamingTransferableGraphImportProcess process = new StreamingTransferableGraphImportProcess(session, vg, tg, advisor, monitor);
+ final StreamingTransferableGraphImportProcess process = failOnMissing == null ? new StreamingTransferableGraphImportProcess(session, vg, tg, advisor, monitor)
+ : new StreamingTransferableGraphImportProcess(session, vg, tg, advisor, monitor, failOnMissing);
session.syncRequest(new ReadRequest() {
@Override
public void run(ReadGraph graph) throws DatabaseException {
private static void writeTransferableGraph(RequestProcessor processor, final TransferableGraphSource source, final RandomAccessBinary out, TGStatusMonitor monitor) throws Exception {
long start = System.nanoTime();
-
+ try {
final Serializer datatypeSerializer = Bindings.getSerializerUnchecked(Datatype.class);
final Serializer identitySerializer = Bindings.getSerializerUnchecked(Identity.class);
final Serializer extensionSerializer = Bindings.getSerializerUnchecked(Extensions.class);
}
}
});
+ } finally {
+ source.close();
+ }
long end = System.nanoTime();
LOGGER.info("Wrote transferable graph in {} seconds.", 1e-9*(end-start));