CreateQueryPlan.java 文件源码

private String createVertices() {
    TypeAndPropertyKeyStore typeAndPropertyKeyStore = TypeAndPropertyKeyStore.getInstance();
    for (QueryVariable queryVariable : structuredQuery.getQueryVariables()) {
        Map<String, Pair<String, String>> stringVertexProperties = queryVariable.
            getVariableProperties();
        typeAndPropertyKeyStore.assertExistingKeyDataTypesMatchPreviousDeclarations(
            stringVertexProperties);

        int vertexId = Integer.parseInt(queryVariable.getVariableName());
        short vertexType = typeAndPropertyKeyStore.mapStringTypeToShortOrInsert(queryVariable.
            getVariableType());
        Map<Short, Pair<DataType, String>> vertexProperties = typeAndPropertyKeyStore.
            mapStringPropertiesToShortAndDataTypeOrInsert(stringVertexProperties);

        Graph.getInstance().addVertex(vertexId, vertexType, vertexProperties);
    }
    // TODO(amine): bug, count the actual number of vertices created to append to sink.
    return structuredQuery.getQueryVariables().size() + " vertices created.";
}