[
https://issues.apache.org/jira/browse/RYA-337?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16125934#comment-16125934
]
ASF GitHub Bot commented on RYA-337:
------------------------------------
Github user meiercaleb commented on a diff in the pull request:
https://github.com/apache/incubator-rya/pull/204#discussion_r132989696
--- Diff:
dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBQueryEngine.java ---
@@ -86,22 +84,10 @@ public MongoDBRdfConfiguration getConf() {
public CloseableIteration<RyaStatement, RyaDAOException> query(
final RyaStatement stmt, MongoDBRdfConfiguration conf)
throws RyaDAOException {
- if (conf == null) {
- conf = configuration;
- }
- final Long maxResults = conf.getLimit();
- final Set<DBObject> queries = new HashSet<DBObject>();
- final DBObject query = strategy.getQuery(stmt);
- queries.add(query);
- final MongoDatabase db =
mongoClient.getDatabase(conf.getMongoDBName());
- final MongoCollection<Document> collection =
db.getCollection(conf.getTriplesCollectionName());
- final RyaStatementCursorIterator iterator = new
RyaStatementCursorIterator(collection, queries, strategy,
- conf.getAuthorizations());
-
- if (maxResults != null) {
- iterator.setMaxResults(maxResults);
- }
- return iterator;
+ Entry<RyaStatement, BindingSet> entry = new
AbstractMap.SimpleEntry<>(stmt, new MapBindingSet());
--- End diff --
Check that the RyaStatement and Config are not null.
> Batch Queries to MongoDB
> ------------------------
>
> Key: RYA-337
> URL: https://issues.apache.org/jira/browse/RYA-337
> Project: Rya
> Issue Type: Improvement
> Components: dao
> Reporter: Aaron Mihalik
> Assignee: Aaron Mihalik
>
> Currently the MongoDB DAO sends one query at a time to Mongo. Instead, the
> DAO should send a batch of queries and perform a client side hash join (like
> the Accumulo DAO)
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
