This is an automated email from the ASF dual-hosted git repository. pujav65 pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/incubator-rya.git
commit 404b8acdc8e8d00117769e769bcec0710bc75958 Author: eric.white <[email protected]> AuthorDate: Tue Jun 4 16:15:10 2019 -0400 Fix compilation error --- .../org/apache/rya/forwardchain/strategy/MongoPipelineStrategy.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/extras/rya.forwardchain/src/main/java/org/apache/rya/forwardchain/strategy/MongoPipelineStrategy.java b/extras/rya.forwardchain/src/main/java/org/apache/rya/forwardchain/strategy/MongoPipelineStrategy.java index 4e80428..0091788 100644 --- a/extras/rya.forwardchain/src/main/java/org/apache/rya/forwardchain/strategy/MongoPipelineStrategy.java +++ b/extras/rya.forwardchain/src/main/java/org/apache/rya/forwardchain/strategy/MongoPipelineStrategy.java @@ -21,6 +21,7 @@ package org.apache.rya.forwardchain.strategy; import java.util.List; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.LongAdder; +import java.util.function.Consumer; import org.apache.log4j.Logger; import org.apache.rya.api.domain.RyaStatement; @@ -177,7 +178,7 @@ public class MongoPipelineStrategy extends AbstractRuleExecutionStrategy { baseCollection.aggregate(pipeline) .allowDiskUse(true) .batchSize(PIPELINE_BATCH_SIZE) - .forEach((final Document doc) -> { + .forEach((Consumer<Document>)(final Document doc) -> { final DBObject dbo = BasicDBObject.parse(doc.toJson()); final RyaStatement rstmt = storageStrategy.deserializeDBObject(dbo); if (!statementExists(rstmt)) {
