在 Titan/Janus 中启用强制索引时索引失败

Question

我已经编写了一个 JUnit 测试来检查 generate-modern.groovy 图是否存在 marko。
我的 gremlin 查询是

"g.V().has('name','marko')";

正如您在 generate-modern.groovy 文件中看到的那样，索引已经应用于此人的姓名属性。我后来做了以下

query.force-index=true

属性在 dynamodb.properties 文件中为真，它会阻止整个图形扫描，从而强制建立索引。但是它抛出以下异常

org.janusgraph.core.JanusGraphException: Could not find a suitable index to answer graph query and graph scans are disabled: [(name = marko)]:VERTEX

上述异常是从以下 StandardJanusGraphTx class 的方法

中引发的

    @Override
    public Iterator<JanusGraphElement> execute(final GraphCentricQuery query, final JointIndexQuery indexQuery, final Object exeInfo, final QueryProfiler profiler) {
        Iterator<JanusGraphElement> iter;
        if (!indexQuery.isEmpty()) {
            List<QueryUtil.IndexCall<Object>> retrievals = new ArrayList<QueryUtil.IndexCall<Object>>();
            for (int i = 0; i < indexQuery.size(); i++) {
                final JointIndexQuery.Subquery subquery = indexQuery.getQuery(i);

                retrievals.add(new QueryUtil.IndexCall<Object>() {
                    @Override
                    public Collection<Object> call(int limit) {
                        final JointIndexQuery.Subquery adjustedQuery = subquery.updateLimit(limit);
                        try {
                            return indexCache.get(adjustedQuery, new Callable<List<Object>>() {
                                @Override
                                public List<Object> call() throws Exception {
                                    return QueryProfiler.profile(subquery.getProfiler(), adjustedQuery, q -> indexSerializer.query(q, txHandle));
                                }
                            });
                        } catch (Exception e) {
                            throw new JanusGraphException("Could not call index", e.getCause());
                        }
                    }
                });
            }


            List<Object> resultSet = QueryUtil.processIntersectingRetrievals(retrievals, indexQuery.getLimit());
            iter = com.google.common.collect.Iterators.transform(resultSet.iterator(), getConversionFunction(query.getResultType()));
        } else {
            if (config.hasForceIndexUsage()) throw new JanusGraphException("Could not find a suitable index to answer graph query and graph scans are disabled: " + query);
            log.warn("Query requires iterating over all vertices [{}]. For better performance, use indexes", query.getCondition());

            QueryProfiler sub = profiler.addNested("scan");
            sub.setAnnotation(QueryProfiler.QUERY_ANNOTATION,indexQuery);
            sub.setAnnotation(QueryProfiler.FULLSCAN_ANNOTATION,true);
            sub.setAnnotation(QueryProfiler.CONDITION_ANNOTATION,query.getResultType());

            switch (query.getResultType()) {
                case VERTEX:
                    return (Iterator) getVertices().iterator();

                case EDGE:
                    return (Iterator) getEdges().iterator();

                case PROPERTY:
                    return new VertexCentricEdgeIterable(getInternalVertices(),RelationCategory.PROPERTY).iterator();

                default:
                    throw new IllegalArgumentException("Unexpected type: " + query.getResultType());
            }
        }

        return iter;
    }

};

从方法中可以看出，当JointIndexQuery对象为空（arrayList为空）且force index为true时抛出异常。
问题是为什么列表是空的？当我们在 generate-modern.groovy 中指定针对名称属性的索引查询时，从 JUnit Test.This 查询工作正常意味着当相同的数据被预加载到 gremlin 中时列表不为空服务器具有相同的文件。

Answer 1

personByName index definition 使用标签约束。

def personByName = mgmt.buildIndex("personByName", Vertex.class).addKey(name).indexOnly(person).buildCompositeIndex()

为了利用该索引，您必须使用标签和属性。例如：

g.V().has('person', 'name', 'marko')

您可以在 JanusGraph 文档中阅读更多相关信息 http://docs.janusgraph.org/latest/indexes.html#_label_constraint

在 Titan/Janus 中启用强制索引时索引失败

Indexing fails on enabling force index in Titan/Janus

titan

tinkerpop3

janusgraph