http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/CustomDatatypeResolverTest.java ---------------------------------------------------------------------- diff --git a/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/CustomDatatypeResolverTest.java b/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/CustomDatatypeResolverTest.java index 0126414..9fd086b 100644 --- a/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/CustomDatatypeResolverTest.java +++ b/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/CustomDatatypeResolverTest.java @@ -1,4 +1,4 @@ -package mvm.rya.api.resolver.impl; +package org.apache.rya.api.resolver.impl; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -22,7 +22,7 @@ package mvm.rya.api.resolver.impl; import junit.framework.TestCase; -import mvm.rya.api.domain.RyaType; +import org.apache.rya.api.domain.RyaType; import org.openrdf.model.impl.URIImpl; /**
http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/DateTimeRyaTypeResolverTest.java ---------------------------------------------------------------------- diff --git a/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/DateTimeRyaTypeResolverTest.java b/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/DateTimeRyaTypeResolverTest.java index 899bbcf..5f60f5a 100644 --- a/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/DateTimeRyaTypeResolverTest.java +++ b/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/DateTimeRyaTypeResolverTest.java @@ -1,4 +1,4 @@ -package mvm.rya.api.resolver.impl; +package org.apache.rya.api.resolver.impl; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -29,9 +29,9 @@ import java.util.GregorianCalendar; import javax.xml.datatype.DatatypeFactory; import javax.xml.datatype.XMLGregorianCalendar; -import mvm.rya.api.domain.RyaType; -import mvm.rya.api.resolver.RdfToRyaConversions; -import mvm.rya.api.resolver.RyaTypeResolverException; +import org.apache.rya.api.domain.RyaType; +import org.apache.rya.api.resolver.RdfToRyaConversions; +import org.apache.rya.api.resolver.RyaTypeResolverException; import org.junit.Ignore; import org.junit.Test; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/DoubleRyaTypeResolverTest.java ---------------------------------------------------------------------- diff --git a/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/DoubleRyaTypeResolverTest.java b/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/DoubleRyaTypeResolverTest.java index 2c5f43d..5e42369 100644 --- a/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/DoubleRyaTypeResolverTest.java +++ b/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/DoubleRyaTypeResolverTest.java @@ -1,4 +1,4 @@ -package mvm.rya.api.resolver.impl; +package org.apache.rya.api.resolver.impl; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -22,7 +22,7 @@ package mvm.rya.api.resolver.impl; import junit.framework.TestCase; -import mvm.rya.api.domain.RyaType; +import org.apache.rya.api.domain.RyaType; import org.openrdf.model.vocabulary.XMLSchema; import java.util.Random; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/IntegerRyaTypeResolverTest.java ---------------------------------------------------------------------- diff --git a/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/IntegerRyaTypeResolverTest.java b/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/IntegerRyaTypeResolverTest.java index 60cded0..199240d 100644 --- a/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/IntegerRyaTypeResolverTest.java +++ b/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/IntegerRyaTypeResolverTest.java @@ -1,4 +1,4 @@ -package mvm.rya.api.resolver.impl; +package org.apache.rya.api.resolver.impl; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -22,7 +22,7 @@ package mvm.rya.api.resolver.impl; import junit.framework.TestCase; -import mvm.rya.api.domain.RyaType; +import org.apache.rya.api.domain.RyaType; import org.openrdf.model.vocabulary.XMLSchema; import java.util.Random; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/LongRyaTypeResolverTest.java ---------------------------------------------------------------------- diff --git a/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/LongRyaTypeResolverTest.java b/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/LongRyaTypeResolverTest.java index 3dfb9c4..c971d39 100644 --- a/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/LongRyaTypeResolverTest.java +++ b/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/LongRyaTypeResolverTest.java @@ -1,4 +1,4 @@ -package mvm.rya.api.resolver.impl; +package org.apache.rya.api.resolver.impl; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -21,7 +21,7 @@ package mvm.rya.api.resolver.impl; -import mvm.rya.api.domain.RyaType; +import org.apache.rya.api.domain.RyaType; import org.junit.Test; import org.openrdf.model.vocabulary.XMLSchema; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/RyaURIResolverTest.java ---------------------------------------------------------------------- diff --git a/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/RyaURIResolverTest.java b/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/RyaURIResolverTest.java index f962b88..811961a 100644 --- a/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/RyaURIResolverTest.java +++ b/common/rya.api/src/test/java/org/apache/rya/api/resolver/impl/RyaURIResolverTest.java @@ -1,4 +1,4 @@ -package mvm.rya.api.resolver.impl; +package org.apache.rya.api.resolver.impl; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -22,8 +22,8 @@ package mvm.rya.api.resolver.impl; import junit.framework.TestCase; -import mvm.rya.api.domain.RyaType; -import mvm.rya.api.domain.RyaURI; +import org.apache.rya.api.domain.RyaType; +import org.apache.rya.api.domain.RyaURI; /** * Date: 7/16/12 http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.api/src/test/java/org/apache/rya/api/resolver/triple/impl/HashedWholeRowTripleResolverTest.java ---------------------------------------------------------------------- diff --git a/common/rya.api/src/test/java/org/apache/rya/api/resolver/triple/impl/HashedWholeRowTripleResolverTest.java b/common/rya.api/src/test/java/org/apache/rya/api/resolver/triple/impl/HashedWholeRowTripleResolverTest.java index 2baa92d..f57b5d1 100644 --- a/common/rya.api/src/test/java/org/apache/rya/api/resolver/triple/impl/HashedWholeRowTripleResolverTest.java +++ b/common/rya.api/src/test/java/org/apache/rya/api/resolver/triple/impl/HashedWholeRowTripleResolverTest.java @@ -1,4 +1,4 @@ -package mvm.rya.api.resolver.triple.impl; +package org.apache.rya.api.resolver.triple.impl; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -24,10 +24,10 @@ package mvm.rya.api.resolver.triple.impl; import java.util.Map; import junit.framework.TestCase; -import mvm.rya.api.RdfCloudTripleStoreConstants; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.domain.RyaURI; -import mvm.rya.api.resolver.triple.TripleRow; +import org.apache.rya.api.RdfCloudTripleStoreConstants; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.domain.RyaURI; +import org.apache.rya.api.resolver.triple.TripleRow; /** * Date: 7/25/12 http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.api/src/test/java/org/apache/rya/api/resolver/triple/impl/WholeRowTripleResolverTest.java ---------------------------------------------------------------------- diff --git a/common/rya.api/src/test/java/org/apache/rya/api/resolver/triple/impl/WholeRowTripleResolverTest.java b/common/rya.api/src/test/java/org/apache/rya/api/resolver/triple/impl/WholeRowTripleResolverTest.java index 30409ff..9fd5260 100644 --- a/common/rya.api/src/test/java/org/apache/rya/api/resolver/triple/impl/WholeRowTripleResolverTest.java +++ b/common/rya.api/src/test/java/org/apache/rya/api/resolver/triple/impl/WholeRowTripleResolverTest.java @@ -1,4 +1,4 @@ -package mvm.rya.api.resolver.triple.impl; +package org.apache.rya.api.resolver.triple.impl; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -22,11 +22,11 @@ package mvm.rya.api.resolver.triple.impl; import junit.framework.TestCase; -import mvm.rya.api.RdfCloudTripleStoreConstants; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.domain.RyaURI; -import mvm.rya.api.resolver.triple.TripleRow; -import mvm.rya.api.resolver.triple.TripleRowRegex; +import org.apache.rya.api.RdfCloudTripleStoreConstants; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.domain.RyaURI; +import org.apache.rya.api.resolver.triple.TripleRow; +import org.apache.rya.api.resolver.triple.TripleRowRegex; import java.util.Map; import java.util.regex.Matcher; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.api/src/test/java/org/apache/rya/api/utils/RdfIOTest.java ---------------------------------------------------------------------- diff --git a/common/rya.api/src/test/java/org/apache/rya/api/utils/RdfIOTest.java b/common/rya.api/src/test/java/org/apache/rya/api/utils/RdfIOTest.java index db377e1..92bcfff 100644 --- a/common/rya.api/src/test/java/org/apache/rya/api/utils/RdfIOTest.java +++ b/common/rya.api/src/test/java/org/apache/rya/api/utils/RdfIOTest.java @@ -17,15 +17,15 @@ * under the License. */ -//package mvm.rya.api.utils; +//package org.apache.rya.api.utils; // //import junit.framework.TestCase; -//import mvm.rya.api.RdfCloudTripleStoreUtils; +//import org.apache.rya.api.RdfCloudTripleStoreUtils; //import org.openrdf.model.Statement; //import org.openrdf.model.impl.StatementImpl; // -//import static mvm.rya.api.RdfCloudTripleStoreConstants.*; +//import static org.apache.rya.api.RdfCloudTripleStoreConstants.*; // ///** // * Class RdfIOTest http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/LoggingProvenanceCollector.java ---------------------------------------------------------------------- diff --git a/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/LoggingProvenanceCollector.java b/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/LoggingProvenanceCollector.java index 2ef279a..cb6cb43 100644 --- a/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/LoggingProvenanceCollector.java +++ b/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/LoggingProvenanceCollector.java @@ -1,4 +1,4 @@ -package mvm.rya.rdftriplestore.provenance; +package org.apache.rya.rdftriplestore.provenance; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -31,7 +31,7 @@ public class LoggingProvenanceCollector implements ProvenanceCollector { private static final Logger log = Logger.getLogger(LoggingProvenanceCollector.class); /* (non-Javadoc) - * @see mvm.rya.rdftriplestore.provenance.ProvenanceCollector#recordQuery(java.lang.String) + * @see org.apache.rya.rdftriplestore.provenance.ProvenanceCollector#recordQuery(java.lang.String) */ public void recordQuery(String query) { log.debug("User entered query: " + query); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/ProvenanceCollectionException.java ---------------------------------------------------------------------- diff --git a/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/ProvenanceCollectionException.java b/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/ProvenanceCollectionException.java index a0bd896..c550ee4 100644 --- a/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/ProvenanceCollectionException.java +++ b/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/ProvenanceCollectionException.java @@ -1,4 +1,4 @@ -package mvm.rya.rdftriplestore.provenance; +package org.apache.rya.rdftriplestore.provenance; /* * Licensed to the Apache Software Foundation (ASF) under one http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/ProvenanceCollector.java ---------------------------------------------------------------------- diff --git a/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/ProvenanceCollector.java b/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/ProvenanceCollector.java index a4ff829..e17d115 100644 --- a/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/ProvenanceCollector.java +++ b/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/ProvenanceCollector.java @@ -1,4 +1,4 @@ -package mvm.rya.rdftriplestore.provenance; +package org.apache.rya.rdftriplestore.provenance; /* * Licensed to the Apache Software Foundation (ASF) under one http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/TriplestoreProvenanceCollector.java ---------------------------------------------------------------------- diff --git a/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/TriplestoreProvenanceCollector.java b/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/TriplestoreProvenanceCollector.java index e283f2c..73a2d70 100644 --- a/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/TriplestoreProvenanceCollector.java +++ b/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/TriplestoreProvenanceCollector.java @@ -1,4 +1,4 @@ -package mvm.rya.rdftriplestore.provenance; +package org.apache.rya.rdftriplestore.provenance; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -22,8 +22,8 @@ package mvm.rya.rdftriplestore.provenance; import java.util.List; -import mvm.rya.rdftriplestore.provenance.rdf.BaseProvenanceModel; -import mvm.rya.rdftriplestore.provenance.rdf.RDFProvenanceModel; +import org.apache.rya.rdftriplestore.provenance.rdf.BaseProvenanceModel; +import org.apache.rya.rdftriplestore.provenance.rdf.RDFProvenanceModel; import org.openrdf.model.Statement; import org.openrdf.repository.RepositoryException; @@ -52,7 +52,7 @@ public class TriplestoreProvenanceCollector implements ProvenanceCollector { } /* (non-Javadoc) - * @see mvm.rya.rdftriplestore.provenance.ProvenanceCollector#recordQuery(java.lang.String) + * @see org.apache.rya.rdftriplestore.provenance.ProvenanceCollector#recordQuery(java.lang.String) */ public void recordQuery(String query) throws ProvenanceCollectionException { List<Statement> provenanceTriples = provenanceModel.getStatementsForQuery(query, user, queryType); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/rdf/BaseProvenanceModel.java ---------------------------------------------------------------------- diff --git a/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/rdf/BaseProvenanceModel.java b/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/rdf/BaseProvenanceModel.java index b8c5f32..70e0f5a 100644 --- a/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/rdf/BaseProvenanceModel.java +++ b/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/rdf/BaseProvenanceModel.java @@ -1,4 +1,4 @@ -package mvm.rya.rdftriplestore.provenance.rdf; +package org.apache.rya.rdftriplestore.provenance.rdf; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -46,7 +46,7 @@ public class BaseProvenanceModel implements RDFProvenanceModel { private static final String queryNameSpace = "http://rya.com/provenance#queryEvent"; /* (non-Javadoc) - * @see mvm.rya.rdftriplestore.provenance.rdf.RDFProvenanceModel#getStatementsForQuery(java.lang.String, java.lang.String, java.lang.String) + * @see org.apache.rya.rdftriplestore.provenance.rdf.RDFProvenanceModel#getStatementsForQuery(java.lang.String, java.lang.String, java.lang.String) */ public List<Statement> getStatementsForQuery(String query, String user, String queryType) { List<Statement> statements = new ArrayList<Statement>(); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/rdf/RDFProvenanceModel.java ---------------------------------------------------------------------- diff --git a/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/rdf/RDFProvenanceModel.java b/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/rdf/RDFProvenanceModel.java index c5495f2..619f80d 100644 --- a/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/rdf/RDFProvenanceModel.java +++ b/common/rya.provenance/src/main/java/org/apache/rya/rdftriplestore/provenance/rdf/RDFProvenanceModel.java @@ -1,4 +1,4 @@ -package mvm.rya.rdftriplestore.provenance.rdf; +package org.apache.rya.rdftriplestore.provenance.rdf; /* * Licensed to the Apache Software Foundation (ASF) under one http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.provenance/src/test/java/org/apache/rya/rdftriplestore/provenance/TriplestoreProvenanceCollectorTest.java ---------------------------------------------------------------------- diff --git a/common/rya.provenance/src/test/java/org/apache/rya/rdftriplestore/provenance/TriplestoreProvenanceCollectorTest.java b/common/rya.provenance/src/test/java/org/apache/rya/rdftriplestore/provenance/TriplestoreProvenanceCollectorTest.java index c431468..be49c8e 100644 --- a/common/rya.provenance/src/test/java/org/apache/rya/rdftriplestore/provenance/TriplestoreProvenanceCollectorTest.java +++ b/common/rya.provenance/src/test/java/org/apache/rya/rdftriplestore/provenance/TriplestoreProvenanceCollectorTest.java @@ -1,4 +1,4 @@ -package mvm.rya.rdftriplestore.provenance; +package org.apache.rya.rdftriplestore.provenance; /* * Licensed to the Apache Software Foundation (ASF) under one http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/common/rya.provenance/src/test/java/org/apache/rya/rdftriplestore/provenance/rdf/BaseProvenanceModelTest.java ---------------------------------------------------------------------- diff --git a/common/rya.provenance/src/test/java/org/apache/rya/rdftriplestore/provenance/rdf/BaseProvenanceModelTest.java b/common/rya.provenance/src/test/java/org/apache/rya/rdftriplestore/provenance/rdf/BaseProvenanceModelTest.java index 99875e2..0da5a4d 100644 --- a/common/rya.provenance/src/test/java/org/apache/rya/rdftriplestore/provenance/rdf/BaseProvenanceModelTest.java +++ b/common/rya.provenance/src/test/java/org/apache/rya/rdftriplestore/provenance/rdf/BaseProvenanceModelTest.java @@ -1,4 +1,4 @@ -package mvm.rya.rdftriplestore.provenance.rdf; +package org.apache.rya.rdftriplestore.provenance.rdf; /* * Licensed to the Apache Software Foundation (ASF) under one http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloNamespaceTableIterator.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloNamespaceTableIterator.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloNamespaceTableIterator.java index ebca6a2..0f1fd3d 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloNamespaceTableIterator.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloNamespaceTableIterator.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo; +package org.apache.rya.accumulo; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -23,7 +23,7 @@ package mvm.rya.accumulo; import com.google.common.base.Preconditions; import info.aduna.iteration.CloseableIteration; -import mvm.rya.api.persist.RdfDAOException; +import org.apache.rya.api.persist.RdfDAOException; import org.apache.accumulo.core.data.Key; import org.apache.accumulo.core.data.Value; import org.openrdf.model.Namespace; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfConfiguration.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfConfiguration.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfConfiguration.java index 709ceb9..87694f9 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfConfiguration.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfConfiguration.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo; +package org.apache.rya.accumulo; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -28,8 +28,8 @@ import java.util.List; import java.util.Map; import java.util.Map.Entry; -import mvm.rya.accumulo.experimental.AccumuloIndexer; -import mvm.rya.api.RdfCloudTripleStoreConfiguration; +import org.apache.rya.accumulo.experimental.AccumuloIndexer; +import org.apache.rya.api.RdfCloudTripleStoreConfiguration; import org.apache.accumulo.core.client.IteratorSetting; import org.apache.accumulo.core.security.Authorizations; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfConstants.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfConstants.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfConstants.java index 1ec57a7..85b0ef9 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfConstants.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfConstants.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo; +package org.apache.rya.accumulo; /* * Licensed to the Apache Software Foundation (ASF) under one http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfEvalStatsDAO.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfEvalStatsDAO.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfEvalStatsDAO.java index a3e0677..10584c5 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfEvalStatsDAO.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfEvalStatsDAO.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo; +package org.apache.rya.accumulo; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -22,13 +22,13 @@ package mvm.rya.accumulo; import static com.google.common.base.Preconditions.checkNotNull; -import static mvm.rya.api.RdfCloudTripleStoreConstants.DELIM; -import static mvm.rya.api.RdfCloudTripleStoreConstants.EMPTY_TEXT; -import static mvm.rya.api.RdfCloudTripleStoreConstants.PRED_CF_TXT; -import static mvm.rya.api.RdfCloudTripleStoreConstants.SUBJECT_CF_TXT; -import static mvm.rya.api.RdfCloudTripleStoreConstants.SUBJECTPRED_CF_TXT; -import static mvm.rya.api.RdfCloudTripleStoreConstants.PREDOBJECT_CF_TXT; -import static mvm.rya.api.RdfCloudTripleStoreConstants.SUBJECTOBJECT_CF_TXT; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.DELIM; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.EMPTY_TEXT; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.PRED_CF_TXT; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.SUBJECT_CF_TXT; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.SUBJECTPRED_CF_TXT; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.PREDOBJECT_CF_TXT; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.SUBJECTOBJECT_CF_TXT; import java.util.ArrayList; import java.util.Collection; @@ -36,10 +36,10 @@ import java.util.Iterator; import java.util.List; import java.util.Map; -import mvm.rya.api.RdfCloudTripleStoreStatement; -import mvm.rya.api.layout.TableLayoutStrategy; -import mvm.rya.api.persist.RdfDAOException; -import mvm.rya.api.persist.RdfEvalStatsDAO; +import org.apache.rya.api.RdfCloudTripleStoreStatement; +import org.apache.rya.api.layout.TableLayoutStrategy; +import org.apache.rya.api.persist.RdfDAOException; +import org.apache.rya.api.persist.RdfEvalStatsDAO; import org.apache.accumulo.core.client.Connector; import org.apache.accumulo.core.client.Scanner; @@ -121,7 +121,7 @@ public class AccumuloRdfEvalStatsDAO implements RdfEvalStatsDAO<AccumuloRdfConfi @Override public double getCardinality(AccumuloRdfConfiguration conf, - mvm.rya.api.persist.RdfEvalStatsDAO.CARDINALITY_OF card, + org.apache.rya.api.persist.RdfEvalStatsDAO.CARDINALITY_OF card, List<Value> val, Resource context) throws RdfDAOException { try { Authorizations authorizations = conf.getAuthorizations(); @@ -166,7 +166,7 @@ public class AccumuloRdfEvalStatsDAO implements RdfEvalStatsDAO<AccumuloRdfConfi @Override public double getCardinality(AccumuloRdfConfiguration conf, - mvm.rya.api.persist.RdfEvalStatsDAO.CARDINALITY_OF card, + org.apache.rya.api.persist.RdfEvalStatsDAO.CARDINALITY_OF card, List<Value> val) throws RdfDAOException { return getCardinality(conf, card, val, null); } http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfQueryIterator.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfQueryIterator.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfQueryIterator.java index d13f50e..29fe0f3 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfQueryIterator.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfQueryIterator.java @@ -17,17 +17,17 @@ * under the License. */ -//package mvm.rya.accumulo; +//package org.apache.rya.accumulo; // //import com.google.common.collect.Iterators; //import com.google.common.io.ByteArrayDataInput; //import com.google.common.io.ByteStreams; //import info.aduna.iteration.CloseableIteration; -//import mvm.rya.api.RdfCloudTripleStoreConstants; -//import mvm.rya.api.RdfCloudTripleStoreUtils; -//import mvm.rya.api.persist.RdfDAOException; -//import mvm.rya.api.utils.NullableStatementImpl; +//import org.apache.rya.api.RdfCloudTripleStoreConstants; +//import org.apache.rya.api.RdfCloudTripleStoreUtils; +//import org.apache.rya.api.persist.RdfDAOException; +//import org.apache.rya.api.utils.NullableStatementImpl; //import org.apache.accumulo.core.client.*; //import org.apache.accumulo.core.data.Key; //import org.apache.accumulo.core.data.Range; @@ -50,9 +50,9 @@ //import java.util.Iterator; //import java.util.Map.Entry; // -//import static mvm.rya.accumulo.AccumuloRdfConstants.ALL_AUTHORIZATIONS; -//import static mvm.rya.api.RdfCloudTripleStoreConstants.TABLE_LAYOUT; -//import static mvm.rya.api.RdfCloudTripleStoreUtils.writeValue; +//import static org.apache.rya.accumulo.AccumuloRdfConstants.ALL_AUTHORIZATIONS; +//import static org.apache.rya.api.RdfCloudTripleStoreConstants.TABLE_LAYOUT; +//import static org.apache.rya.api.RdfCloudTripleStoreUtils.writeValue; // //public class AccumuloRdfQueryIterator implements // CloseableIteration<Entry<Statement, BindingSet>, RdfDAOException> { http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfUtils.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfUtils.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfUtils.java index 157fc5a..4f882a3 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfUtils.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRdfUtils.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo; +package org.apache.rya.accumulo; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -21,8 +21,8 @@ package mvm.rya.accumulo; -import mvm.rya.api.RdfCloudTripleStoreConstants; -import mvm.rya.api.resolver.triple.TripleRow; +import org.apache.rya.api.RdfCloudTripleStoreConstants; +import org.apache.rya.api.resolver.triple.TripleRow; import org.apache.accumulo.core.client.AccumuloException; import org.apache.accumulo.core.client.AccumuloSecurityException; import org.apache.accumulo.core.client.TableExistsException; @@ -32,7 +32,7 @@ import org.apache.accumulo.core.data.Value; import org.apache.commons.logging.Log; import org.apache.commons.logging.LogFactory; -import static mvm.rya.api.RdfCloudTripleStoreConstants.EMPTY_BYTES; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.EMPTY_BYTES; /** * Class AccumuloRdfUtils http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRyaDAO.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRyaDAO.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRyaDAO.java index 195030e..bd7d2b3 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRyaDAO.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/AccumuloRyaDAO.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo; +package org.apache.rya.accumulo; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -22,15 +22,15 @@ package mvm.rya.accumulo; import static com.google.common.base.Preconditions.checkNotNull; -import static mvm.rya.accumulo.AccumuloRdfConstants.ALL_AUTHORIZATIONS; -import static mvm.rya.api.RdfCloudTripleStoreConstants.EMPTY_TEXT; -import static mvm.rya.api.RdfCloudTripleStoreConstants.INFO_NAMESPACE_TXT; -import static mvm.rya.api.RdfCloudTripleStoreConstants.MAX_MEMORY; -import static mvm.rya.api.RdfCloudTripleStoreConstants.MAX_TIME; -import static mvm.rya.api.RdfCloudTripleStoreConstants.NUM_THREADS; -import static mvm.rya.api.RdfCloudTripleStoreConstants.RTS_SUBJECT_RYA; -import static mvm.rya.api.RdfCloudTripleStoreConstants.RTS_VERSION_PREDICATE_RYA; -import static mvm.rya.api.RdfCloudTripleStoreConstants.VERSION_RYA; +import static org.apache.rya.accumulo.AccumuloRdfConstants.ALL_AUTHORIZATIONS; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.EMPTY_TEXT; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.INFO_NAMESPACE_TXT; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.MAX_MEMORY; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.MAX_TIME; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.NUM_THREADS; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.RTS_SUBJECT_RYA; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.RTS_VERSION_PREDICATE_RYA; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.VERSION_RYA; import java.io.IOException; import java.util.Collection; @@ -65,17 +65,17 @@ import com.google.common.collect.Iterators; import com.google.common.collect.Lists; import info.aduna.iteration.CloseableIteration; -import mvm.rya.accumulo.experimental.AccumuloIndexer; -import mvm.rya.accumulo.query.AccumuloRyaQueryEngine; -import mvm.rya.api.RdfCloudTripleStoreConfiguration; -import mvm.rya.api.RdfCloudTripleStoreConstants.TABLE_LAYOUT; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.domain.RyaURI; -import mvm.rya.api.layout.TableLayoutStrategy; -import mvm.rya.api.persist.RyaDAO; -import mvm.rya.api.persist.RyaDAOException; -import mvm.rya.api.persist.RyaNamespaceManager; -import mvm.rya.api.resolver.RyaTripleContext; +import org.apache.rya.accumulo.experimental.AccumuloIndexer; +import org.apache.rya.accumulo.query.AccumuloRyaQueryEngine; +import org.apache.rya.api.RdfCloudTripleStoreConfiguration; +import org.apache.rya.api.RdfCloudTripleStoreConstants.TABLE_LAYOUT; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.domain.RyaURI; +import org.apache.rya.api.layout.TableLayoutStrategy; +import org.apache.rya.api.persist.RyaDAO; +import org.apache.rya.api.persist.RyaDAOException; +import org.apache.rya.api.persist.RyaNamespaceManager; +import org.apache.rya.api.resolver.RyaTripleContext; public class AccumuloRyaDAO implements RyaDAO<AccumuloRdfConfiguration>, RyaNamespaceManager<AccumuloRdfConfiguration> { private static final Log logger = LogFactory.getLog(AccumuloRyaDAO.class); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/DefineTripleQueryRangeFactory.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/DefineTripleQueryRangeFactory.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/DefineTripleQueryRangeFactory.java index b5a4e84..a6104f4 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/DefineTripleQueryRangeFactory.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/DefineTripleQueryRangeFactory.java @@ -17,13 +17,13 @@ * under the License. */ -//package mvm.rya.accumulo; +//package org.apache.rya.accumulo; // //import com.google.common.io.ByteArrayDataOutput; //import com.google.common.io.ByteStreams; -//import mvm.rya.api.RdfCloudTripleStoreUtils; -//import mvm.rya.api.domain.RangeValue; +//import org.apache.rya.api.RdfCloudTripleStoreUtils; +//import org.apache.rya.api.domain.RangeValue; //import org.apache.accumulo.core.data.Range; //import org.apache.hadoop.io.Text; //import org.openrdf.model.Value; @@ -33,8 +33,8 @@ //import java.io.IOException; //import java.util.Map; // -//import static mvm.rya.api.RdfCloudTripleStoreConstants.*; -//import static mvm.rya.api.RdfCloudTripleStoreUtils.CustomEntry; +//import static org.apache.rya.api.RdfCloudTripleStoreConstants.*; +//import static org.apache.rya.api.RdfCloudTripleStoreUtils.CustomEntry; // ///** // * Class DefineTripleQueryRangeFactory http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/RyaTableKeyValues.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/RyaTableKeyValues.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/RyaTableKeyValues.java index 574029e..78e00f2 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/RyaTableKeyValues.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/RyaTableKeyValues.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo; +package org.apache.rya.accumulo; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -21,7 +21,7 @@ package mvm.rya.accumulo; -import static mvm.rya.accumulo.AccumuloRdfConstants.EMPTY_VALUE; +import static org.apache.rya.accumulo.AccumuloRdfConstants.EMPTY_VALUE; import java.io.IOException; import java.util.AbstractMap.SimpleEntry; @@ -29,12 +29,12 @@ import java.util.ArrayList; import java.util.Collection; import java.util.Map; -import mvm.rya.api.RdfCloudTripleStoreConfiguration; -import mvm.rya.api.RdfCloudTripleStoreConstants; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.resolver.RyaTripleContext; -import mvm.rya.api.resolver.triple.TripleRow; -import mvm.rya.api.resolver.triple.TripleRowResolverException; +import org.apache.rya.api.RdfCloudTripleStoreConfiguration; +import org.apache.rya.api.RdfCloudTripleStoreConstants; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.resolver.RyaTripleContext; +import org.apache.rya.api.resolver.triple.TripleRow; +import org.apache.rya.api.resolver.triple.TripleRowResolverException; import org.apache.accumulo.core.data.Key; import org.apache.accumulo.core.data.Value; @@ -75,7 +75,7 @@ public class RyaTableKeyValues { * TODO: If there are contexts, do we still replicate the information into the default graph as well * as the named graphs? */try { - Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, mvm.rya.api.resolver.triple.TripleRow> rowMap = instance.serializeTriple(stmt); + Map<RdfCloudTripleStoreConstants.TABLE_LAYOUT, org.apache.rya.api.resolver.triple.TripleRow> rowMap = instance.serializeTriple(stmt); TripleRow tripleRow = rowMap.get(RdfCloudTripleStoreConstants.TABLE_LAYOUT.SPO); byte[] columnVisibility = tripleRow.getColumnVisibility(); Text cv = columnVisibility == null ? EMPTY_CV_TEXT : new Text(columnVisibility); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/RyaTableMutationsFactory.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/RyaTableMutationsFactory.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/RyaTableMutationsFactory.java index 2a4871d..b06be7b 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/RyaTableMutationsFactory.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/RyaTableMutationsFactory.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo; +package org.apache.rya.accumulo; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -21,9 +21,9 @@ package mvm.rya.accumulo; -import static mvm.rya.accumulo.AccumuloRdfConstants.EMPTY_CV; -import static mvm.rya.accumulo.AccumuloRdfConstants.EMPTY_VALUE; -import static mvm.rya.api.RdfCloudTripleStoreConstants.EMPTY_TEXT; +import static org.apache.rya.accumulo.AccumuloRdfConstants.EMPTY_CV; +import static org.apache.rya.accumulo.AccumuloRdfConstants.EMPTY_VALUE; +import static org.apache.rya.api.RdfCloudTripleStoreConstants.EMPTY_TEXT; import java.io.IOException; import java.util.ArrayList; @@ -31,13 +31,13 @@ import java.util.Collection; import java.util.HashMap; import java.util.Map; -import mvm.rya.api.RdfCloudTripleStoreConfiguration; -import mvm.rya.api.RdfCloudTripleStoreConstants; -import mvm.rya.api.RdfCloudTripleStoreConstants.TABLE_LAYOUT; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.resolver.RyaTripleContext; -import mvm.rya.api.resolver.triple.TripleRow; -import mvm.rya.api.resolver.triple.TripleRowResolverException; +import org.apache.rya.api.RdfCloudTripleStoreConfiguration; +import org.apache.rya.api.RdfCloudTripleStoreConstants; +import org.apache.rya.api.RdfCloudTripleStoreConstants.TABLE_LAYOUT; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.resolver.RyaTripleContext; +import org.apache.rya.api.resolver.triple.TripleRow; +import org.apache.rya.api.resolver.triple.TripleRowResolverException; import org.apache.accumulo.core.data.Mutation; import org.apache.accumulo.core.data.Value; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/experimental/AbstractAccumuloIndexer.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/experimental/AbstractAccumuloIndexer.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/experimental/AbstractAccumuloIndexer.java index 5df5da9..90cae5e 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/experimental/AbstractAccumuloIndexer.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/experimental/AbstractAccumuloIndexer.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo.experimental; +package org.apache.rya.accumulo.experimental; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -23,8 +23,8 @@ package mvm.rya.accumulo.experimental; import java.io.IOException; import java.util.Collection; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.domain.RyaURI; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.domain.RyaURI; import org.apache.accumulo.core.client.MultiTableBatchWriter; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/experimental/AccumuloIndexer.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/experimental/AccumuloIndexer.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/experimental/AccumuloIndexer.java index 5581e08..3e08ef4 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/experimental/AccumuloIndexer.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/experimental/AccumuloIndexer.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo.experimental; +package org.apache.rya.accumulo.experimental; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -25,8 +25,8 @@ import java.io.IOException; import org.apache.accumulo.core.client.Connector; import org.apache.accumulo.core.client.MultiTableBatchWriter; -import mvm.rya.api.RdfCloudTripleStoreConfiguration; -import mvm.rya.api.persist.index.RyaSecondaryIndexer; +import org.apache.rya.api.RdfCloudTripleStoreConfiguration; +import org.apache.rya.api.persist.index.RyaSecondaryIndexer; public interface AccumuloIndexer extends RyaSecondaryIndexer { public void init(); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/instance/AccumuloRyaInstanceDetailsRepository.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/instance/AccumuloRyaInstanceDetailsRepository.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/instance/AccumuloRyaInstanceDetailsRepository.java index 6e818b3..46d2a69 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/instance/AccumuloRyaInstanceDetailsRepository.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/instance/AccumuloRyaInstanceDetailsRepository.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo.instance; +package org.apache.rya.accumulo.instance; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -46,8 +46,8 @@ import org.apache.accumulo.core.data.Value; import org.apache.accumulo.core.security.Authorizations; import org.apache.hadoop.io.Text; -import mvm.rya.api.instance.RyaDetails; -import mvm.rya.api.instance.RyaDetailsRepository; +import org.apache.rya.api.instance.RyaDetails; +import org.apache.rya.api.instance.RyaDetailsRepository; /** * An implementation of {@link RyaDetailsRepository} that stores a Rya http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/instance/RyaDetailsSerializer.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/instance/RyaDetailsSerializer.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/instance/RyaDetailsSerializer.java index 8c863ea..ca130ee 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/instance/RyaDetailsSerializer.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/instance/RyaDetailsSerializer.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo.instance; +package org.apache.rya.accumulo.instance; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -29,8 +29,8 @@ import java.io.ObjectOutputStream; import javax.annotation.ParametersAreNonnullByDefault; -import mvm.rya.api.instance.RyaDetails; -import mvm.rya.api.instance.RyaDetailsRepository.RyaDetailsRepositoryException; +import org.apache.rya.api.instance.RyaDetails; +import org.apache.rya.api.instance.RyaDetailsRepository.RyaDetailsRepositoryException; /** * Serializes {@link RyaDetails} instances. http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/AccumuloRyaQueryEngine.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/AccumuloRyaQueryEngine.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/AccumuloRyaQueryEngine.java index ba3ffd2..d7f9dfa 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/AccumuloRyaQueryEngine.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/AccumuloRyaQueryEngine.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo.query; +package org.apache.rya.accumulo.query; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -21,7 +21,7 @@ package mvm.rya.accumulo.query; -import static mvm.rya.api.RdfCloudTripleStoreUtils.layoutToTable; +import static org.apache.rya.api.RdfCloudTripleStoreUtils.layoutToTable; import info.aduna.iteration.CloseableIteration; import java.io.IOException; @@ -31,26 +31,26 @@ import java.util.HashSet; import java.util.Iterator; import java.util.Map; -import mvm.rya.accumulo.AccumuloRdfConfiguration; -import mvm.rya.api.RdfCloudTripleStoreConfiguration; -import mvm.rya.api.RdfCloudTripleStoreConstants; -import mvm.rya.api.RdfCloudTripleStoreConstants.TABLE_LAYOUT; -import mvm.rya.api.RdfCloudTripleStoreUtils; -import mvm.rya.api.domain.RyaRange; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.domain.RyaType; -import mvm.rya.api.domain.RyaURI; -import mvm.rya.api.layout.TableLayoutStrategy; -import mvm.rya.api.persist.RyaDAOException; -import mvm.rya.api.persist.query.BatchRyaQuery; -import mvm.rya.api.persist.query.RyaQuery; -import mvm.rya.api.persist.query.RyaQueryEngine; -import mvm.rya.api.query.strategy.ByteRange; -import mvm.rya.api.query.strategy.TriplePatternStrategy; -import mvm.rya.api.resolver.RyaContext; -import mvm.rya.api.resolver.RyaTripleContext; -import mvm.rya.api.resolver.triple.TripleRowRegex; -import mvm.rya.api.utils.CloseableIterableIteration; +import org.apache.rya.accumulo.AccumuloRdfConfiguration; +import org.apache.rya.api.RdfCloudTripleStoreConfiguration; +import org.apache.rya.api.RdfCloudTripleStoreConstants; +import org.apache.rya.api.RdfCloudTripleStoreConstants.TABLE_LAYOUT; +import org.apache.rya.api.RdfCloudTripleStoreUtils; +import org.apache.rya.api.domain.RyaRange; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.domain.RyaType; +import org.apache.rya.api.domain.RyaURI; +import org.apache.rya.api.layout.TableLayoutStrategy; +import org.apache.rya.api.persist.RyaDAOException; +import org.apache.rya.api.persist.query.BatchRyaQuery; +import org.apache.rya.api.persist.query.RyaQuery; +import org.apache.rya.api.persist.query.RyaQueryEngine; +import org.apache.rya.api.query.strategy.ByteRange; +import org.apache.rya.api.query.strategy.TriplePatternStrategy; +import org.apache.rya.api.resolver.RyaContext; +import org.apache.rya.api.resolver.RyaTripleContext; +import org.apache.rya.api.resolver.triple.TripleRowRegex; +import org.apache.rya.api.utils.CloseableIterableIteration; import org.apache.accumulo.core.client.BatchScanner; import org.apache.accumulo.core.client.Connector; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/KeyValueToRyaStatementFunction.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/KeyValueToRyaStatementFunction.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/KeyValueToRyaStatementFunction.java index 2813438..9dd84c6 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/KeyValueToRyaStatementFunction.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/KeyValueToRyaStatementFunction.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo.query; +package org.apache.rya.accumulo.query; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -23,12 +23,12 @@ package mvm.rya.accumulo.query; import java.util.Map; -import mvm.rya.api.RdfCloudTripleStoreConfiguration; -import mvm.rya.api.RdfCloudTripleStoreConstants.TABLE_LAYOUT; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.resolver.RyaTripleContext; -import mvm.rya.api.resolver.triple.TripleRow; -import mvm.rya.api.resolver.triple.TripleRowResolverException; +import org.apache.rya.api.RdfCloudTripleStoreConfiguration; +import org.apache.rya.api.RdfCloudTripleStoreConstants.TABLE_LAYOUT; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.resolver.RyaTripleContext; +import org.apache.rya.api.resolver.triple.TripleRow; +import org.apache.rya.api.resolver.triple.TripleRowResolverException; import org.apache.accumulo.core.data.Key; import org.apache.accumulo.core.data.Value; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/RangeBindingSetEntries.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/RangeBindingSetEntries.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/RangeBindingSetEntries.java index c59cb87..35ef776 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/RangeBindingSetEntries.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/RangeBindingSetEntries.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo.query; +package org.apache.rya.accumulo.query; /* * Licensed to the Apache Software Foundation (ASF) under one http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/RyaStatementBindingSetKeyValueIterator.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/RyaStatementBindingSetKeyValueIterator.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/RyaStatementBindingSetKeyValueIterator.java index b4333bd..076ce0f 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/RyaStatementBindingSetKeyValueIterator.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/RyaStatementBindingSetKeyValueIterator.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo.query; +package org.apache.rya.accumulo.query; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -28,14 +28,14 @@ import java.util.Iterator; import java.util.Map; import java.util.NoSuchElementException; -import mvm.rya.api.RdfCloudTripleStoreConstants.TABLE_LAYOUT; -import mvm.rya.api.RdfCloudTripleStoreUtils; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.persist.RyaDAOException; -import mvm.rya.api.resolver.RyaContext; -import mvm.rya.api.resolver.RyaTripleContext; -import mvm.rya.api.resolver.triple.TripleRow; -import mvm.rya.api.resolver.triple.TripleRowResolverException; +import org.apache.rya.api.RdfCloudTripleStoreConstants.TABLE_LAYOUT; +import org.apache.rya.api.RdfCloudTripleStoreUtils; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.persist.RyaDAOException; +import org.apache.rya.api.resolver.RyaContext; +import org.apache.rya.api.resolver.RyaTripleContext; +import org.apache.rya.api.resolver.triple.TripleRow; +import org.apache.rya.api.resolver.triple.TripleRowResolverException; import org.apache.accumulo.core.client.BatchScanner; import org.apache.accumulo.core.client.Scanner; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/RyaStatementKeyValueIterator.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/RyaStatementKeyValueIterator.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/RyaStatementKeyValueIterator.java index f4c3081..fb66e70 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/RyaStatementKeyValueIterator.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/RyaStatementKeyValueIterator.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo.query; +package org.apache.rya.accumulo.query; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -26,13 +26,13 @@ import info.aduna.iteration.CloseableIteration; import java.util.Iterator; import java.util.Map; -import mvm.rya.api.RdfCloudTripleStoreConstants.TABLE_LAYOUT; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.persist.RyaDAOException; -import mvm.rya.api.resolver.RyaContext; -import mvm.rya.api.resolver.RyaTripleContext; -import mvm.rya.api.resolver.triple.TripleRow; -import mvm.rya.api.resolver.triple.TripleRowResolverException; +import org.apache.rya.api.RdfCloudTripleStoreConstants.TABLE_LAYOUT; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.persist.RyaDAOException; +import org.apache.rya.api.resolver.RyaContext; +import org.apache.rya.api.resolver.RyaTripleContext; +import org.apache.rya.api.resolver.triple.TripleRow; +import org.apache.rya.api.resolver.triple.TripleRowResolverException; import org.apache.accumulo.core.data.Key; import org.apache.accumulo.core.data.Value; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/ScannerBaseCloseableIterable.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/ScannerBaseCloseableIterable.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/ScannerBaseCloseableIterable.java index d2dcef9..199972e 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/ScannerBaseCloseableIterable.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/query/ScannerBaseCloseableIterable.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo.query; +package org.apache.rya.accumulo.query; /* * Licensed to the Apache Software Foundation (ASF) under one http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/utils/TimeRangeFilter.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/utils/TimeRangeFilter.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/utils/TimeRangeFilter.java index 97d2f54..f6cb445 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/utils/TimeRangeFilter.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/utils/TimeRangeFilter.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo.utils; +package org.apache.rya.accumulo.utils; /* * Licensed to the Apache Software Foundation (ASF) under one http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/utils/VisibilitySimplifier.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/utils/VisibilitySimplifier.java b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/utils/VisibilitySimplifier.java index cc4edca..173948c 100644 --- a/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/utils/VisibilitySimplifier.java +++ b/dao/accumulo.rya/src/main/java/org/apache/rya/accumulo/utils/VisibilitySimplifier.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package mvm.rya.accumulo.utils; +package org.apache.rya.accumulo.utils; import static java.util.Objects.requireNonNull; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloITBase.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloITBase.java b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloITBase.java index 7dd23e6..5225555 100644 --- a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloITBase.java +++ b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloITBase.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package mvm.rya.accumulo; +package org.apache.rya.accumulo; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloRdfConfigurationTest.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloRdfConfigurationTest.java b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloRdfConfigurationTest.java index ffd316e..e3f6396 100644 --- a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloRdfConfigurationTest.java +++ b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloRdfConfigurationTest.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo; +package org.apache.rya.accumulo; /* * Licensed to the Apache Software Foundation (ASF) under one http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloRyaDAOTest.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloRyaDAOTest.java b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloRyaDAOTest.java index 8b55070..f170a7e 100644 --- a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloRyaDAOTest.java +++ b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloRyaDAOTest.java @@ -1,4 +1,4 @@ -package mvm.rya.accumulo; +package org.apache.rya.accumulo; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -32,14 +32,14 @@ import java.util.Collection; import java.util.List; import java.util.UUID; -import mvm.rya.accumulo.query.AccumuloRyaQueryEngine; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.domain.RyaType; -import mvm.rya.api.domain.RyaURI; -import mvm.rya.api.persist.RyaDAOException; -import mvm.rya.api.persist.query.RyaQuery; -import mvm.rya.api.resolver.RdfToRyaConversions; -import mvm.rya.api.resolver.RyaContext; +import org.apache.rya.accumulo.query.AccumuloRyaQueryEngine; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.domain.RyaType; +import org.apache.rya.api.domain.RyaURI; +import org.apache.rya.api.persist.RyaDAOException; +import org.apache.rya.api.persist.query.RyaQuery; +import org.apache.rya.api.resolver.RdfToRyaConversions; +import org.apache.rya.api.resolver.RyaContext; import org.apache.accumulo.core.client.Connector; import org.apache.accumulo.core.client.IteratorSetting; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloRyaITBase.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloRyaITBase.java b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloRyaITBase.java index dea227b..a4ef7d7 100644 --- a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloRyaITBase.java +++ b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/AccumuloRyaITBase.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package mvm.rya.accumulo; +package org.apache.rya.accumulo; import java.io.IOException; import java.util.Date; @@ -31,18 +31,18 @@ import org.junit.BeforeClass; import com.google.common.base.Optional; -import mvm.rya.accumulo.instance.AccumuloRyaInstanceDetailsRepository; -import mvm.rya.api.instance.RyaDetails; -import mvm.rya.api.instance.RyaDetails.EntityCentricIndexDetails; -import mvm.rya.api.instance.RyaDetails.FreeTextIndexDetails; -import mvm.rya.api.instance.RyaDetails.GeoIndexDetails; -import mvm.rya.api.instance.RyaDetails.JoinSelectivityDetails; -import mvm.rya.api.instance.RyaDetails.PCJIndexDetails; -import mvm.rya.api.instance.RyaDetails.ProspectorDetails; -import mvm.rya.api.instance.RyaDetails.TemporalIndexDetails; -import mvm.rya.api.instance.RyaDetailsRepository; -import mvm.rya.api.instance.RyaDetailsRepository.AlreadyInitializedException; -import mvm.rya.api.instance.RyaDetailsRepository.RyaDetailsRepositoryException; +import org.apache.rya.accumulo.instance.AccumuloRyaInstanceDetailsRepository; +import org.apache.rya.api.instance.RyaDetails; +import org.apache.rya.api.instance.RyaDetails.EntityCentricIndexDetails; +import org.apache.rya.api.instance.RyaDetails.FreeTextIndexDetails; +import org.apache.rya.api.instance.RyaDetails.GeoIndexDetails; +import org.apache.rya.api.instance.RyaDetails.JoinSelectivityDetails; +import org.apache.rya.api.instance.RyaDetails.PCJIndexDetails; +import org.apache.rya.api.instance.RyaDetails.ProspectorDetails; +import org.apache.rya.api.instance.RyaDetails.TemporalIndexDetails; +import org.apache.rya.api.instance.RyaDetailsRepository; +import org.apache.rya.api.instance.RyaDetailsRepository.AlreadyInitializedException; +import org.apache.rya.api.instance.RyaDetailsRepository.RyaDetailsRepositoryException; /** * Contains boilerplate code for spinning up a Mini Accumulo Cluster and initializing http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/DefineTripleQueryRangeFactoryTest.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/DefineTripleQueryRangeFactoryTest.java b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/DefineTripleQueryRangeFactoryTest.java index 7c3331d..3537f74 100644 --- a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/DefineTripleQueryRangeFactoryTest.java +++ b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/DefineTripleQueryRangeFactoryTest.java @@ -17,15 +17,15 @@ * under the License. */ -//package mvm.rya.accumulo; +//package org.apache.rya.accumulo; // //import junit.framework.TestCase; -//import mvm.rya.accumulo.AccumuloRdfConfiguration; -//import mvm.rya.accumulo.DefineTripleQueryRangeFactory; -//import mvm.rya.accumulo.AccumuloRdfConfiguration; -//import mvm.rya.accumulo.DefineTripleQueryRangeFactory; -//import mvm.rya.api.domain.RangeValue; +//import org.apache.rya.accumulo.AccumuloRdfConfiguration; +//import org.apache.rya.accumulo.DefineTripleQueryRangeFactory; +//import org.apache.rya.accumulo.AccumuloRdfConfiguration; +//import org.apache.rya.accumulo.DefineTripleQueryRangeFactory; +//import org.apache.rya.api.domain.RangeValue; //import org.apache.accumulo.core.data.Range; //import org.openrdf.model.URI; //import org.openrdf.model.Value; @@ -34,7 +34,7 @@ // //import java.util.Map; // -//import static mvm.rya.api.RdfCloudTripleStoreConstants.*; +//import static org.apache.rya.api.RdfCloudTripleStoreConstants.*; // ///** // */ http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/MiniAccumuloClusterInstance.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/MiniAccumuloClusterInstance.java b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/MiniAccumuloClusterInstance.java index eb11ed8..2552ef5 100644 --- a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/MiniAccumuloClusterInstance.java +++ b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/MiniAccumuloClusterInstance.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package mvm.rya.accumulo; +package org.apache.rya.accumulo; import java.io.File; import java.io.IOException; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/instance/AccumuloRyaDetailsRepositoryIT.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/instance/AccumuloRyaDetailsRepositoryIT.java b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/instance/AccumuloRyaDetailsRepositoryIT.java index bdd6059..67e2696 100644 --- a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/instance/AccumuloRyaDetailsRepositoryIT.java +++ b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/instance/AccumuloRyaDetailsRepositoryIT.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package mvm.rya.accumulo.instance; +package org.apache.rya.accumulo.instance; import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; @@ -45,24 +45,24 @@ import org.junit.Test; import com.google.common.base.Optional; -import mvm.rya.accumulo.AccumuloITBase; -import mvm.rya.accumulo.MiniAccumuloClusterInstance; -import mvm.rya.api.instance.RyaDetails; -import mvm.rya.api.instance.RyaDetails.EntityCentricIndexDetails; -import mvm.rya.api.instance.RyaDetails.FreeTextIndexDetails; -import mvm.rya.api.instance.RyaDetails.GeoIndexDetails; -import mvm.rya.api.instance.RyaDetails.JoinSelectivityDetails; -import mvm.rya.api.instance.RyaDetails.PCJIndexDetails; -import mvm.rya.api.instance.RyaDetails.PCJIndexDetails.FluoDetails; -import mvm.rya.api.instance.RyaDetails.PCJIndexDetails.PCJDetails; -import mvm.rya.api.instance.RyaDetails.PCJIndexDetails.PCJDetails.PCJUpdateStrategy; -import mvm.rya.api.instance.RyaDetails.ProspectorDetails; -import mvm.rya.api.instance.RyaDetails.TemporalIndexDetails; -import mvm.rya.api.instance.RyaDetailsRepository; -import mvm.rya.api.instance.RyaDetailsRepository.AlreadyInitializedException; -import mvm.rya.api.instance.RyaDetailsRepository.ConcurrentUpdateException; -import mvm.rya.api.instance.RyaDetailsRepository.NotInitializedException; -import mvm.rya.api.instance.RyaDetailsRepository.RyaDetailsRepositoryException; +import org.apache.rya.accumulo.AccumuloITBase; +import org.apache.rya.accumulo.MiniAccumuloClusterInstance; +import org.apache.rya.api.instance.RyaDetails; +import org.apache.rya.api.instance.RyaDetails.EntityCentricIndexDetails; +import org.apache.rya.api.instance.RyaDetails.FreeTextIndexDetails; +import org.apache.rya.api.instance.RyaDetails.GeoIndexDetails; +import org.apache.rya.api.instance.RyaDetails.JoinSelectivityDetails; +import org.apache.rya.api.instance.RyaDetails.PCJIndexDetails; +import org.apache.rya.api.instance.RyaDetails.PCJIndexDetails.FluoDetails; +import org.apache.rya.api.instance.RyaDetails.PCJIndexDetails.PCJDetails; +import org.apache.rya.api.instance.RyaDetails.PCJIndexDetails.PCJDetails.PCJUpdateStrategy; +import org.apache.rya.api.instance.RyaDetails.ProspectorDetails; +import org.apache.rya.api.instance.RyaDetails.TemporalIndexDetails; +import org.apache.rya.api.instance.RyaDetailsRepository; +import org.apache.rya.api.instance.RyaDetailsRepository.AlreadyInitializedException; +import org.apache.rya.api.instance.RyaDetailsRepository.ConcurrentUpdateException; +import org.apache.rya.api.instance.RyaDetailsRepository.NotInitializedException; +import org.apache.rya.api.instance.RyaDetailsRepository.RyaDetailsRepositoryException; /** * Tests the methods of {@link AccumuloRyaDetailsRepository} by using a {@link MiniAccumuloCluster}. http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/utils/VisibilitySimplifierTest.java ---------------------------------------------------------------------- diff --git a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/utils/VisibilitySimplifierTest.java b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/utils/VisibilitySimplifierTest.java index 3d22e2f..a9a03ce 100644 --- a/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/utils/VisibilitySimplifierTest.java +++ b/dao/accumulo.rya/src/test/java/org/apache/rya/accumulo/utils/VisibilitySimplifierTest.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package mvm.rya.accumulo.utils; +package org.apache.rya.accumulo.utils; import static org.junit.Assert.assertEquals; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoConnectorFactory.java ---------------------------------------------------------------------- diff --git a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoConnectorFactory.java b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoConnectorFactory.java index 77a9f16..bd3e86f 100644 --- a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoConnectorFactory.java +++ b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoConnectorFactory.java @@ -1,4 +1,4 @@ -package mvm.rya.mongodb; +package org.apache.rya.mongodb; /* * Licensed to the Apache Software Foundation (ASF) under one http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBQueryEngine.java ---------------------------------------------------------------------- diff --git a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBQueryEngine.java b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBQueryEngine.java index afa0a77..cf9bf78 100644 --- a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBQueryEngine.java +++ b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBQueryEngine.java @@ -1,4 +1,4 @@ -package mvm.rya.mongodb; +package org.apache.rya.mongodb; /* * Licensed to the Apache Software Foundation (ASF) under one * or more contributor license agreements. See the NOTICE file @@ -38,17 +38,17 @@ import com.mongodb.DBObject; import com.mongodb.MongoClient; import info.aduna.iteration.CloseableIteration; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.persist.RyaDAOException; -import mvm.rya.api.persist.query.BatchRyaQuery; -import mvm.rya.api.persist.query.RyaQuery; -import mvm.rya.api.persist.query.RyaQueryEngine; -import mvm.rya.mongodb.dao.MongoDBStorageStrategy; -import mvm.rya.mongodb.dao.SimpleMongoDBStorageStrategy; -import mvm.rya.mongodb.iter.NonCloseableRyaStatementCursorIterator; -import mvm.rya.mongodb.iter.RyaStatementBindingSetCursorIterator; -import mvm.rya.mongodb.iter.RyaStatementCursorIterable; -import mvm.rya.mongodb.iter.RyaStatementCursorIterator; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.persist.RyaDAOException; +import org.apache.rya.api.persist.query.BatchRyaQuery; +import org.apache.rya.api.persist.query.RyaQuery; +import org.apache.rya.api.persist.query.RyaQueryEngine; +import org.apache.rya.mongodb.dao.MongoDBStorageStrategy; +import org.apache.rya.mongodb.dao.SimpleMongoDBStorageStrategy; +import org.apache.rya.mongodb.iter.NonCloseableRyaStatementCursorIterator; +import org.apache.rya.mongodb.iter.RyaStatementBindingSetCursorIterator; +import org.apache.rya.mongodb.iter.RyaStatementCursorIterable; +import org.apache.rya.mongodb.iter.RyaStatementCursorIterator; import com.google.common.collect.HashMultimap; import com.google.common.collect.Multimap; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBRdfConfiguration.java ---------------------------------------------------------------------- diff --git a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBRdfConfiguration.java b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBRdfConfiguration.java index e8e301d..99f276b 100644 --- a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBRdfConfiguration.java +++ b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBRdfConfiguration.java @@ -1,4 +1,4 @@ -package mvm.rya.mongodb; +package org.apache.rya.mongodb; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -23,8 +23,8 @@ package mvm.rya.mongodb; import java.util.List; -import mvm.rya.api.RdfCloudTripleStoreConfiguration; -import mvm.rya.api.persist.index.RyaSecondaryIndexer; +import org.apache.rya.api.RdfCloudTripleStoreConfiguration; +import org.apache.rya.api.persist.index.RyaSecondaryIndexer; import org.apache.hadoop.conf.Configuration; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBRyaDAO.java ---------------------------------------------------------------------- diff --git a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBRyaDAO.java b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBRyaDAO.java index bb5d58e..8967a79 100644 --- a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBRyaDAO.java +++ b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoDBRyaDAO.java @@ -1,4 +1,4 @@ -package mvm.rya.mongodb; +package org.apache.rya.mongodb; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -37,18 +37,18 @@ import com.mongodb.InsertOptions; import com.mongodb.MongoClient; import de.flapdoodle.embed.mongo.tests.MongodForTestsFactory; -import mvm.rya.api.RdfCloudTripleStoreConfiguration; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.domain.RyaURI; -import mvm.rya.api.persist.RyaDAO; -import mvm.rya.api.persist.RyaDAOException; -import mvm.rya.api.persist.RyaNamespaceManager; -import mvm.rya.api.persist.index.RyaSecondaryIndexer; -import mvm.rya.api.persist.query.RyaQueryEngine; -import mvm.rya.mongodb.dao.MongoDBNamespaceManager; -import mvm.rya.mongodb.dao.MongoDBStorageStrategy; -import mvm.rya.mongodb.dao.SimpleMongoDBNamespaceManager; -import mvm.rya.mongodb.dao.SimpleMongoDBStorageStrategy; +import org.apache.rya.api.RdfCloudTripleStoreConfiguration; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.domain.RyaURI; +import org.apache.rya.api.persist.RyaDAO; +import org.apache.rya.api.persist.RyaDAOException; +import org.apache.rya.api.persist.RyaNamespaceManager; +import org.apache.rya.api.persist.index.RyaSecondaryIndexer; +import org.apache.rya.api.persist.query.RyaQueryEngine; +import org.apache.rya.mongodb.dao.MongoDBNamespaceManager; +import org.apache.rya.mongodb.dao.MongoDBStorageStrategy; +import org.apache.rya.mongodb.dao.SimpleMongoDBNamespaceManager; +import org.apache.rya.mongodb.dao.SimpleMongoDBStorageStrategy; /** * Default DAO for mongo backed RYA allowing for CRUD operations. http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoSecondaryIndex.java ---------------------------------------------------------------------- diff --git a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoSecondaryIndex.java b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoSecondaryIndex.java index e32216f..3d3e22f 100644 --- a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoSecondaryIndex.java +++ b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/MongoSecondaryIndex.java @@ -1,4 +1,4 @@ -package mvm.rya.mongodb; +package org.apache.rya.mongodb; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -21,7 +21,7 @@ package mvm.rya.mongodb; import com.mongodb.MongoClient; -import mvm.rya.api.persist.index.RyaSecondaryIndexer; +import org.apache.rya.api.persist.index.RyaSecondaryIndexer; public interface MongoSecondaryIndex extends RyaSecondaryIndexer{ public void init(); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/MongoDBNamespaceManager.java ---------------------------------------------------------------------- diff --git a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/MongoDBNamespaceManager.java b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/MongoDBNamespaceManager.java index fd9b659..1d86ce4 100644 --- a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/MongoDBNamespaceManager.java +++ b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/MongoDBNamespaceManager.java @@ -1,4 +1,4 @@ -package mvm.rya.mongodb.dao; +package org.apache.rya.mongodb.dao; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -20,10 +20,10 @@ package mvm.rya.mongodb.dao; */ -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.persist.RyaNamespaceManager; -import mvm.rya.api.persist.query.RyaQuery; -import mvm.rya.mongodb.MongoDBRdfConfiguration; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.persist.RyaNamespaceManager; +import org.apache.rya.api.persist.query.RyaQuery; +import org.apache.rya.mongodb.MongoDBRdfConfiguration; import com.mongodb.DBCollection; import com.mongodb.DBObject; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/MongoDBStorageStrategy.java ---------------------------------------------------------------------- diff --git a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/MongoDBStorageStrategy.java b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/MongoDBStorageStrategy.java index 5ae371b..1fb5d72 100644 --- a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/MongoDBStorageStrategy.java +++ b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/MongoDBStorageStrategy.java @@ -1,4 +1,4 @@ -package mvm.rya.mongodb.dao; +package org.apache.rya.mongodb.dao; import com.mongodb.DBCollection; import com.mongodb.DBObject; @@ -23,8 +23,8 @@ import com.mongodb.DBObject; */ -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.persist.query.RyaQuery; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.persist.query.RyaQuery; /** * Defines how objects are stored in MongoDB. http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/SimpleMongoDBNamespaceManager.java ---------------------------------------------------------------------- diff --git a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/SimpleMongoDBNamespaceManager.java b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/SimpleMongoDBNamespaceManager.java index 259420b..d2d6d7e 100644 --- a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/SimpleMongoDBNamespaceManager.java +++ b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/SimpleMongoDBNamespaceManager.java @@ -1,4 +1,4 @@ -package mvm.rya.mongodb.dao; +package org.apache.rya.mongodb.dao; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -26,8 +26,8 @@ import java.security.MessageDigest; import java.security.NoSuchAlgorithmException; import java.util.Map; -import mvm.rya.api.persist.RyaDAOException; -import mvm.rya.mongodb.MongoDBRdfConfiguration; +import org.apache.rya.api.persist.RyaDAOException; +import org.apache.rya.mongodb.MongoDBRdfConfiguration; import org.apache.commons.codec.binary.Hex; import org.openrdf.model.Namespace; http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/SimpleMongoDBStorageStrategy.java ---------------------------------------------------------------------- diff --git a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/SimpleMongoDBStorageStrategy.java b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/SimpleMongoDBStorageStrategy.java index d09316a..d51a2fe 100644 --- a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/SimpleMongoDBStorageStrategy.java +++ b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/dao/SimpleMongoDBStorageStrategy.java @@ -1,4 +1,4 @@ -package mvm.rya.mongodb.dao; +package org.apache.rya.mongodb.dao; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -34,10 +34,10 @@ import com.mongodb.BasicDBObject; import com.mongodb.DBCollection; import com.mongodb.DBObject; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.domain.RyaType; -import mvm.rya.api.domain.RyaURI; -import mvm.rya.api.persist.query.RyaQuery; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.domain.RyaType; +import org.apache.rya.api.domain.RyaURI; +import org.apache.rya.api.persist.query.RyaQuery; /** * Defines how {@link RyaStatement}s are stored in MongoDB. http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/instance/MongoDetailsAdapter.java ---------------------------------------------------------------------- diff --git a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/instance/MongoDetailsAdapter.java b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/instance/MongoDetailsAdapter.java index 282ecbb..0237b97 100644 --- a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/instance/MongoDetailsAdapter.java +++ b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/instance/MongoDetailsAdapter.java @@ -16,7 +16,7 @@ * specific language governing permissions and limitations * under the License. */ -package mvm.rya.mongodb.instance; +package org.apache.rya.mongodb.instance; import static java.util.Objects.requireNonNull; @@ -34,17 +34,17 @@ import com.mongodb.BasicDBObject; import com.mongodb.BasicDBObjectBuilder; import com.mongodb.DBObject; -import mvm.rya.api.instance.RyaDetails; -import mvm.rya.api.instance.RyaDetails.EntityCentricIndexDetails; -import mvm.rya.api.instance.RyaDetails.FreeTextIndexDetails; -import mvm.rya.api.instance.RyaDetails.GeoIndexDetails; -import mvm.rya.api.instance.RyaDetails.JoinSelectivityDetails; -import mvm.rya.api.instance.RyaDetails.PCJIndexDetails; -import mvm.rya.api.instance.RyaDetails.PCJIndexDetails.FluoDetails; -import mvm.rya.api.instance.RyaDetails.PCJIndexDetails.PCJDetails; -import mvm.rya.api.instance.RyaDetails.PCJIndexDetails.PCJDetails.PCJUpdateStrategy; -import mvm.rya.api.instance.RyaDetails.ProspectorDetails; -import mvm.rya.api.instance.RyaDetails.TemporalIndexDetails; +import org.apache.rya.api.instance.RyaDetails; +import org.apache.rya.api.instance.RyaDetails.EntityCentricIndexDetails; +import org.apache.rya.api.instance.RyaDetails.FreeTextIndexDetails; +import org.apache.rya.api.instance.RyaDetails.GeoIndexDetails; +import org.apache.rya.api.instance.RyaDetails.JoinSelectivityDetails; +import org.apache.rya.api.instance.RyaDetails.PCJIndexDetails; +import org.apache.rya.api.instance.RyaDetails.PCJIndexDetails.FluoDetails; +import org.apache.rya.api.instance.RyaDetails.PCJIndexDetails.PCJDetails; +import org.apache.rya.api.instance.RyaDetails.PCJIndexDetails.PCJDetails.PCJUpdateStrategy; +import org.apache.rya.api.instance.RyaDetails.ProspectorDetails; +import org.apache.rya.api.instance.RyaDetails.TemporalIndexDetails; /** * Serializes configuration details for use in Mongo. http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/instance/MongoRyaInstanceDetailsRepository.java ---------------------------------------------------------------------- diff --git a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/instance/MongoRyaInstanceDetailsRepository.java b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/instance/MongoRyaInstanceDetailsRepository.java index dfefa8f..cc37013 100644 --- a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/instance/MongoRyaInstanceDetailsRepository.java +++ b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/instance/MongoRyaInstanceDetailsRepository.java @@ -1,4 +1,4 @@ -package mvm.rya.mongodb.instance; +package org.apache.rya.mongodb.instance; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -31,9 +31,9 @@ import com.mongodb.DBObject; import com.mongodb.MongoClient; import com.mongodb.WriteResult; -import mvm.rya.api.instance.RyaDetails; -import mvm.rya.api.instance.RyaDetailsRepository; -import mvm.rya.mongodb.instance.MongoDetailsAdapter.MalformedRyaDetailsException; +import org.apache.rya.api.instance.RyaDetails; +import org.apache.rya.api.instance.RyaDetailsRepository; +import org.apache.rya.mongodb.instance.MongoDetailsAdapter.MalformedRyaDetailsException; /** * An implementation of {@link RyaDetailsRepository} that stores a Rya http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/iter/NonCloseableRyaStatementCursorIterator.java ---------------------------------------------------------------------- diff --git a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/iter/NonCloseableRyaStatementCursorIterator.java b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/iter/NonCloseableRyaStatementCursorIterator.java index ba37ca1..35dab6d 100644 --- a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/iter/NonCloseableRyaStatementCursorIterator.java +++ b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/iter/NonCloseableRyaStatementCursorIterator.java @@ -1,4 +1,4 @@ -package mvm.rya.mongodb.iter; +package org.apache.rya.mongodb.iter; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -22,8 +22,8 @@ package mvm.rya.mongodb.iter; import java.util.Iterator; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.persist.RyaDAOException; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.persist.RyaDAOException; public class NonCloseableRyaStatementCursorIterator implements Iterator<RyaStatement> { http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/17bde6d8/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/iter/RyaStatementBindingSetCursorIterator.java ---------------------------------------------------------------------- diff --git a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/iter/RyaStatementBindingSetCursorIterator.java b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/iter/RyaStatementBindingSetCursorIterator.java index d24cbdc..ebe5c3f 100644 --- a/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/iter/RyaStatementBindingSetCursorIterator.java +++ b/dao/mongodb.rya/src/main/java/org/apache/rya/mongodb/iter/RyaStatementBindingSetCursorIterator.java @@ -1,4 +1,4 @@ -package mvm.rya.mongodb.iter; +package org.apache.rya.mongodb.iter; /* * Licensed to the Apache Software Foundation (ASF) under one @@ -26,10 +26,10 @@ import java.util.Collection; import java.util.Iterator; import java.util.Map.Entry; -import mvm.rya.api.RdfCloudTripleStoreUtils; -import mvm.rya.api.domain.RyaStatement; -import mvm.rya.api.persist.RyaDAOException; -import mvm.rya.mongodb.dao.MongoDBStorageStrategy; +import org.apache.rya.api.RdfCloudTripleStoreUtils; +import org.apache.rya.api.domain.RyaStatement; +import org.apache.rya.api.persist.RyaDAOException; +import org.apache.rya.mongodb.dao.MongoDBStorageStrategy; import org.openrdf.query.BindingSet;