Titan BatchLoading berkeleydb не стойкий

Question

Я действительно не могу понять, где моя проблема. Im using Titan 0.5.0 (Это та же проблема с новыми версиями Titan ...)

Я хочу загрузить кучу вершин и ребер из файла csv с записями 100 тыс. (Каждая строка приводит к по меньшей мере 3 узлы и некоторые ребра) в мой граф. Это займет около 5 минут, чтобы, наконец, завершить импорт.

Так что я пробовал то же самое с конфигурацией storage.batch-loading = true. Ну, это значительно быстрее всего за 2 минуты, чтобы завершить импорт.

Но проблема в том, что если im включит опцию storage.batch-loading = true, узлы и ребра не сохраняются постоянными в базе данных. Поэтому, если я закрываю Gremlin и снова открываю свой график, он пуст.

Он работает как шарм с storage.batch-loading установленным на false. Это занимает больше времени, но записи сохраняются постоянными.

Да, я беру на себя Batchgraph после импорта, а также сам график. Я что-то упустил?

В этом примере я хочу импортировать только около 30 тыс. Узлов для тестирования, но они также не сохраняются постоянными. Конфигурация:

storage.backend=berkeleyje 
storage.directory=graph 

storage.batch-loading = true 

query.fast-property = true 

Gremlin Сценарий:

g = TitanFactory.open("../graphs/batchImportTest2/batchImportTest2.properties") 

//1 Prepare Graph for import 

m = g.getManagementSystem(); 
username = m.makePropertyKey('username').dataType(String.class).make() 
m.buildIndex('byUsername',Vertex.class).addKey(username).unique().buildCompositeIndex() 
email = m.makePropertyKey('email').dataType(String.class).make() 
m.buildIndex('byEmail',Vertex.class).addKey(email).unique().buildCompositeIndex() 
m.commit() 
g.commit() 

//2 Import Nodes and Edges 

bg = new BatchGraph(g, VertexIDType.STRING, 50000) 
new File("userInfo_js.txt").eachLine({ final String line ->def (username,email) = line.split('\t')*.trim();def userVertex = bg.getVertex(username) ?: bg.addVertex(username); userVertex.setProperty("username", username);userVertex.setProperty("email", email)}) 
bg.commit() 
g.commit() 

Answer 1

Я попытался воспроизвести его, но все это работает, как ожидалось. Смотрите мой GIST для полной записи моей оболочки сессии, может быть, вы можете заметить разницу:

https://gist.github.com/dkuppitz/5319a2fa7f9a8069fa15