Настройка JanusGraph для использования ElasticSearch и Cassandra через Java - PullRequest
Новая
       35

Настройка JanusGraph для использования ElasticSearch и Cassandra через Java

0 голосов
/ 10 января 2019

Я пытаюсь создать схему, используя janusgraph, использую cassandra в качестве внутреннего хранилища и использую упругий поиск в качестве индексатора. подключиться к JanusGraph, используя следующий код: 

Graph graph = GraphFactory.open(CONFIG_FILE);

содержимое файла конфигурации: 

gremlin.graph=org.janusgraph.core.JanusGraphFactory

storage.backend=cassandrathrift

storage.hostname=127.0.0.1

storage.cassandra.keyspace=JanusGraph

cache.db-cache = true

cache.db-cache-clean-wait = 20

cache.db-cache-time = 180000

cache.db-cache-size = 0.25

index.search.backend=elasticsearch

index.search.hostname=127.0.0.1

index.search.port=9300

способ создания индекса следующий: 

 VertexLabel user = mgt.makeVertexLabel(USER).make();
    PropertyKey userName = 
    mgt.makePropertyKey(USER_NAME).dataType(String.class).make();

    //building mixed index (i.e. we use external indexer)
    mgt.buildIndex(indexName(USER, USER_NAME), Vertex.class).
    addKey(userName, Mapping.STRING.asParameter()).
    indexOnly(user).
    buildMixedIndex(BACKING_INDEX);

Как видите, я сначала создаю вершину, а затем индексирую некоторое свойство.

когда я запускаю код без использования индексатора, у меня не возникает проблем, но когда я использую индексатор, я получаю следующее исключение: 

Exception in thread "main" java.lang.IllegalArgumentException: Could not find implementation class: org.janusgraph.diskstorage.es.ElasticSearchIndex

at org.janusgraph.util.system.ConfigurationUtil.instantiate(ConfigurationUtil.java:60)
    at org.janusgraph.diskstorage.Backend.getImplementationClass(Backend.java:476)
    at org.janusgraph.diskstorage.Backend.getIndexes(Backend.java:463)
    at org.janusgraph.diskstorage.Backend.<init>(Backend.java:148)
    at org.janusgraph.graphdb.configuration.GraphDatabaseConfiguration.getBackend(GraphDatabaseConfiguration.java:1840)
    at org.janusgraph.graphdb.database.StandardJanusGraph.<init>(StandardJanusGraph.java:138)
    at org.janusgraph.core.JanusGraphFactory.open(JanusGraphFactory.java:160)
    at org.janusgraph.core.JanusGraphFactory.open(JanusGraphFactory.java:131)
    at org.janusgraph.core.JanusGraphFactory.open(JanusGraphFactory.java:78)
    at mounaf.janusgraph.Schema.<init>(Schema.java:61)
    at mounaf.janusgraph.BuiltinQueries.main(BuiltinQueries.java:16)
Caused by: java.lang.ClassNotFoundException: org.janusgraph.diskstorage.es.ElasticSearchIndex
    at java.net.URLClassLoader.findClass(URLClassLoader.java:381)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:331)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    at java.lang.Class.forName0(Native Method)
    at java.lang.Class.forName(Class.java:264)
    at org.janusgraph.util.system.ConfigurationUtil.instantiate(ConfigurationUtil.java:56)
    ... 10 more

Вы можете помочь мне решить эту проблему.

1 Ответ

0 голосов
/ 24 апреля 2019

Я помню, что у меня были проблемы с использованием метода openManagement в java, но я использовал client.submit (String gremlin) для настройки моей схемы и индексов, и это сработало. 

client.submit("mgt = graph.openManagement()\n" +
"user = mgt.makeVertexLabel(USER).make()\n" +
"userName = mgt.makePropertyKey(USER_NAME).dataType(String.class).make()\n" +
"mgt.buildIndex(indexName(USER, USER_NAME), Vertex.class).addKey(userName, Mapping.STRING.asParameter()).indexOnly(user).buildMixedIndex(BACKING_INDEX)\n" +
"mgmt.commit()"
...