[ https://issues.apache.org/jira/browse/RYA-487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16472095#comment-16472095 ]
ASF GitHub Bot commented on RYA-487: ------------------------------------ Github user ejwhite922 commented on a diff in the pull request: https://github.com/apache/incubator-rya/pull/296#discussion_r187640119 --- Diff: dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBRdfConfiguration.java --- @@ -274,16 +274,17 @@ public boolean getUseAggregationPipeline() { * on their child subtrees. * @param value whether to use aggregation pipeline optimization. */ - public void setUseAggregationPipeline(boolean value) { + public void setUseAggregationPipeline(final boolean value) { setBoolean(USE_AGGREGATION_PIPELINE, value); } @Override public List<Class<QueryOptimizer>> getOptimizers() { - List<Class<QueryOptimizer>> optimizers = super.getOptimizers(); + final List<Class<QueryOptimizer>> optimizers = super.getOptimizers(); if (getUseAggregationPipeline()) { - Class<?> cl = AggregationPipelineQueryOptimizer.class; + final Class<?> cl = AggregationPipelineQueryOptimizer.class; @SuppressWarnings("unchecked") + final --- End diff -- Put final on the same line as its variable > Kafka Connect Rya Sink > ---------------------- > > Key: RYA-487 > URL: https://issues.apache.org/jira/browse/RYA-487 > Project: Rya > Issue Type: New Feature > Affects Versions: 4.0.0 > Reporter: Kevin Chilton > Assignee: Kevin Chilton > Priority: Major > Fix For: 4.0.0 > > > Implement a Kafka Connect Sink that writes to Rya. > This sink does not have to handle visibilities. -- This message was sent by Atlassian JIRA (v7.6.3#76005)