http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/storage/accumulo/VariableOrder.java ---------------------------------------------------------------------- diff --git a/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/storage/accumulo/VariableOrder.java b/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/storage/accumulo/VariableOrder.java index 7e903bc..6ec801e 100644 --- a/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/storage/accumulo/VariableOrder.java +++ b/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/storage/accumulo/VariableOrder.java @@ -23,8 +23,9 @@ import static com.google.common.base.Preconditions.checkNotNull; import java.util.Collection; import java.util.Iterator; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; -// SEE RYA-211 import javax.annotation.concurrent.Immutable; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; +import net.jcip.annotations.Immutable; import org.openrdf.query.BindingSet; @@ -36,8 +37,8 @@ import com.google.common.collect.ImmutableList; * specify the order {@link Binding}s within the set are serialized to Accumulo. * This order effects which rows a prefix scan will hit. */ -// SEE RYA-211 @Immutable -// SEE RYA-211 @ParametersAreNonnullByDefault +@Immutable +@DefaultAnnotation(NonNull.class) public final class VariableOrder implements Iterable<String> { public static final String VAR_ORDER_DELIM = ";";
http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/storage/accumulo/VisibilityBindingSet.java ---------------------------------------------------------------------- diff --git a/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/storage/accumulo/VisibilityBindingSet.java b/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/storage/accumulo/VisibilityBindingSet.java index d98f556..740c41e 100644 --- a/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/storage/accumulo/VisibilityBindingSet.java +++ b/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/storage/accumulo/VisibilityBindingSet.java @@ -20,14 +20,15 @@ package org.apache.rya.indexing.pcj.storage.accumulo; import static java.util.Objects.requireNonNull; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.openrdf.query.BindingSet; /** * Decorates a {@link BindingSet} with a collection of visibilities. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class VisibilityBindingSet extends BindingSetDecorator { private static final long serialVersionUID = 1L; private String visibility; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/storage/accumulo/VisibilityBindingSetStringConverter.java ---------------------------------------------------------------------- diff --git a/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/storage/accumulo/VisibilityBindingSetStringConverter.java b/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/storage/accumulo/VisibilityBindingSetStringConverter.java index 8530efe..942ba38 100644 --- a/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/storage/accumulo/VisibilityBindingSetStringConverter.java +++ b/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/storage/accumulo/VisibilityBindingSetStringConverter.java @@ -18,7 +18,8 @@ */ package org.apache.rya.indexing.pcj.storage.accumulo; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.openrdf.query.BindingSet; @@ -26,7 +27,7 @@ import org.openrdf.query.BindingSet; * Converts {@link BindingSet}s to Strings and back again. The Strings do not * include the binding names and are ordered with a {@link VariableOrder}. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class VisibilityBindingSetStringConverter extends BindingSetStringConverter { public static final char VISIBILITY_DELIM = 1; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/update/PrecomputedJoinUpdater.java ---------------------------------------------------------------------- diff --git a/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/update/PrecomputedJoinUpdater.java b/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/update/PrecomputedJoinUpdater.java index 462bf4d..2baa52e 100644 --- a/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/update/PrecomputedJoinUpdater.java +++ b/extras/rya.indexing.pcj/src/main/java/org/apache/rya/indexing/pcj/update/PrecomputedJoinUpdater.java @@ -20,7 +20,8 @@ package org.apache.rya.indexing.pcj.update; import java.util.Collection; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.rya.indexing.pcj.storage.PcjException; @@ -30,7 +31,7 @@ import org.apache.rya.api.domain.RyaStatement; * Updates the state of all PCJ indices whenever {@link RyaStatement}s are * added to or removed from the system. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public interface PrecomputedJoinUpdater { /** http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.api/src/main/java/org/apache/rya/indexing/pcj/fluo/api/CreatePcj.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.api/src/main/java/org/apache/rya/indexing/pcj/fluo/api/CreatePcj.java b/extras/rya.pcj.fluo/pcj.fluo.api/src/main/java/org/apache/rya/indexing/pcj/fluo/api/CreatePcj.java index 1066050..1259a01 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.api/src/main/java/org/apache/rya/indexing/pcj/fluo/api/CreatePcj.java +++ b/extras/rya.pcj.fluo/pcj.fluo.api/src/main/java/org/apache/rya/indexing/pcj/fluo/api/CreatePcj.java @@ -26,7 +26,8 @@ import static org.apache.rya.indexing.pcj.fluo.app.IncrementalUpdateConstants.NO import java.util.HashSet; import java.util.Set; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.rya.indexing.pcj.fluo.app.FluoStringConverter; import org.apache.rya.indexing.pcj.fluo.app.query.FluoQuery; @@ -71,7 +72,7 @@ import org.apache.fluo.api.client.Transaction; * will percolate to the top of the query, and those results will be exported to * Rya's query system. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class CreatePcj { /** http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.api/src/main/java/org/apache/rya/indexing/pcj/fluo/api/DeletePcj.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.api/src/main/java/org/apache/rya/indexing/pcj/fluo/api/DeletePcj.java b/extras/rya.pcj.fluo/pcj.fluo.api/src/main/java/org/apache/rya/indexing/pcj/fluo/api/DeletePcj.java index 4d3d779..1d92262 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.api/src/main/java/org/apache/rya/indexing/pcj/fluo/api/DeletePcj.java +++ b/extras/rya.pcj.fluo/pcj.fluo.api/src/main/java/org/apache/rya/indexing/pcj/fluo/api/DeletePcj.java @@ -25,7 +25,8 @@ import java.util.ArrayList; import java.util.Iterator; import java.util.List; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.rya.indexing.pcj.fluo.app.NodeType; import org.apache.rya.indexing.pcj.fluo.app.query.FilterMetadata; @@ -56,7 +57,7 @@ import org.apache.fluo.api.data.Span; * into memory.</li> * </ol> */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class DeletePcj { private final FluoQueryMetadataDAO dao = new FluoQueryMetadataDAO(); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.api/src/main/java/org/apache/rya/indexing/pcj/fluo/api/GetQueryReport.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.api/src/main/java/org/apache/rya/indexing/pcj/fluo/api/GetQueryReport.java b/extras/rya.pcj.fluo/pcj.fluo.api/src/main/java/org/apache/rya/indexing/pcj/fluo/api/GetQueryReport.java index 51d580d..1fb1485 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.api/src/main/java/org/apache/rya/indexing/pcj/fluo/api/GetQueryReport.java +++ b/extras/rya.pcj.fluo/pcj.fluo.api/src/main/java/org/apache/rya/indexing/pcj/fluo/api/GetQueryReport.java @@ -26,8 +26,9 @@ import java.util.List; import java.util.Map; import edu.umd.cs.findbugs.annotations.Nullable; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; -// SEE RYA-211 import javax.annotation.concurrent.Immutable; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; +import net.jcip.annotations.Immutable; import org.apache.rya.indexing.pcj.fluo.app.query.FilterMetadata; import org.apache.rya.indexing.pcj.fluo.app.query.FluoQuery; @@ -50,7 +51,7 @@ import org.apache.fluo.api.data.Span; * Get a reports that indicates how many binding sets have been emitted for * the queries that is being managed by the fluo application. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class GetQueryReport { private final FluoQueryMetadataDAO metadataDao = new FluoQueryMetadataDAO(); @@ -145,8 +146,8 @@ public class GetQueryReport { * as well as the number of Binding Sets that have been emitted for each of * the query nodes. */ -// SEE RYA-211 @Immutable -// SEE RYA-211 @ParametersAreNonnullByDefault + @Immutable + @DefaultAnnotation(NonNull.class) public static final class QueryReport { /** @@ -212,7 +213,7 @@ public class GetQueryReport { /** * Builds instances of {@link QueryReport}. */ -// SEE RYA-211 @ParametersAreNonnullByDefault + @DefaultAnnotation(NonNull.class) public static final class Builder { private FluoQuery fluoQuery = null; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/BindingSetRow.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/BindingSetRow.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/BindingSetRow.java index 16374ad..8c8505d 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/BindingSetRow.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/BindingSetRow.java @@ -21,8 +21,9 @@ package org.apache.rya.indexing.pcj.fluo.app; import static com.google.common.base.Preconditions.checkNotNull; import static org.apache.rya.indexing.pcj.fluo.app.IncrementalUpdateConstants.NODEID_BS_DELIM; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; -// SEE RYA-211 import javax.annotation.concurrent.Immutable; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; +import net.jcip.annotations.Immutable; import org.apache.fluo.api.data.Bytes; @@ -30,8 +31,8 @@ import org.apache.fluo.api.data.Bytes; * The values of an Accumulo Row ID for a row that stores a Binding set for * a specific Node ID of a query. */ -// SEE RYA-211 @Immutable -// SEE RYA-211 @ParametersAreNonnullByDefault +@Immutable +@DefaultAnnotation(NonNull.class) public class BindingSetRow { private final String nodeId; private final String bindingSetString; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/FilterFinder.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/FilterFinder.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/FilterFinder.java index 034f510..ae976ee 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/FilterFinder.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/FilterFinder.java @@ -23,7 +23,8 @@ import static com.google.common.base.Preconditions.checkNotNull; import java.util.concurrent.atomic.AtomicReference; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.openrdf.query.algebra.Filter; import org.openrdf.query.algebra.helpers.QueryModelVisitorBase; @@ -35,7 +36,7 @@ import com.google.common.base.Optional; /** * Searches a SPARQL query for {@link Filter}s. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) class FilterFinder { /** http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/FilterResultUpdater.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/FilterResultUpdater.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/FilterResultUpdater.java index 85b7bd7..3b17a33 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/FilterResultUpdater.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/FilterResultUpdater.java @@ -21,7 +21,8 @@ package org.apache.rya.indexing.pcj.fluo.app; import static com.google.common.base.Preconditions.checkNotNull; import static org.apache.rya.indexing.pcj.fluo.app.IncrementalUpdateConstants.NODEID_BS_DELIM; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.rya.indexing.pcj.fluo.app.query.FilterMetadata; import org.apache.rya.indexing.pcj.fluo.app.query.FluoQueryColumns; @@ -57,7 +58,7 @@ import org.apache.fluo.api.data.Column; * Updates the results of a Filter node when its child has added a new Binding * Set to its results. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class FilterResultUpdater { private static final BindingSetStringConverter ID_CONVERTER = new BindingSetStringConverter(); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/FluoStringConverter.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/FluoStringConverter.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/FluoStringConverter.java index 86676cb..5221c21 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/FluoStringConverter.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/FluoStringConverter.java @@ -23,7 +23,8 @@ import static org.apache.rya.indexing.pcj.fluo.app.IncrementalUpdateConstants.DE import static org.apache.rya.indexing.pcj.fluo.app.IncrementalUpdateConstants.TYPE_DELIM; import static org.apache.rya.indexing.pcj.fluo.app.IncrementalUpdateConstants.URI_TYPE; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.openrdf.model.Literal; import org.openrdf.model.URI; @@ -40,7 +41,7 @@ import org.apache.rya.api.resolver.RdfToRyaConversions; * Contains method that convert between the Sesame representations of RDF * components and the Strings that are used by the Fluo PCJ application. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class FluoStringConverter { /** http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/JoinResultUpdater.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/JoinResultUpdater.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/JoinResultUpdater.java index 7661959..9084cd6 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/JoinResultUpdater.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/JoinResultUpdater.java @@ -27,7 +27,8 @@ import java.util.Iterator; import java.util.List; import java.util.Set; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.rya.indexing.pcj.fluo.app.query.FluoQueryColumns; import org.apache.rya.indexing.pcj.fluo.app.query.FluoQueryMetadataDAO; @@ -57,7 +58,7 @@ import org.apache.fluo.api.data.Span; * Updates the results of a Join node when one of its children has added a * new Binding Set to its results. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class JoinResultUpdater { private static final BindingSetStringConverter idConverter = new BindingSetStringConverter(); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/QueryResultUpdater.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/QueryResultUpdater.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/QueryResultUpdater.java index 947e624..9cd2bd7 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/QueryResultUpdater.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/QueryResultUpdater.java @@ -21,7 +21,8 @@ package org.apache.rya.indexing.pcj.fluo.app; import static com.google.common.base.Preconditions.checkNotNull; import static org.apache.rya.indexing.pcj.fluo.app.IncrementalUpdateConstants.NODEID_BS_DELIM; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.rya.indexing.pcj.fluo.app.query.FluoQueryColumns; import org.apache.rya.indexing.pcj.fluo.app.query.QueryMetadata; @@ -39,7 +40,7 @@ import org.apache.fluo.api.data.Column; * Updates the results of a Query node when one of its children has added a * new Binding Set to its results. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class QueryResultUpdater { private final BindingSetStringConverter converter = new BindingSetStringConverter(); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/IncrementalResultExporter.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/IncrementalResultExporter.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/IncrementalResultExporter.java index e58d2d4..a0edbda 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/IncrementalResultExporter.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/IncrementalResultExporter.java @@ -18,7 +18,8 @@ */ package org.apache.rya.indexing.pcj.fluo.app.export; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.fluo.api.client.TransactionBase; import org.apache.rya.indexing.pcj.storage.accumulo.VisibilityBindingSet; @@ -28,7 +29,7 @@ import org.apache.rya.indexing.pcj.storage.accumulo.VisibilityBindingSet; * Exports a single Binding Set that is a new result for a SPARQL query to some * other location. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public interface IncrementalResultExporter { /** http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/IncrementalResultExporterFactory.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/IncrementalResultExporterFactory.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/IncrementalResultExporterFactory.java index feb648f..f9fe2bd 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/IncrementalResultExporterFactory.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/IncrementalResultExporterFactory.java @@ -18,7 +18,8 @@ */ package org.apache.rya.indexing.pcj.fluo.app.export; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import com.google.common.base.Optional; @@ -28,7 +29,7 @@ import org.apache.fluo.api.observer.Observer.Context; * Builds instances of {@link IncrementalResultExporter} using the provided * configurations. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public interface IncrementalResultExporterFactory { /** http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/ParametersBase.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/ParametersBase.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/ParametersBase.java index b19c7cd..a21ba14 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/ParametersBase.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/ParametersBase.java @@ -22,14 +22,15 @@ import static com.google.common.base.Preconditions.checkNotNull; import java.util.Map; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import com.google.common.base.Optional; /** * Contains common parsing functions that make it easier to interpret parameter maps. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public abstract class ParametersBase { protected final Map<String, String> params; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/rya/RyaExportParameters.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/rya/RyaExportParameters.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/rya/RyaExportParameters.java index c220bee..cba6a43 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/rya/RyaExportParameters.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/export/rya/RyaExportParameters.java @@ -21,7 +21,8 @@ package org.apache.rya.indexing.pcj.fluo.app.export.rya; import java.util.Map; import edu.umd.cs.findbugs.annotations.Nullable; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.rya.indexing.pcj.fluo.app.export.ParametersBase; @@ -34,7 +35,7 @@ import org.apache.fluo.api.observer.Observer; * {@link Observer#init(io.fluo.api.observer.Observer.Context)} method related * to Rya PCJ exporting. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class RyaExportParameters extends ParametersBase { public static final String CONF_EXPORT_TO_RYA = "pcj.fluo.export.rya.enabled"; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/observers/BindingSetUpdater.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/observers/BindingSetUpdater.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/observers/BindingSetUpdater.java index 5e56009..20d3005 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/observers/BindingSetUpdater.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/observers/BindingSetUpdater.java @@ -20,7 +20,8 @@ package org.apache.rya.indexing.pcj.fluo.app.observers; import static com.google.common.base.Preconditions.checkNotNull; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.rya.indexing.pcj.fluo.app.BindingSetRow; import org.apache.rya.indexing.pcj.fluo.app.FilterResultUpdater; @@ -44,7 +45,7 @@ import org.apache.fluo.api.observer.AbstractObserver; * Set. This observer updates its parent if the new Binding Set effects the parent's * results. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public abstract class BindingSetUpdater extends AbstractObserver { // DAO http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/CommonNodeMetadata.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/CommonNodeMetadata.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/CommonNodeMetadata.java index ee1f364..e54acf1 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/CommonNodeMetadata.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/CommonNodeMetadata.java @@ -20,8 +20,9 @@ package org.apache.rya.indexing.pcj.fluo.app.query; import static com.google.common.base.Preconditions.checkNotNull; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; -// SEE RYA-211 import javax.annotation.concurrent.Immutable; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; +import net.jcip.annotations.Immutable; import org.apache.commons.lang3.builder.EqualsBuilder; import org.apache.rya.indexing.pcj.storage.accumulo.VariableOrder; @@ -31,8 +32,8 @@ import com.google.common.base.Objects; /** * Metadata that is common to all nodes that are part of a query. */ -// SEE RYA-211 @Immutable -// SEE RYA-211 @ParametersAreNonnullByDefault +@Immutable +@DefaultAnnotation(NonNull.class) public abstract class CommonNodeMetadata { private final String nodeId; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FilterMetadata.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FilterMetadata.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FilterMetadata.java index 481f520..8866bd4 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FilterMetadata.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FilterMetadata.java @@ -22,8 +22,9 @@ import static com.google.common.base.Preconditions.checkArgument; import static com.google.common.base.Preconditions.checkNotNull; import edu.umd.cs.findbugs.annotations.Nullable; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; -// SEE RYA-211 import javax.annotation.concurrent.Immutable; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; +import net.jcip.annotations.Immutable; import org.apache.commons.lang3.builder.EqualsBuilder; import org.apache.rya.indexing.pcj.storage.accumulo.VariableOrder; @@ -33,8 +34,8 @@ import com.google.common.base.Objects; /** * Metadata that is specific to Filter nodes. */ -// SEE RYA-211 @Immutable -// SEE RYA-211 @ParametersAreNonnullByDefault +@Immutable +@DefaultAnnotation(NonNull.class) public class FilterMetadata extends CommonNodeMetadata { private final String originalSparql; @@ -158,7 +159,7 @@ public class FilterMetadata extends CommonNodeMetadata { /** * Builds instances of {@link FilterMetadata}. */ -// SEE RYA-211 @ParametersAreNonnullByDefault + @DefaultAnnotation(NonNull.class) public static final class Builder { private final String nodeId; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FluoQuery.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FluoQuery.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FluoQuery.java index 4d3002e..263db7e 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FluoQuery.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FluoQuery.java @@ -26,8 +26,9 @@ import java.util.Map; import java.util.Map.Entry; import edu.umd.cs.findbugs.annotations.Nullable; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; -// SEE RYA-211 import javax.annotation.concurrent.Immutable; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; +import net.jcip.annotations.Immutable; import org.apache.commons.lang3.builder.EqualsBuilder; @@ -38,8 +39,8 @@ import com.google.common.collect.ImmutableMap; /** * Metadata for every node of a query that is being updated by the Fluo application. */ -// SEE RYA-211 @Immutable -// SEE RYA-211 @ParametersAreNonnullByDefault +@Immutable +@DefaultAnnotation(NonNull.class) public class FluoQuery { private final QueryMetadata queryMetadata; @@ -196,7 +197,7 @@ public class FluoQuery { /** * Builds instances of {@link FluoQuery}. */ -// SEE RYA-211 @ParametersAreNonnullByDefault + @DefaultAnnotation(NonNull.class) public static final class Builder { private QueryMetadata.Builder queryBuilder = null; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FluoQueryColumns.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FluoQueryColumns.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FluoQueryColumns.java index 9b9836f..f12c6ab 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FluoQueryColumns.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FluoQueryColumns.java @@ -23,7 +23,8 @@ import static java.util.Objects.requireNonNull; import java.util.Arrays; import java.util.List; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.fluo.api.data.Column; @@ -163,7 +164,7 @@ public class FluoQueryColumns { * Enumerates the {@link Column}s that hold all of the fields for each type * of node that can compose a query. */ -// SEE RYA-211 @ParametersAreNonnullByDefault + @DefaultAnnotation(NonNull.class) public enum QueryNodeMetadataColumns { /** * The columns a {@link QueryMetadata} object's fields are stored within. http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FluoQueryMetadataDAO.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FluoQueryMetadataDAO.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FluoQueryMetadataDAO.java index 8886b39..f9acb11 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FluoQueryMetadataDAO.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/FluoQueryMetadataDAO.java @@ -22,7 +22,8 @@ import static com.google.common.base.Preconditions.checkNotNull; import java.util.Map; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.rya.indexing.pcj.fluo.app.NodeType; import org.apache.rya.indexing.pcj.fluo.app.query.JoinMetadata.JoinType; @@ -39,7 +40,7 @@ import org.apache.fluo.api.data.Column; * Reads and writes {@link FluoQuery} instances and their components to/from * a Fluo table. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class FluoQueryMetadataDAO { /** http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/JoinMetadata.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/JoinMetadata.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/JoinMetadata.java index 7dfcf37..7bad9a7 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/JoinMetadata.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/JoinMetadata.java @@ -21,8 +21,9 @@ package org.apache.rya.indexing.pcj.fluo.app.query; import static com.google.common.base.Preconditions.checkNotNull; import edu.umd.cs.findbugs.annotations.Nullable; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; -// SEE RYA-211 import javax.annotation.concurrent.Immutable; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; +import net.jcip.annotations.Immutable; import org.apache.commons.lang3.builder.EqualsBuilder; import org.apache.rya.indexing.pcj.storage.accumulo.VariableOrder; @@ -32,8 +33,8 @@ import com.google.common.base.Objects; /** * Metadata that is specific to Join nodes. */ -// SEE RYA-211 @Immutable -// SEE RYA-211 @ParametersAreNonnullByDefault +@Immutable +@DefaultAnnotation(NonNull.class) public class JoinMetadata extends CommonNodeMetadata { /** @@ -161,7 +162,7 @@ public class JoinMetadata extends CommonNodeMetadata { /** * Builds instances of {@link JoinMetadata}. */ -// SEE RYA-211 @ParametersAreNonnullByDefault + @DefaultAnnotation(NonNull.class) public static final class Builder { private final String nodeId; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/QueryMetadata.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/QueryMetadata.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/QueryMetadata.java index 7bb3c5f..064cfe8 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/QueryMetadata.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/QueryMetadata.java @@ -21,8 +21,9 @@ package org.apache.rya.indexing.pcj.fluo.app.query; import static com.google.common.base.Preconditions.checkNotNull; import edu.umd.cs.findbugs.annotations.Nullable; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; -// SEE RYA-211 import javax.annotation.concurrent.Immutable; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; +import net.jcip.annotations.Immutable; import org.apache.commons.lang3.builder.EqualsBuilder; import org.apache.rya.indexing.pcj.storage.accumulo.VariableOrder; @@ -32,8 +33,8 @@ import com.google.common.base.Objects; /** * Metadata that is specific to a Projection. */ -// SEE RYA-211 @Immutable -// SEE RYA-211 @ParametersAreNonnullByDefault +@Immutable +@DefaultAnnotation(NonNull.class) public class QueryMetadata extends CommonNodeMetadata { private final String sparql; @@ -125,7 +126,7 @@ public class QueryMetadata extends CommonNodeMetadata { /** * Builds instances of {@link QueryMetadata}. */ -// SEE RYA-211 @ParametersAreNonnullByDefault + @DefaultAnnotation(NonNull.class) public static final class Builder { private final String nodeId; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/SparqlFluoQueryBuilder.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/SparqlFluoQueryBuilder.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/SparqlFluoQueryBuilder.java index 15039c1..2128700 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/SparqlFluoQueryBuilder.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/SparqlFluoQueryBuilder.java @@ -32,8 +32,9 @@ import java.util.Map; import java.util.Set; import java.util.UUID; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; -// SEE RYA-211 import javax.annotation.concurrent.Immutable; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; +import net.jcip.annotations.Immutable; import org.apache.rya.indexing.pcj.fluo.app.FilterResultUpdater; import org.apache.rya.indexing.pcj.fluo.app.FluoStringConverter; @@ -89,7 +90,7 @@ public class SparqlFluoQueryBuilder { * of a {@link ParsedQuery}. This structure should only be used while creating * a new PCJ in Fluo and disposed of afterwards. */ -// SEE RYA-211 @ParametersAreNonnullByDefault + @DefaultAnnotation(NonNull.class) public static final class NodeIds { /** @@ -415,8 +416,8 @@ public class SparqlFluoQueryBuilder { /** * Holds the Variable Order of the binding sets for the children of a join node. */ -// SEE RYA-211 @Immutable -// SEE RYA-211 @ParametersAreNonnullByDefault + @Immutable + @DefaultAnnotation(NonNull.class) private static final class JoinVarOrders { private final VariableOrder leftVarOrder; private final VariableOrder rightVarOrder; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/StatementPatternMetadata.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/StatementPatternMetadata.java b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/StatementPatternMetadata.java index 2531436..7de10d5 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/StatementPatternMetadata.java +++ b/extras/rya.pcj.fluo/pcj.fluo.app/src/main/java/org/apache/rya/indexing/pcj/fluo/app/query/StatementPatternMetadata.java @@ -21,8 +21,9 @@ package org.apache.rya.indexing.pcj.fluo.app.query; import static com.google.common.base.Preconditions.checkNotNull; import edu.umd.cs.findbugs.annotations.Nullable; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; -// SEE RYA-211 import javax.annotation.concurrent.Immutable; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; +import net.jcip.annotations.Immutable; import org.apache.commons.lang3.builder.EqualsBuilder; import org.apache.rya.indexing.pcj.storage.accumulo.VariableOrder; @@ -32,8 +33,8 @@ import com.google.common.base.Objects; /** * Metadata that is specific to Statement Pattern nodes. */ -// SEE RYA-211 @Immutable -// SEE RYA-211 @ParametersAreNonnullByDefault +@Immutable +@DefaultAnnotation(NonNull.class) public class StatementPatternMetadata extends CommonNodeMetadata { private final String statementPattern; @@ -125,7 +126,7 @@ public class StatementPatternMetadata extends CommonNodeMetadata { /** * Builds instances of {@link StatementPatternMetadata}. */ -// SEE RYA-211 @ParametersAreNonnullByDefault + @DefaultAnnotation(NonNull.class) public static final class Builder { private final String nodeId; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/PcjAdminClient.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/PcjAdminClient.java b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/PcjAdminClient.java index cadb035..901f39d 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/PcjAdminClient.java +++ b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/PcjAdminClient.java @@ -32,7 +32,8 @@ import java.util.List; import java.util.Properties; import java.util.Set; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.accumulo.core.client.AccumuloException; import org.apache.accumulo.core.client.AccumuloSecurityException; @@ -65,7 +66,7 @@ import org.apache.rya.rdftriplestore.RyaSailRepository; /** * An application that helps Rya PCJ administrators interact with the cluster. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class PcjAdminClient { private static final Logger log = LogManager.getLogger(PcjAdminClient.class); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/PcjAdminClientCommand.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/PcjAdminClientCommand.java b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/PcjAdminClientCommand.java index 5d546a5..2b3b105 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/PcjAdminClientCommand.java +++ b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/PcjAdminClientCommand.java @@ -18,7 +18,8 @@ */ package org.apache.rya.indexing.pcj.fluo.client; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.accumulo.core.client.Connector; @@ -28,7 +29,7 @@ import org.apache.rya.rdftriplestore.RyaSailRepository; /** * A command that may be executed by the {@link PcjAdminClient}. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public interface PcjAdminClientCommand { /** http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/PcjAdminClientProperties.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/PcjAdminClientProperties.java b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/PcjAdminClientProperties.java index d5aca09..02f344d 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/PcjAdminClientProperties.java +++ b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/PcjAdminClientProperties.java @@ -23,13 +23,14 @@ import static com.google.common.base.Preconditions.checkNotNull; import java.util.Properties; import edu.umd.cs.findbugs.annotations.Nullable; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; /** * Interprets a {@link Properties} object so that it is easier to access * configuration values used by {@link PcjAdminClient}. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class PcjAdminClientProperties { // Properties that configure how Fluo will connect to Accumulo. http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/command/ListQueriesCommand.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/command/ListQueriesCommand.java b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/command/ListQueriesCommand.java index 95d36f4..d242372 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/command/ListQueriesCommand.java +++ b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/command/ListQueriesCommand.java @@ -23,7 +23,8 @@ import static com.google.common.base.Preconditions.checkNotNull; import java.util.HashMap; import java.util.Map; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.accumulo.core.client.Connector; import org.apache.logging.log4j.LogManager; @@ -47,7 +48,7 @@ import org.apache.rya.rdftriplestore.RyaSailRepository; /** * A command that lists information about the queries that are being managed by the Fluo app. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class ListQueriesCommand implements PcjAdminClientCommand { private static final Logger log = LogManager.getLogger(ListQueriesCommand.class); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/command/LoadTriplesCommand.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/command/LoadTriplesCommand.java b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/command/LoadTriplesCommand.java index 99da653..8a7004d 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/command/LoadTriplesCommand.java +++ b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/command/LoadTriplesCommand.java @@ -25,7 +25,8 @@ import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.accumulo.core.client.Connector; import org.apache.commons.io.FilenameUtils; @@ -51,7 +52,7 @@ import org.apache.rya.rdftriplestore.RyaSailRepository; /** * A command that loads the contents of an NTriple file into the Fluo application. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class LoadTriplesCommand implements PcjAdminClientCommand { private static final Logger log = LogManager.getLogger(LoadTriplesCommand.class); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/command/NewQueryCommand.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/command/NewQueryCommand.java b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/command/NewQueryCommand.java index b5d3c9e..e612a07 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/command/NewQueryCommand.java +++ b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/command/NewQueryCommand.java @@ -25,7 +25,8 @@ import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.accumulo.core.client.Connector; import org.apache.commons.io.IOUtils; @@ -52,7 +53,7 @@ import org.apache.rya.rdftriplestore.RyaSailRepository; * A command that creates a creates a new PCJ in the Fluo app and loads historic * statement pattern matches for it. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class NewQueryCommand implements PcjAdminClientCommand { private static final Logger log = LogManager.getLogger(NewQueryCommand.class); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/util/ParsedQueryRequest.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/util/ParsedQueryRequest.java b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/util/ParsedQueryRequest.java index a8604a6..bf49663 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/util/ParsedQueryRequest.java +++ b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/util/ParsedQueryRequest.java @@ -27,8 +27,9 @@ import java.util.Set; import java.util.regex.Matcher; import java.util.regex.Pattern; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; -// SEE RYA-211 import javax.annotation.concurrent.Immutable; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; +import net.jcip.annotations.Immutable; import org.apache.commons.lang3.builder.EqualsBuilder; import org.apache.rya.indexing.pcj.storage.accumulo.VariableOrder; @@ -36,8 +37,8 @@ import org.apache.rya.indexing.pcj.storage.accumulo.VariableOrder; /** * Represents a request to create a new PCJ in the Fluo app. */ -// SEE RYA-211 @Immutable -// SEE RYA-211 @ParametersAreNonnullByDefault +@Immutable +@DefaultAnnotation(NonNull.class) public class ParsedQueryRequest { private final String sparql; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/util/QueryReportRenderer.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/util/QueryReportRenderer.java b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/util/QueryReportRenderer.java index 51a6495..e1c386d 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/util/QueryReportRenderer.java +++ b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/util/QueryReportRenderer.java @@ -20,7 +20,8 @@ package org.apache.rya.indexing.pcj.fluo.client.util; import static com.google.common.base.Preconditions.checkNotNull; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; import org.apache.commons.lang3.StringUtils; import org.apache.rya.indexing.pcj.fluo.api.GetQueryReport.QueryReport; @@ -37,7 +38,7 @@ import org.openrdf.queryrender.sparql.SPARQLQueryRenderer; /** * Pretty renders a {@link QueryReport}. */ -// SEE RYA-211 @ParametersAreNonnullByDefault +@DefaultAnnotation(NonNull.class) public class QueryReportRenderer { /** http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/util/Report.java ---------------------------------------------------------------------- diff --git a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/util/Report.java b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/util/Report.java index 524a4ed..542bb60 100644 --- a/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/util/Report.java +++ b/extras/rya.pcj.fluo/pcj.fluo.client/src/main/java/org/apache/rya/indexing/pcj/fluo/client/util/Report.java @@ -21,8 +21,9 @@ package org.apache.rya.indexing.pcj.fluo.client.util; import static com.google.common.base.Preconditions.checkArgument; import static com.google.common.base.Preconditions.checkNotNull; -// SEE RYA-211 import javax.annotation.ParametersAreNonnullByDefault; -// SEE RYA-211 import javax.annotation.concurrent.Immutable; +import edu.umd.cs.findbugs.annotations.DefaultAnnotation; +import edu.umd.cs.findbugs.annotations.NonNull; +import net.jcip.annotations.Immutable; import org.apache.commons.lang3.StringUtils; @@ -33,8 +34,8 @@ import com.google.common.collect.ImmutableList; * left hand side of the table and the value of the item on the right hand side. * If an item does not have any values, then it prints an empty line. */ -// SEE RYA-211 @Immutable -// SEE RYA-211 @ParametersAreNonnullByDefault +@Immutable +@DefaultAnnotation(NonNull.class) public class Report { private final ImmutableList<ReportItem> items; @@ -111,8 +112,8 @@ public class Report { * An item that may appear within a {@link Report}. Each item has a title * that briefly describes the value it holds. */ -// SEE RYA-211 @Immutable -// SEE RYA-211 @ParametersAreNonnullByDefault + @Immutable + @DefaultAnnotation(NonNull.class) public static final class ReportItem { private final String title; private final String[] valueLines; @@ -172,7 +173,7 @@ public class Report { /** * Builds instances of {@link Report}. */ -// SEE RYA-211 @ParametersAreNonnullByDefault + @DefaultAnnotation(NonNull.class) public static final class Builder { private final ImmutableList.Builder<ReportItem> lines = ImmutableList.builder(); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/c06c1073/pom.xml ---------------------------------------------------------------------- diff --git a/pom.xml b/pom.xml index ac950ec..797f3af 100644 --- a/pom.xml +++ b/pom.xml @@ -122,7 +122,10 @@ under the License. <fluo.version>1.0.0-incubating</fluo.version> <jmh.version>1.13</jmh.version> + <jsr305.version>1.3.9-1</jsr305.version> + <jcip.version>1.0-1</jcip.version> + <findbugs.plugin.version>3.0.4</findbugs.plugin.version> </properties> <dependencyManagement> <dependencies> @@ -574,6 +577,11 @@ under the License. <artifactId>findbugs-annotations</artifactId> <version>${jsr305.version}</version> </dependency> + <dependency> + <groupId>com.github.stephenc.jcip</groupId> + <artifactId>jcip-annotations</artifactId> + <version>${jcip.version}</version> + </dependency> <dependency> <groupId>org.apache.accumulo</groupId> @@ -830,6 +838,16 @@ under the License. </plugins> </build> + <reporting> + <plugins> + <plugin> + <groupId>org.codehaus.mojo</groupId> + <artifactId>findbugs-maven-plugin</artifactId> + <version>${findbugs.plugin.version}</version> + </plugin> + </plugins> + </reporting> + <repositories> <repository> <id>LocationTech - SNAPSHOT</id>
