RYA-198 Renaming Files
Project: http://git-wip-us.apache.org/repos/asf/incubator-rya/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rya/commit/44a2dcf0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rya/tree/44a2dcf0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rya/diff/44a2dcf0 Branch: refs/heads/master Commit: 44a2dcf065286ad6b122121ff7d3bf462c60dc3e Parents: e541b71 Author: Aaron Mihalik <[email protected]> Authored: Fri Oct 14 14:59:50 2016 -0400 Committer: Aaron Mihalik <[email protected]> Committed: Fri Oct 14 15:33:14 2016 -0400 ---------------------------------------------------------------------- .../InvalidValueTypeMarkerRuntimeException.java | 55 - .../api/RdfCloudTripleStoreConfiguration.java | 520 ----- .../rya/api/RdfCloudTripleStoreConstants.java | 151 -- .../rya/api/RdfCloudTripleStoreStatement.java | 72 - .../mvm/rya/api/RdfCloudTripleStoreUtils.java | 420 ---- .../java/mvm/rya/api/client/BatchUpdatePCJ.java | 40 - .../main/java/mvm/rya/api/client/CreatePCJ.java | 40 - .../main/java/mvm/rya/api/client/DeletePCJ.java | 38 - .../mvm/rya/api/client/GetInstanceDetails.java | 44 - .../main/java/mvm/rya/api/client/Install.java | 268 --- .../client/InstanceDoesNotExistException.java | 38 - .../java/mvm/rya/api/client/InstanceExists.java | 37 - .../java/mvm/rya/api/client/ListInstances.java | 38 - .../api/client/PCJDoesNotExistException.java | 38 - .../main/java/mvm/rya/api/client/RyaClient.java | 112 - .../mvm/rya/api/client/RyaClientException.java | 37 - .../rya/api/date/DateTimeTtlValueConverter.java | 80 - .../api/date/TimestampTtlStrValueConverter.java | 56 - .../api/date/TimestampTtlValueConverter.java | 56 - .../mvm/rya/api/date/TtlValueConverter.java | 41 - .../src/main/java/mvm/rya/api/domain/Node.java | 38 - .../main/java/mvm/rya/api/domain/RangeURI.java | 52 - .../java/mvm/rya/api/domain/RangeValue.java | 72 - .../main/java/mvm/rya/api/domain/RyaRange.java | 32 - .../main/java/mvm/rya/api/domain/RyaSchema.java | 43 - .../java/mvm/rya/api/domain/RyaStatement.java | 252 --- .../main/java/mvm/rya/api/domain/RyaType.java | 135 -- .../java/mvm/rya/api/domain/RyaTypePrefix.java | 59 - .../java/mvm/rya/api/domain/RyaTypeRange.java | 99 - .../main/java/mvm/rya/api/domain/RyaURI.java | 63 - .../java/mvm/rya/api/domain/RyaURIPrefix.java | 47 - .../java/mvm/rya/api/domain/RyaURIRange.java | 95 - .../rya/api/instance/ConfigurationFields.java | 35 - .../java/mvm/rya/api/instance/RyaDetails.java | 1031 --------- .../rya/api/instance/RyaDetailsRepository.java | 123 - .../api/instance/RyaDetailsToConfiguration.java | 98 - .../mvm/rya/api/instance/RyaDetailsUpdater.java | 124 - .../mvm/rya/api/layout/TableLayoutStrategy.java | 40 - .../api/layout/TablePrefixLayoutStrategy.java | 85 - .../mvm/rya/api/persist/RdfDAOException.java | 44 - .../mvm/rya/api/persist/RdfEvalStatsDAO.java | 54 - .../java/mvm/rya/api/persist/RyaConfigured.java | 35 - .../main/java/mvm/rya/api/persist/RyaDAO.java | 126 -- .../mvm/rya/api/persist/RyaDAOException.java | 43 - .../rya/api/persist/RyaNamespaceManager.java | 41 - .../api/persist/index/RyaSecondaryIndexer.java | 63 - .../persist/joinselect/SelectivityEvalDAO.java | 37 - .../rya/api/persist/query/BatchRyaQuery.java | 115 - .../mvm/rya/api/persist/query/RyaQuery.java | 97 - .../rya/api/persist/query/RyaQueryEngine.java | 96 - .../rya/api/persist/query/RyaQueryOptions.java | 246 -- .../rya/api/persist/query/join/HashJoin.java | 158 -- .../api/persist/query/join/IterativeJoin.java | 233 -- .../mvm/rya/api/persist/query/join/Join.java | 44 - .../rya/api/persist/query/join/MergeJoin.java | 244 -- .../mvm/rya/api/persist/utils/RyaDAOHelper.java | 176 -- .../strategy/AbstractTriplePatternStrategy.java | 93 - .../mvm/rya/api/query/strategy/ByteRange.java | 45 - .../query/strategy/TriplePatternStrategy.java | 49 - .../AbstractHashedTriplePatternStrategy.java | 90 - .../HashedPoWholeRowTriplePatternStrategy.java | 136 -- .../HashedSpoWholeRowTriplePatternStrategy.java | 142 -- .../OspWholeRowTriplePatternStrategy.java | 113 - .../PoWholeRowTriplePatternStrategy.java | 128 -- .../SpoWholeRowTriplePatternStrategy.java | 130 -- .../resolver/CustomRyaTypeResolverMapping.java | 57 - .../rya/api/resolver/RdfToRyaConversions.java | 93 - .../java/mvm/rya/api/resolver/RyaContext.java | 192 -- .../rya/api/resolver/RyaToRdfConversions.java | 75 - .../mvm/rya/api/resolver/RyaTripleContext.java | 133 -- .../mvm/rya/api/resolver/RyaTypeResolver.java | 60 - .../api/resolver/RyaTypeResolverException.java | 43 - .../api/resolver/RyaTypeResolverMapping.java | 57 - .../resolver/impl/BooleanRyaTypeResolver.java | 61 - .../api/resolver/impl/ByteRyaTypeResolver.java | 63 - .../resolver/impl/CustomDatatypeResolver.java | 70 - .../resolver/impl/DateTimeRyaTypeResolver.java | 76 - .../resolver/impl/DoubleRyaTypeResolver.java | 68 - .../api/resolver/impl/FloatRyaTypeResolver.java | 64 - .../resolver/impl/IntegerRyaTypeResolver.java | 67 - .../api/resolver/impl/LongRyaTypeResolver.java | 68 - .../api/resolver/impl/RyaTypeResolverImpl.java | 124 - .../rya/api/resolver/impl/RyaURIResolver.java | 44 - .../ServiceBackedRyaTypeResolverMappings.java | 45 - .../api/resolver/impl/ShortRyaTypeResolver.java | 65 - .../mvm/rya/api/resolver/triple/TripleRow.java | 107 - .../rya/api/resolver/triple/TripleRowRegex.java | 84 - .../api/resolver/triple/TripleRowResolver.java | 43 - .../triple/TripleRowResolverException.java | 43 - .../impl/WholeRowHashedTripleResolver.java | 160 -- .../triple/impl/WholeRowTripleResolver.java | 139 -- .../mvm/rya/api/security/SecurityProvider.java | 28 - .../api/utils/CloseableIterableIteration.java | 76 - .../mvm/rya/api/utils/EnumerationWrapper.java | 58 - .../java/mvm/rya/api/utils/IteratorWrapper.java | 58 - .../rya/api/utils/NullableStatementImpl.java | 105 - .../api/utils/PeekingCloseableIteration.java | 74 - .../RyaStatementAddBindingSetFunction.java | 40 - ...ementRemoveBindingSetCloseableIteration.java | 61 - .../InvalidValueTypeMarkerRuntimeException.java | 55 + .../api/RdfCloudTripleStoreConfiguration.java | 520 +++++ .../rya/api/RdfCloudTripleStoreConstants.java | 151 ++ .../rya/api/RdfCloudTripleStoreStatement.java | 72 + .../rya/api/RdfCloudTripleStoreUtils.java | 420 ++++ .../apache/rya/api/client/BatchUpdatePCJ.java | 40 + .../org/apache/rya/api/client/CreatePCJ.java | 40 + .../org/apache/rya/api/client/DeletePCJ.java | 38 + .../rya/api/client/GetInstanceDetails.java | 44 + .../java/org/apache/rya/api/client/Install.java | 268 +++ .../client/InstanceDoesNotExistException.java | 38 + .../apache/rya/api/client/InstanceExists.java | 37 + .../apache/rya/api/client/ListInstances.java | 38 + .../api/client/PCJDoesNotExistException.java | 38 + .../org/apache/rya/api/client/RyaClient.java | 112 + .../rya/api/client/RyaClientException.java | 37 + .../rya/api/date/DateTimeTtlValueConverter.java | 80 + .../api/date/TimestampTtlStrValueConverter.java | 56 + .../api/date/TimestampTtlValueConverter.java | 56 + .../apache/rya/api/date/TtlValueConverter.java | 41 + .../java/org/apache/rya/api/domain/Node.java | 38 + .../org/apache/rya/api/domain/RangeURI.java | 52 + .../org/apache/rya/api/domain/RangeValue.java | 72 + .../org/apache/rya/api/domain/RyaRange.java | 32 + .../org/apache/rya/api/domain/RyaSchema.java | 43 + .../org/apache/rya/api/domain/RyaStatement.java | 252 +++ .../java/org/apache/rya/api/domain/RyaType.java | 135 ++ .../apache/rya/api/domain/RyaTypePrefix.java | 59 + .../org/apache/rya/api/domain/RyaTypeRange.java | 99 + .../java/org/apache/rya/api/domain/RyaURI.java | 63 + .../org/apache/rya/api/domain/RyaURIPrefix.java | 47 + .../org/apache/rya/api/domain/RyaURIRange.java | 95 + .../rya/api/instance/ConfigurationFields.java | 35 + .../org/apache/rya/api/instance/RyaDetails.java | 1031 +++++++++ .../rya/api/instance/RyaDetailsRepository.java | 123 + .../api/instance/RyaDetailsToConfiguration.java | 98 + .../rya/api/instance/RyaDetailsUpdater.java | 124 + .../rya/api/layout/TableLayoutStrategy.java | 40 + .../api/layout/TablePrefixLayoutStrategy.java | 85 + .../apache/rya/api/persist/RdfDAOException.java | 44 + .../apache/rya/api/persist/RdfEvalStatsDAO.java | 54 + .../apache/rya/api/persist/RyaConfigured.java | 35 + .../java/org/apache/rya/api/persist/RyaDAO.java | 126 ++ .../apache/rya/api/persist/RyaDAOException.java | 43 + .../rya/api/persist/RyaNamespaceManager.java | 41 + .../api/persist/index/RyaSecondaryIndexer.java | 63 + .../persist/joinselect/SelectivityEvalDAO.java | 37 + .../rya/api/persist/query/BatchRyaQuery.java | 115 + .../apache/rya/api/persist/query/RyaQuery.java | 97 + .../rya/api/persist/query/RyaQueryEngine.java | 96 + .../rya/api/persist/query/RyaQueryOptions.java | 246 ++ .../rya/api/persist/query/join/HashJoin.java | 158 ++ .../api/persist/query/join/IterativeJoin.java | 233 ++ .../apache/rya/api/persist/query/join/Join.java | 44 + .../rya/api/persist/query/join/MergeJoin.java | 244 ++ .../rya/api/persist/utils/RyaDAOHelper.java | 176 ++ .../strategy/AbstractTriplePatternStrategy.java | 93 + .../rya/api/query/strategy/ByteRange.java | 45 + .../query/strategy/TriplePatternStrategy.java | 49 + .../AbstractHashedTriplePatternStrategy.java | 90 + .../HashedPoWholeRowTriplePatternStrategy.java | 136 ++ .../HashedSpoWholeRowTriplePatternStrategy.java | 142 ++ .../OspWholeRowTriplePatternStrategy.java | 113 + .../PoWholeRowTriplePatternStrategy.java | 128 ++ .../SpoWholeRowTriplePatternStrategy.java | 130 ++ .../resolver/CustomRyaTypeResolverMapping.java | 57 + .../rya/api/resolver/RdfToRyaConversions.java | 93 + .../org/apache/rya/api/resolver/RyaContext.java | 192 ++ .../rya/api/resolver/RyaToRdfConversions.java | 75 + .../rya/api/resolver/RyaTripleContext.java | 133 ++ .../rya/api/resolver/RyaTypeResolver.java | 60 + .../api/resolver/RyaTypeResolverException.java | 43 + .../api/resolver/RyaTypeResolverMapping.java | 57 + .../resolver/impl/BooleanRyaTypeResolver.java | 61 + .../api/resolver/impl/ByteRyaTypeResolver.java | 63 + .../resolver/impl/CustomDatatypeResolver.java | 70 + .../resolver/impl/DateTimeRyaTypeResolver.java | 76 + .../resolver/impl/DoubleRyaTypeResolver.java | 68 + .../api/resolver/impl/FloatRyaTypeResolver.java | 64 + .../resolver/impl/IntegerRyaTypeResolver.java | 67 + .../api/resolver/impl/LongRyaTypeResolver.java | 68 + .../api/resolver/impl/RyaTypeResolverImpl.java | 124 + .../rya/api/resolver/impl/RyaURIResolver.java | 44 + .../ServiceBackedRyaTypeResolverMappings.java | 45 + .../api/resolver/impl/ShortRyaTypeResolver.java | 65 + .../rya/api/resolver/triple/TripleRow.java | 107 + .../rya/api/resolver/triple/TripleRowRegex.java | 84 + .../api/resolver/triple/TripleRowResolver.java | 43 + .../triple/TripleRowResolverException.java | 43 + .../impl/WholeRowHashedTripleResolver.java | 160 ++ .../triple/impl/WholeRowTripleResolver.java | 139 ++ .../rya/api/security/SecurityProvider.java | 28 + .../api/utils/CloseableIterableIteration.java | 76 + .../rya/api/utils/EnumerationWrapper.java | 58 + .../apache/rya/api/utils/IteratorWrapper.java | 58 + .../rya/api/utils/NullableStatementImpl.java | 105 + .../api/utils/PeekingCloseableIteration.java | 74 + .../RyaStatementAddBindingSetFunction.java | 40 + ...ementRemoveBindingSetCloseableIteration.java | 61 + .../java/mvm/rya/api/domain/RyaTypeTest.java | 119 - .../mvm/rya/api/domain/RyaURIPrefixTest.java | 37 - .../mvm/rya/api/instance/RyaDetailsTest.java | 140 -- .../instance/RyaDetailsToConfigurationTest.java | 84 - .../rya/api/instance/RyaDetailsUpdaterTest.java | 141 -- .../mvm/rya/api/persist/query/RyaQueryTest.java | 63 - .../AbstractTriplePatternStrategyTest.java | 192 -- ...shedPoWholeRowTriplePatternStrategyTest.java | 244 -- ...hedSpoWholeRowTriplePatternStrategyTest.java | 199 -- .../wholerow/MockRdfCloudConfiguration.java | 32 - .../OspWholeRowTriplePatternStrategyTest.java | 135 -- .../PoWholeRowTriplePatternStrategyTest.java | 159 -- .../SpoWholeRowTriplePatternStrategyTest.java | 185 -- .../mvm/rya/api/resolver/RyaContextTest.java | 86 - .../impl/CustomDatatypeResolverTest.java | 40 - .../impl/DateTimeRyaTypeResolverTest.java | 177 -- .../impl/DoubleRyaTypeResolverTest.java | 46 - .../impl/IntegerRyaTypeResolverTest.java | 44 - .../resolver/impl/LongRyaTypeResolverTest.java | 49 - .../api/resolver/impl/RyaURIResolverTest.java | 40 - .../impl/HashedWholeRowTripleResolverTest.java | 124 - .../triple/impl/WholeRowTripleResolverTest.java | 127 -- .../test/java/mvm/rya/api/utils/RdfIOTest.java | 67 - .../org/apache/rya/api/domain/RyaTypeTest.java | 119 + .../apache/rya/api/domain/RyaURIPrefixTest.java | 37 + .../apache/rya/api/instance/RyaDetailsTest.java | 140 ++ .../instance/RyaDetailsToConfigurationTest.java | 84 + .../rya/api/instance/RyaDetailsUpdaterTest.java | 141 ++ .../rya/api/persist/query/RyaQueryTest.java | 63 + .../AbstractTriplePatternStrategyTest.java | 192 ++ ...shedPoWholeRowTriplePatternStrategyTest.java | 244 ++ ...hedSpoWholeRowTriplePatternStrategyTest.java | 199 ++ .../wholerow/MockRdfCloudConfiguration.java | 32 + .../OspWholeRowTriplePatternStrategyTest.java | 135 ++ .../PoWholeRowTriplePatternStrategyTest.java | 159 ++ .../SpoWholeRowTriplePatternStrategyTest.java | 185 ++ .../apache/rya/api/resolver/RyaContextTest.java | 86 + .../impl/CustomDatatypeResolverTest.java | 40 + .../impl/DateTimeRyaTypeResolverTest.java | 177 ++ .../impl/DoubleRyaTypeResolverTest.java | 46 + .../impl/IntegerRyaTypeResolverTest.java | 44 + .../resolver/impl/LongRyaTypeResolverTest.java | 49 + .../api/resolver/impl/RyaURIResolverTest.java | 40 + .../impl/HashedWholeRowTripleResolverTest.java | 124 + .../triple/impl/WholeRowTripleResolverTest.java | 127 ++ .../org/apache/rya/api/utils/RdfIOTest.java | 67 + .../provenance/LoggingProvenanceCollector.java | 41 - .../ProvenanceCollectionException.java | 39 - .../provenance/ProvenanceCollector.java | 34 - .../TriplestoreProvenanceCollector.java | 68 - .../provenance/rdf/BaseProvenanceModel.java | 68 - .../provenance/rdf/RDFProvenanceModel.java | 33 - .../provenance/LoggingProvenanceCollector.java | 41 + .../ProvenanceCollectionException.java | 39 + .../provenance/ProvenanceCollector.java | 34 + .../TriplestoreProvenanceCollector.java | 68 + .../provenance/rdf/BaseProvenanceModel.java | 68 + .../provenance/rdf/RDFProvenanceModel.java | 33 + .../TriplestoreProvenanceCollectorTest.java | 51 - .../provenance/rdf/BaseProvenanceModelTest.java | 38 - .../TriplestoreProvenanceCollectorTest.java | 51 + .../provenance/rdf/BaseProvenanceModelTest.java | 38 + .../AccumuloNamespaceTableIterator.java | 99 - .../rya/accumulo/AccumuloRdfConfiguration.java | 158 -- .../mvm/rya/accumulo/AccumuloRdfConstants.java | 40 - .../rya/accumulo/AccumuloRdfEvalStatsDAO.java | 173 -- .../rya/accumulo/AccumuloRdfQueryIterator.java | 297 --- .../java/mvm/rya/accumulo/AccumuloRdfUtils.java | 72 - .../java/mvm/rya/accumulo/AccumuloRyaDAO.java | 551 ----- .../accumulo/DefineTripleQueryRangeFactory.java | 152 -- .../mvm/rya/accumulo/RyaTableKeyValues.java | 115 - .../rya/accumulo/RyaTableMutationsFactory.java | 148 -- .../experimental/AbstractAccumuloIndexer.java | 59 - .../accumulo/experimental/AccumuloIndexer.java | 38 - .../AccumuloRyaInstanceDetailsRepository.java | 229 -- .../accumulo/instance/RyaDetailsSerializer.java | 96 - .../accumulo/query/AccumuloRyaQueryEngine.java | 410 ---- .../query/KeyValueToRyaStatementFunction.java | 72 - .../accumulo/query/RangeBindingSetEntries.java | 58 - .../RyaStatementBindingSetKeyValueIterator.java | 154 -- .../query/RyaStatementKeyValueIterator.java | 107 - .../query/ScannerBaseCloseableIterable.java | 56 - .../mvm/rya/accumulo/utils/TimeRangeFilter.java | 87 - .../accumulo/utils/VisibilitySimplifier.java | 54 - .../AccumuloNamespaceTableIterator.java | 99 + .../rya/accumulo/AccumuloRdfConfiguration.java | 158 ++ .../rya/accumulo/AccumuloRdfConstants.java | 40 + .../rya/accumulo/AccumuloRdfEvalStatsDAO.java | 173 ++ .../rya/accumulo/AccumuloRdfQueryIterator.java | 297 +++ .../apache/rya/accumulo/AccumuloRdfUtils.java | 72 + .../org/apache/rya/accumulo/AccumuloRyaDAO.java | 551 +++++ .../accumulo/DefineTripleQueryRangeFactory.java | 152 ++ .../apache/rya/accumulo/RyaTableKeyValues.java | 115 + .../rya/accumulo/RyaTableMutationsFactory.java | 148 ++ .../experimental/AbstractAccumuloIndexer.java | 59 + .../accumulo/experimental/AccumuloIndexer.java | 38 + .../AccumuloRyaInstanceDetailsRepository.java | 229 ++ .../accumulo/instance/RyaDetailsSerializer.java | 96 + .../accumulo/query/AccumuloRyaQueryEngine.java | 410 ++++ .../query/KeyValueToRyaStatementFunction.java | 72 + .../accumulo/query/RangeBindingSetEntries.java | 58 + .../RyaStatementBindingSetKeyValueIterator.java | 154 ++ .../query/RyaStatementKeyValueIterator.java | 107 + .../query/ScannerBaseCloseableIterable.java | 56 + .../rya/accumulo/utils/TimeRangeFilter.java | 87 + .../accumulo/utils/VisibilitySimplifier.java | 54 + .../java/mvm/rya/accumulo/AccumuloITBase.java | 105 - .../accumulo/AccumuloRdfConfigurationTest.java | 75 - .../mvm/rya/accumulo/AccumuloRyaDAOTest.java | 713 ------ .../mvm/rya/accumulo/AccumuloRyaITBase.java | 109 - .../DefineTripleQueryRangeFactoryTest.java | 265 --- .../accumulo/MiniAccumuloClusterInstance.java | 119 - .../AccumuloRyaDetailsRepositoryIT.java | 304 --- .../utils/VisibilitySimplifierTest.java | 53 - .../org/apache/rya/accumulo/AccumuloITBase.java | 105 + .../accumulo/AccumuloRdfConfigurationTest.java | 75 + .../apache/rya/accumulo/AccumuloRyaDAOTest.java | 713 ++++++ .../apache/rya/accumulo/AccumuloRyaITBase.java | 109 + .../DefineTripleQueryRangeFactoryTest.java | 265 +++ .../accumulo/MiniAccumuloClusterInstance.java | 119 + .../AccumuloRyaDetailsRepositoryIT.java | 304 +++ .../utils/VisibilitySimplifierTest.java | 53 + .../mvm/rya/mongodb/MongoConnectorFactory.java | 138 -- .../mvm/rya/mongodb/MongoDBQueryEngine.java | 202 -- .../rya/mongodb/MongoDBRdfConfiguration.java | 128 -- .../java/mvm/rya/mongodb/MongoDBRyaDAO.java | 233 -- .../mvm/rya/mongodb/MongoSecondaryIndex.java | 31 - .../mongodb/dao/MongoDBNamespaceManager.java | 35 - .../rya/mongodb/dao/MongoDBStorageStrategy.java | 45 - .../dao/SimpleMongoDBNamespaceManager.java | 181 -- .../dao/SimpleMongoDBStorageStrategy.java | 162 -- .../mongodb/instance/MongoDetailsAdapter.java | 236 -- .../MongoRyaInstanceDetailsRepository.java | 144 -- .../NonCloseableRyaStatementCursorIterator.java | 57 - .../RyaStatementBindingSetCursorIterator.java | 125 -- .../iter/RyaStatementCursorIterable.java | 67 - .../iter/RyaStatementCursorIterator.java | 104 - .../rya/mongodb/MongoConnectorFactory.java | 138 ++ .../apache/rya/mongodb/MongoDBQueryEngine.java | 202 ++ .../rya/mongodb/MongoDBRdfConfiguration.java | 128 ++ .../org/apache/rya/mongodb/MongoDBRyaDAO.java | 233 ++ .../apache/rya/mongodb/MongoSecondaryIndex.java | 31 + .../mongodb/dao/MongoDBNamespaceManager.java | 35 + .../rya/mongodb/dao/MongoDBStorageStrategy.java | 45 + .../dao/SimpleMongoDBNamespaceManager.java | 181 ++ .../dao/SimpleMongoDBStorageStrategy.java | 162 ++ .../mongodb/instance/MongoDetailsAdapter.java | 236 ++ .../MongoRyaInstanceDetailsRepository.java | 144 ++ .../NonCloseableRyaStatementCursorIterator.java | 57 + .../RyaStatementBindingSetCursorIterator.java | 125 ++ .../iter/RyaStatementCursorIterable.java | 67 + .../iter/RyaStatementCursorIterator.java | 104 + .../mvm/rya/mongodb/MongoDBQueryEngineTest.java | 124 - .../java/mvm/rya/mongodb/MongoDBRyaDAOIT.java | 139 -- .../java/mvm/rya/mongodb/MongoDBRyaDAOTest.java | 137 -- .../SimpleMongoDBStorageStrategyTest.java | 85 - .../instance/MongoDetailsAdapterTest.java | 296 --- .../instance/MongoRyaDetailsRepositoryIT.java | 307 --- .../rya/mongodb/MongoDBQueryEngineTest.java | 124 + .../org/apache/rya/mongodb/MongoDBRyaDAOIT.java | 139 ++ .../apache/rya/mongodb/MongoDBRyaDAOTest.java | 137 ++ .../SimpleMongoDBStorageStrategyTest.java | 85 + .../instance/MongoDetailsAdapterTest.java | 296 +++ .../instance/MongoRyaDetailsRepositoryIT.java | 307 +++ .../documentIndex/DocIndexIteratorUtil.java | 31 - .../DocumentIndexIntersectingIterator.java | 850 ------- .../rya/accumulo/documentIndex/TextColumn.java | 108 - .../iterators/BindingSetHashJoinIterator.java | 324 --- .../pcj/iterators/IteratorCombiner.java | 107 - .../PCJKeyToCrossProductBindingSetIterator.java | 267 --- .../PCJKeyToJoinBindingSetIterator.java | 199 -- .../client/accumulo/AccumuloBatchUpdatePCJ.java | 244 -- .../api/client/accumulo/AccumuloCommand.java | 64 - .../accumulo/AccumuloConnectionDetails.java | 83 - .../api/client/accumulo/AccumuloCreatePCJ.java | 181 -- .../api/client/accumulo/AccumuloDeletePCJ.java | 130 -- .../accumulo/AccumuloGetInstanceDetails.java | 77 - .../api/client/accumulo/AccumuloInstall.java | 218 -- .../client/accumulo/AccumuloInstanceExists.java | 71 - .../client/accumulo/AccumuloListInstances.java | 141 -- .../accumulo/AccumuloRyaClientFactory.java | 60 - .../api/client/accumulo/FluoClientFactory.java | 72 - .../java/mvm/rya/indexing/DocIdIndexer.java | 47 - .../rya/indexing/FilterFunctionOptimizer.java | 339 --- .../java/mvm/rya/indexing/FreeTextIndexer.java | 48 - .../java/mvm/rya/indexing/GeoConstants.java | 46 - .../ExternalIndexMatcher.java | 34 - .../GeneralizedExternalProcessor.java | 726 ------ .../IndexPlanValidator/IndexListPruner.java | 31 - .../IndexPlanValidator/IndexPlanValidator.java | 210 -- .../IndexPlanValidator/IndexTupleGenerator.java | 33 - .../IndexedExecutionPlanGenerator.java | 127 -- .../IndexedQueryPlanSelector.java | 32 - .../ThreshholdPlanSelector.java | 240 -- .../TupleExecutionPlanGenerator.java | 215 -- .../IndexPlanValidator/TupleReArranger.java | 348 --- .../IndexPlanValidator/TupleValidator.java | 34 - .../ValidIndexCombinationGenerator.java | 461 ---- .../VarConstantIndexListPruner.java | 174 -- .../java/mvm/rya/indexing/IndexingExpr.java | 94 - .../rya/indexing/IndexingFunctionRegistry.java | 134 -- .../java/mvm/rya/indexing/IteratorFactory.java | 159 -- .../main/java/mvm/rya/indexing/KeyParts.java | 333 --- .../src/main/java/mvm/rya/indexing/Md5Hash.java | 44 - .../java/mvm/rya/indexing/SearchFunction.java | 45 - .../mvm/rya/indexing/SearchFunctionFactory.java | 71 - .../mvm/rya/indexing/StatementConstraints.java | 73 - .../mvm/rya/indexing/StatementSerializer.java | 225 -- .../java/mvm/rya/indexing/TemporalIndexer.java | 166 -- .../java/mvm/rya/indexing/TemporalInstant.java | 83 - .../rya/indexing/TemporalInstantRfc3339.java | 219 -- .../java/mvm/rya/indexing/TemporalInterval.java | 181 -- .../java/mvm/rya/indexing/TemporalTupleSet.java | 287 --- .../mvm/rya/indexing/accumulo/ConfigUtils.java | 418 ---- .../accumulo/entity/AccumuloDocIdIndexer.java | 443 ---- .../accumulo/entity/EntityCentricIndex.java | 327 --- .../entity/EntityLocalityGroupSetter.java | 171 -- .../accumulo/entity/EntityOptimizer.java | 434 ---- .../accumulo/entity/EntityTupleSet.java | 263 --- .../rya/indexing/accumulo/entity/StarQuery.java | 636 ------ .../freetext/AccumuloFreeTextIndexer.java | 790 ------- .../accumulo/freetext/ColumnPrefixes.java | 120 - .../accumulo/freetext/FreeTextTupleSet.java | 160 -- .../accumulo/freetext/LuceneTokenizer.java | 57 - .../accumulo/freetext/SimpleTokenizer.java | 43 - .../indexing/accumulo/freetext/Tokenizer.java | 31 - .../freetext/iterators/AndingIterator.java | 563 ----- .../freetext/iterators/BooleanTreeIterator.java | 322 --- .../accumulo/freetext/query/ASTExpression.java | 63 - .../accumulo/freetext/query/ASTNodeUtils.java | 210 -- .../accumulo/freetext/query/ASTSimpleNode.java | 917 -------- .../accumulo/freetext/query/ASTTerm.java | 79 - .../freetext/query/JJTQueryParserState.java | 1024 --------- .../indexing/accumulo/freetext/query/Node.java | 937 -------- .../accumulo/freetext/query/ParseException.java | 1088 --------- .../accumulo/freetext/query/QueryParser.java | 1293 ----------- .../accumulo/freetext/query/QueryParser.jj | 176 -- .../accumulo/freetext/query/QueryParser.jjt | 90 - .../freetext/query/QueryParserConstants.java | 960 -------- .../freetext/query/QueryParserTokenManager.java | 1389 ------------ .../query/QueryParserTreeConstants.java | 920 -------- .../freetext/query/SimpleCharStream.java | 1372 ------------ .../accumulo/freetext/query/SimpleNode.java | 980 -------- .../indexing/accumulo/freetext/query/Token.java | 1032 --------- .../accumulo/freetext/query/TokenMgrError.java | 1048 --------- .../temporal/AccumuloTemporalIndexer.java | 945 -------- .../external/PrecomputedJoinIndexer.java | 279 --- .../external/PrecomputedJoinIndexerConfig.java | 122 - .../PrecomputedJoinStorageSupplier.java | 80 - .../PrecomputedJoinUpdaterSupplier.java | 78 - .../accumulo/AccumuloPcjStorageConfig.java | 58 - .../accumulo/AccumuloPcjStorageSupplier.java | 78 - .../indexing/external/fluo/FluoPcjUpdater.java | 89 - .../external/fluo/FluoPcjUpdaterConfig.java | 119 - .../external/fluo/FluoPcjUpdaterSupplier.java | 100 - .../rya/indexing/external/fluo/NoOpUpdater.java | 53 - .../external/fluo/NoOpUpdaterSupplier.java | 39 - .../fluo/PcjUpdaterSupplierFactory.java | 57 - .../external/tupleSet/AccumuloIndexSet.java | 604 ----- .../external/tupleSet/ExternalTupleSet.java | 309 --- .../external/tupleSet/ParsedQueryUtil.java | 60 - .../tupleSet/SimpleExternalTupleSet.java | 81 - .../indexing/mongodb/AbstractMongoIndexer.java | 192 -- .../mongodb/IndexingMongoDBStorageStrategy.java | 57 - .../mongodb/freetext/MongoFreeTextIndexer.java | 58 - .../freetext/TextMongoDBStorageStrategy.java | 45 - .../mongodb/temporal/MongoTemporalIndexer.java | 150 -- .../TemporalMongoDBStorageStrategy.java | 68 - .../pcj/matching/AbstractPCJMatcher.java | 126 -- .../pcj/matching/AbstractQuerySegment.java | 122 - .../pcj/matching/FlattenedOptional.java | 331 --- .../rya/indexing/pcj/matching/JoinSegment.java | 130 -- .../pcj/matching/JoinSegmentPCJMatcher.java | 106 - .../pcj/matching/OptionalJoinSegment.java | 146 -- .../matching/OptionalJoinSegmentPCJMatcher.java | 142 -- .../rya/indexing/pcj/matching/PCJMatcher.java | 76 - .../pcj/matching/PCJMatcherFactory.java | 73 - .../pcj/matching/PCJNodeConsolidator.java | 628 ------ .../rya/indexing/pcj/matching/PCJOptimizer.java | 374 ---- .../pcj/matching/PCJOptimizerUtilities.java | 377 ---- .../pcj/matching/QueryNodesToTupleExpr.java | 194 -- .../rya/indexing/pcj/matching/QuerySegment.java | 83 - .../pcj/matching/QueryVariableNormalizer.java | 1180 ---------- .../pcj/matching/TopOfQueryFilterRelocator.java | 97 - .../rya/sail/config/RyaAccumuloSailConfig.java | 165 -- .../rya/sail/config/RyaAccumuloSailFactory.java | 95 - .../mvm/rya/sail/config/RyaSailFactory.java | 159 -- .../documentIndex/DocIndexIteratorUtil.java | 31 + .../DocumentIndexIntersectingIterator.java | 850 +++++++ .../rya/accumulo/documentIndex/TextColumn.java | 108 + .../iterators/BindingSetHashJoinIterator.java | 324 +++ .../pcj/iterators/IteratorCombiner.java | 107 + .../PCJKeyToCrossProductBindingSetIterator.java | 267 +++ .../PCJKeyToJoinBindingSetIterator.java | 199 ++ .../client/accumulo/AccumuloBatchUpdatePCJ.java | 244 ++ .../api/client/accumulo/AccumuloCommand.java | 64 + .../accumulo/AccumuloConnectionDetails.java | 83 + .../api/client/accumulo/AccumuloCreatePCJ.java | 181 ++ .../api/client/accumulo/AccumuloDeletePCJ.java | 130 ++ .../accumulo/AccumuloGetInstanceDetails.java | 77 + .../api/client/accumulo/AccumuloInstall.java | 218 ++ .../client/accumulo/AccumuloInstanceExists.java | 71 + .../client/accumulo/AccumuloListInstances.java | 141 ++ .../accumulo/AccumuloRyaClientFactory.java | 60 + .../api/client/accumulo/FluoClientFactory.java | 72 + .../org/apache/rya/indexing/DocIdIndexer.java | 47 + .../rya/indexing/FilterFunctionOptimizer.java | 339 +++ .../apache/rya/indexing/FreeTextIndexer.java | 48 + .../org/apache/rya/indexing/GeoConstants.java | 46 + .../ExternalIndexMatcher.java | 34 + .../GeneralizedExternalProcessor.java | 726 ++++++ .../IndexPlanValidator/IndexListPruner.java | 31 + .../IndexPlanValidator/IndexPlanValidator.java | 210 ++ .../IndexPlanValidator/IndexTupleGenerator.java | 33 + .../IndexedExecutionPlanGenerator.java | 127 ++ .../IndexedQueryPlanSelector.java | 32 + .../ThreshholdPlanSelector.java | 240 ++ .../TupleExecutionPlanGenerator.java | 215 ++ .../IndexPlanValidator/TupleReArranger.java | 348 +++ .../IndexPlanValidator/TupleValidator.java | 34 + .../ValidIndexCombinationGenerator.java | 461 ++++ .../VarConstantIndexListPruner.java | 174 ++ .../org/apache/rya/indexing/IndexingExpr.java | 94 + .../rya/indexing/IndexingFunctionRegistry.java | 134 ++ .../apache/rya/indexing/IteratorFactory.java | 159 ++ .../java/org/apache/rya/indexing/KeyParts.java | 333 +++ .../java/org/apache/rya/indexing/Md5Hash.java | 44 + .../org/apache/rya/indexing/SearchFunction.java | 45 + .../rya/indexing/SearchFunctionFactory.java | 71 + .../rya/indexing/StatementConstraints.java | 73 + .../rya/indexing/StatementSerializer.java | 225 ++ .../apache/rya/indexing/TemporalIndexer.java | 166 ++ .../apache/rya/indexing/TemporalInstant.java | 83 + .../rya/indexing/TemporalInstantRfc3339.java | 219 ++ .../apache/rya/indexing/TemporalInterval.java | 181 ++ .../apache/rya/indexing/TemporalTupleSet.java | 287 +++ .../rya/indexing/accumulo/ConfigUtils.java | 418 ++++ .../accumulo/entity/AccumuloDocIdIndexer.java | 443 ++++ .../accumulo/entity/EntityCentricIndex.java | 327 +++ .../entity/EntityLocalityGroupSetter.java | 171 ++ .../accumulo/entity/EntityOptimizer.java | 434 ++++ .../accumulo/entity/EntityTupleSet.java | 263 +++ .../rya/indexing/accumulo/entity/StarQuery.java | 636 ++++++ .../freetext/AccumuloFreeTextIndexer.java | 790 +++++++ .../accumulo/freetext/ColumnPrefixes.java | 120 + .../accumulo/freetext/FreeTextTupleSet.java | 160 ++ .../accumulo/freetext/LuceneTokenizer.java | 57 + .../accumulo/freetext/SimpleTokenizer.java | 43 + .../indexing/accumulo/freetext/Tokenizer.java | 31 + .../freetext/iterators/AndingIterator.java | 563 +++++ .../freetext/iterators/BooleanTreeIterator.java | 322 +++ .../accumulo/freetext/query/ASTExpression.java | 63 + .../accumulo/freetext/query/ASTNodeUtils.java | 210 ++ .../accumulo/freetext/query/ASTSimpleNode.java | 917 ++++++++ .../accumulo/freetext/query/ASTTerm.java | 79 + .../freetext/query/JJTQueryParserState.java | 1024 +++++++++ .../indexing/accumulo/freetext/query/Node.java | 937 ++++++++ .../accumulo/freetext/query/ParseException.java | 1088 +++++++++ .../accumulo/freetext/query/QueryParser.java | 1293 +++++++++++ .../accumulo/freetext/query/QueryParser.jj | 176 ++ .../accumulo/freetext/query/QueryParser.jjt | 90 + .../freetext/query/QueryParserConstants.java | 960 ++++++++ .../freetext/query/QueryParserTokenManager.java | 1389 ++++++++++++ .../query/QueryParserTreeConstants.java | 920 ++++++++ .../freetext/query/SimpleCharStream.java | 1372 ++++++++++++ .../accumulo/freetext/query/SimpleNode.java | 980 ++++++++ .../indexing/accumulo/freetext/query/Token.java | 1032 +++++++++ .../accumulo/freetext/query/TokenMgrError.java | 1048 +++++++++ .../temporal/AccumuloTemporalIndexer.java | 945 ++++++++ .../external/PrecomputedJoinIndexer.java | 279 +++ .../external/PrecomputedJoinIndexerConfig.java | 122 + .../PrecomputedJoinStorageSupplier.java | 80 + .../PrecomputedJoinUpdaterSupplier.java | 78 + .../accumulo/AccumuloPcjStorageConfig.java | 58 + .../accumulo/AccumuloPcjStorageSupplier.java | 78 + .../indexing/external/fluo/FluoPcjUpdater.java | 89 + .../external/fluo/FluoPcjUpdaterConfig.java | 119 + .../external/fluo/FluoPcjUpdaterSupplier.java | 100 + .../rya/indexing/external/fluo/NoOpUpdater.java | 53 + .../external/fluo/NoOpUpdaterSupplier.java | 39 + .../fluo/PcjUpdaterSupplierFactory.java | 57 + .../external/tupleSet/AccumuloIndexSet.java | 604 +++++ .../external/tupleSet/ExternalTupleSet.java | 309 +++ .../external/tupleSet/ParsedQueryUtil.java | 60 + .../tupleSet/SimpleExternalTupleSet.java | 81 + .../indexing/mongodb/AbstractMongoIndexer.java | 192 ++ .../mongodb/IndexingMongoDBStorageStrategy.java | 57 + .../mongodb/freetext/MongoFreeTextIndexer.java | 58 + .../freetext/TextMongoDBStorageStrategy.java | 45 + .../mongodb/temporal/MongoTemporalIndexer.java | 150 ++ .../TemporalMongoDBStorageStrategy.java | 68 + .../pcj/matching/AbstractPCJMatcher.java | 126 ++ .../pcj/matching/AbstractQuerySegment.java | 122 + .../pcj/matching/FlattenedOptional.java | 331 +++ .../rya/indexing/pcj/matching/JoinSegment.java | 130 ++ .../pcj/matching/JoinSegmentPCJMatcher.java | 106 + .../pcj/matching/OptionalJoinSegment.java | 146 ++ .../matching/OptionalJoinSegmentPCJMatcher.java | 142 ++ .../rya/indexing/pcj/matching/PCJMatcher.java | 76 + .../pcj/matching/PCJMatcherFactory.java | 73 + .../pcj/matching/PCJNodeConsolidator.java | 628 ++++++ .../rya/indexing/pcj/matching/PCJOptimizer.java | 374 ++++ .../pcj/matching/PCJOptimizerUtilities.java | 377 ++++ .../pcj/matching/QueryNodesToTupleExpr.java | 194 ++ .../rya/indexing/pcj/matching/QuerySegment.java | 83 + .../pcj/matching/QueryVariableNormalizer.java | 1180 ++++++++++ .../pcj/matching/TopOfQueryFilterRelocator.java | 97 + .../rya/sail/config/RyaAccumuloSailConfig.java | 165 ++ .../rya/sail/config/RyaAccumuloSailFactory.java | 95 + .../apache/rya/sail/config/RyaSailFactory.java | 159 ++ .../DocumentIndexIntersectingIteratorTest.java | 1903 ---------------- .../accumulo/AccumuloBatchUpdatePCJIT.java | 153 -- .../client/accumulo/AccumuloCreatePCJIT.java | 161 -- .../client/accumulo/AccumuloDeletePCJIT.java | 141 -- .../accumulo/AccumuloGetInstanceDetailsIT.java | 142 -- .../api/client/accumulo/AccumuloInstallIT.java | 85 - .../accumulo/AccumuloInstanceExistsIT.java | 100 - .../accumulo/AccumuloListInstancesIT.java | 65 - .../mvm/rya/api/client/accumulo/FluoITBase.java | 312 --- .../GeneralizedExternalProcessorTest.java | 173 -- .../IndexPlanValidatorTest.java | 752 ------- .../IndexedExecutionPlanGeneratorTest.java | 368 --- .../ThreshholdPlanSelectorTest.java | 713 ------ .../TupleExecutionPlanGeneratorTest.java | 362 --- .../IndexPlanValidator/TupleReArrangerTest.java | 140 -- .../ValidIndexCombinationGeneratorTest.java | 533 ----- .../VarConstantIndexListPrunerTest.java | 296 --- .../accumulo/StatementSerializerTest.java | 106 - .../accumulo/entity/AccumuloDocIndexerTest.java | 2114 ------------------ .../accumulo/entity/EntityCentricIndexTest.java | 115 - .../accumulo/entity/EntityOptimizerTest.java | 1357 ----------- .../indexing/accumulo/entity/StarQueryTest.java | 290 --- .../freetext/AccumuloFreeTextIndexerTest.java | 268 --- .../freetext/query/QueryParserTest.java | 130 -- .../temporal/AccumuloTemporalIndexerTest.java | 1052 --------- .../accumulo/temporal/TemporalInstantTest.java | 97 - .../accumulo/temporal/TemporalIntervalTest.java | 179 -- .../AccumuloConstantPcjIntegrationTest.java | 414 ---- .../external/AccumuloPcjIntegrationTest.java | 1448 ------------ .../indexing/external/PCJOptionalTestIT.java | 324 --- .../external/PcjIntegrationTestingUtil.java | 413 ---- .../PrecompJoinOptimizerIntegrationTest.java | 505 ----- .../external/PrecompJoinOptimizerTest.java | 429 ---- .../external/PrecompJoinOptimizerTest2.java | 1131 ---------- .../PrecompJoinOptimizerVarToConstTest.java | 430 ---- .../PrecomputedJoinStorageSupplierTest.java | 79 - .../PrecomputedJoinUpdaterSupplierTest.java | 79 - .../AccumuloIndexSetColumnVisibilityTest.java | 251 --- .../external/tupleSet/AccumuloIndexSetTest.java | 678 ------ .../external/tupleSet/ParsedQueryUtilTest.java | 67 - .../tupleSet/QueryVariableNormalizerTest.java | 965 -------- .../tupleSet/SimpleExternalTupleSetTest.java | 173 -- .../VarConstQueryVariableNormalizerTest.java | 747 ------- .../mongo/MongoFreeTextIndexerTest.java | 207 -- .../mongo/MongoTemporalIndexerTest.java | 693 ------ .../pcj/matching/FlattenedOptionalTest.java | 150 -- .../pcj/matching/JoinSegmentPCJMatcherTest.java | 233 -- .../indexing/pcj/matching/JoinSegmentTest.java | 223 -- .../OptionalJoinSegmentPCJMatcherTest.java | 293 --- .../pcj/matching/OptionalJoinSegmentTest.java | 141 -- .../pcj/matching/PCJNodeConsolidatorTest.java | 476 ---- .../indexing/pcj/matching/PCJOptimizerTest.java | 538 ----- .../pcj/matching/PCJOptimizerUtilitesTest.java | 113 - .../sail/config/RyaAccumuloSailFactoryTest.java | 196 -- .../DocumentIndexIntersectingIteratorTest.java | 1903 ++++++++++++++++ .../accumulo/AccumuloBatchUpdatePCJIT.java | 153 ++ .../client/accumulo/AccumuloCreatePCJIT.java | 161 ++ .../client/accumulo/AccumuloDeletePCJIT.java | 141 ++ .../accumulo/AccumuloGetInstanceDetailsIT.java | 142 ++ .../api/client/accumulo/AccumuloInstallIT.java | 85 + .../accumulo/AccumuloInstanceExistsIT.java | 100 + .../accumulo/AccumuloListInstancesIT.java | 65 + .../rya/api/client/accumulo/FluoITBase.java | 312 +++ .../GeneralizedExternalProcessorTest.java | 173 ++ .../IndexPlanValidatorTest.java | 752 +++++++ .../IndexedExecutionPlanGeneratorTest.java | 368 +++ .../ThreshholdPlanSelectorTest.java | 713 ++++++ .../TupleExecutionPlanGeneratorTest.java | 362 +++ .../IndexPlanValidator/TupleReArrangerTest.java | 140 ++ .../ValidIndexCombinationGeneratorTest.java | 533 +++++ .../VarConstantIndexListPrunerTest.java | 296 +++ .../accumulo/StatementSerializerTest.java | 106 + .../accumulo/entity/AccumuloDocIndexerTest.java | 2114 ++++++++++++++++++ .../accumulo/entity/EntityCentricIndexTest.java | 115 + .../accumulo/entity/EntityOptimizerTest.java | 1357 +++++++++++ .../indexing/accumulo/entity/StarQueryTest.java | 290 +++ .../freetext/AccumuloFreeTextIndexerTest.java | 268 +++ .../freetext/query/QueryParserTest.java | 130 ++ .../temporal/AccumuloTemporalIndexerTest.java | 1052 +++++++++ .../accumulo/temporal/TemporalInstantTest.java | 97 + .../accumulo/temporal/TemporalIntervalTest.java | 179 ++ .../AccumuloConstantPcjIntegrationTest.java | 414 ++++ .../external/AccumuloPcjIntegrationTest.java | 1448 ++++++++++++ .../indexing/external/PCJOptionalTestIT.java | 324 +++ .../external/PcjIntegrationTestingUtil.java | 413 ++++ .../PrecompJoinOptimizerIntegrationTest.java | 505 +++++ .../external/PrecompJoinOptimizerTest.java | 429 ++++ .../external/PrecompJoinOptimizerTest2.java | 1131 ++++++++++ .../PrecompJoinOptimizerVarToConstTest.java | 430 ++++ .../PrecomputedJoinStorageSupplierTest.java | 79 + .../PrecomputedJoinUpdaterSupplierTest.java | 79 + .../AccumuloIndexSetColumnVisibilityTest.java | 251 +++ .../external/tupleSet/AccumuloIndexSetTest.java | 678 ++++++ .../external/tupleSet/ParsedQueryUtilTest.java | 67 + .../tupleSet/QueryVariableNormalizerTest.java | 965 ++++++++ .../tupleSet/SimpleExternalTupleSetTest.java | 173 ++ .../VarConstQueryVariableNormalizerTest.java | 747 +++++++ .../mongo/MongoFreeTextIndexerTest.java | 207 ++ .../mongo/MongoTemporalIndexerTest.java | 693 ++++++ .../pcj/matching/FlattenedOptionalTest.java | 150 ++ .../pcj/matching/JoinSegmentPCJMatcherTest.java | 233 ++ .../indexing/pcj/matching/JoinSegmentTest.java | 223 ++ .../OptionalJoinSegmentPCJMatcherTest.java | 293 +++ .../pcj/matching/OptionalJoinSegmentTest.java | 141 ++ .../pcj/matching/PCJNodeConsolidatorTest.java | 476 ++++ .../indexing/pcj/matching/PCJOptimizerTest.java | 538 +++++ .../pcj/matching/PCJOptimizerUtilitesTest.java | 113 + .../sail/config/RyaAccumuloSailFactoryTest.java | 196 ++ .../java/mvm/rya/shell/RyaAdminCommands.java | 278 --- .../java/mvm/rya/shell/RyaBannerProvider.java | 97 - .../mvm/rya/shell/RyaConnectionCommands.java | 167 -- .../java/mvm/rya/shell/RyaPromptProvider.java | 62 - .../java/mvm/rya/shell/SharedShellState.java | 338 --- .../mvm/rya/shell/util/ConnectorFactory.java | 66 - .../java/mvm/rya/shell/util/InstallPrompt.java | 139 -- .../rya/shell/util/InstanceNamesFormatter.java | 77 - .../java/mvm/rya/shell/util/JLinePrompt.java | 200 -- .../java/mvm/rya/shell/util/PasswordPrompt.java | 71 - .../mvm/rya/shell/util/RyaDetailsFormatter.java | 117 - .../java/mvm/rya/shell/util/SparqlPrompt.java | 55 - .../org/apache/rya/shell/RyaAdminCommands.java | 278 +++ .../org/apache/rya/shell/RyaBannerProvider.java | 97 + .../apache/rya/shell/RyaConnectionCommands.java | 167 ++ .../org/apache/rya/shell/RyaPromptProvider.java | 62 + .../org/apache/rya/shell/SharedShellState.java | 338 +++ .../apache/rya/shell/util/ConnectorFactory.java | 66 + .../apache/rya/shell/util/InstallPrompt.java | 139 ++ .../rya/shell/util/InstanceNamesFormatter.java | 77 + .../org/apache/rya/shell/util/JLinePrompt.java | 200 ++ .../apache/rya/shell/util/PasswordPrompt.java | 71 + .../rya/shell/util/RyaDetailsFormatter.java | 117 + .../org/apache/rya/shell/util/SparqlPrompt.java | 55 + .../mvm/rya/shell/RyaAdminCommandsTest.java | 294 --- .../mvm/rya/shell/RyaConnectionCommandsIT.java | 269 --- .../mvm/rya/shell/RyaPromptProviderTest.java | 80 - .../test/java/mvm/rya/shell/RyaShellITBase.java | 103 - .../mvm/rya/shell/SharedShellStateTest.java | 167 -- .../mvm/rya/shell/util/ConnectorFactoryIT.java | 57 - .../shell/util/InstanceNamesFormatterTest.java | 81 - .../rya/shell/util/RyaDetailsFormatterTest.java | 109 - .../apache/rya/shell/RyaAdminCommandsTest.java | 294 +++ .../rya/shell/RyaConnectionCommandsIT.java | 269 +++ .../apache/rya/shell/RyaPromptProviderTest.java | 80 + .../org/apache/rya/shell/RyaShellITBase.java | 103 + .../apache/rya/shell/SharedShellStateTest.java | 167 ++ .../rya/shell/util/ConnectorFactoryIT.java | 57 + .../shell/util/InstanceNamesFormatterTest.java | 81 + .../rya/shell/util/RyaDetailsFormatterTest.java | 109 + .../GeoEnabledFilterFunctionOptimizer.java | 353 --- .../main/java/mvm/rya/indexing/GeoIndexer.java | 185 -- .../mvm/rya/indexing/GeoRyaSailFactory.java | 146 -- .../mvm/rya/indexing/OptionalConfigUtils.java | 141 -- .../accumulo/geo/GeoMesaGeoIndexer.java | 518 ----- .../indexing/accumulo/geo/GeoParseUtils.java | 119 - .../rya/indexing/accumulo/geo/GeoTupleSet.java | 363 --- .../mongodb/geo/GeoMongoDBStorageStrategy.java | 143 -- .../indexing/mongodb/geo/MongoGeoIndexer.java | 112 - .../indexing/mongodb/geo/MongoGeoTupleSet.java | 360 --- .../GeoEnabledFilterFunctionOptimizer.java | 353 +++ .../org/apache/rya/indexing/GeoIndexer.java | 185 ++ .../apache/rya/indexing/GeoRyaSailFactory.java | 146 ++ .../rya/indexing/OptionalConfigUtils.java | 141 ++ .../accumulo/geo/GeoMesaGeoIndexer.java | 518 +++++ .../indexing/accumulo/geo/GeoParseUtils.java | 119 + .../rya/indexing/accumulo/geo/GeoTupleSet.java | 363 +++ .../mongodb/geo/GeoMongoDBStorageStrategy.java | 143 ++ .../indexing/mongodb/geo/MongoGeoIndexer.java | 112 + .../indexing/mongodb/geo/MongoGeoTupleSet.java | 360 +++ .../indexing/accumulo/geo/GeoIndexerSfTest.java | 514 ----- .../indexing/accumulo/geo/GeoIndexerTest.java | 401 ---- .../indexing/mongo/MongoGeoIndexerSfTest.java | 304 --- .../rya/indexing/mongo/MongoGeoIndexerTest.java | 396 ---- .../indexing/accumulo/geo/GeoIndexerSfTest.java | 514 +++++ .../indexing/accumulo/geo/GeoIndexerTest.java | 401 ++++ .../indexing/mongo/MongoGeoIndexerSfTest.java | 304 +++ .../rya/indexing/mongo/MongoGeoIndexerTest.java | 396 ++++ .../AbstractDualInstanceAccumuloMRTool.java | 64 - .../mvm/rya/accumulo/mr/merge/CopyTool.java | 1016 --------- .../mvm/rya/accumulo/mr/merge/MergeTool.java | 554 ----- .../accumulo/mr/merge/common/InstanceType.java | 56 - .../mr/merge/gui/DateTimePickerDialog.java | 173 -- .../merge/mappers/AccumuloCopyToolMapper.java | 52 - .../mr/merge/mappers/AccumuloRyaRuleMapper.java | 69 - .../mr/merge/mappers/BaseCopyToolMapper.java | 260 --- .../mr/merge/mappers/BaseRuleMapper.java | 222 -- .../mr/merge/mappers/FileCopyToolMapper.java | 81 - .../mr/merge/mappers/MergeToolMapper.java | 575 ----- .../mr/merge/mappers/RowRuleMapper.java | 200 -- .../mr/merge/reducers/MultipleFileReducer.java | 64 - .../mr/merge/util/AccumuloInstanceDriver.java | 577 ----- .../mr/merge/util/AccumuloQueryRuleset.java | 203 -- .../mr/merge/util/AccumuloRyaUtils.java | 667 ------ .../rya/accumulo/mr/merge/util/CopyRule.java | 383 ---- .../rya/accumulo/mr/merge/util/GroupedRow.java | 182 -- .../accumulo/mr/merge/util/QueryRuleset.java | 549 ----- .../rya/accumulo/mr/merge/util/TimeUtils.java | 349 --- .../accumulo/mr/merge/util/ToolConfigUtils.java | 136 -- .../AbstractDualInstanceAccumuloMRTool.java | 64 + .../apache/rya/accumulo/mr/merge/CopyTool.java | 1016 +++++++++ .../apache/rya/accumulo/mr/merge/MergeTool.java | 554 +++++ .../accumulo/mr/merge/common/InstanceType.java | 56 + .../mr/merge/gui/DateTimePickerDialog.java | 173 ++ .../merge/mappers/AccumuloCopyToolMapper.java | 52 + .../mr/merge/mappers/AccumuloRyaRuleMapper.java | 69 + .../mr/merge/mappers/BaseCopyToolMapper.java | 260 +++ .../mr/merge/mappers/BaseRuleMapper.java | 222 ++ .../mr/merge/mappers/FileCopyToolMapper.java | 81 + .../mr/merge/mappers/MergeToolMapper.java | 575 +++++ .../mr/merge/mappers/RowRuleMapper.java | 200 ++ .../mr/merge/reducers/MultipleFileReducer.java | 64 + .../mr/merge/util/AccumuloInstanceDriver.java | 577 +++++ .../mr/merge/util/AccumuloQueryRuleset.java | 203 ++ .../mr/merge/util/AccumuloRyaUtils.java | 667 ++++++ .../rya/accumulo/mr/merge/util/CopyRule.java | 383 ++++ .../rya/accumulo/mr/merge/util/GroupedRow.java | 182 ++ .../accumulo/mr/merge/util/QueryRuleset.java | 549 +++++ .../rya/accumulo/mr/merge/util/TimeUtils.java | 349 +++ .../accumulo/mr/merge/util/ToolConfigUtils.java | 136 ++ .../mvm/rya/accumulo/mr/merge/CopyToolTest.java | 359 --- .../rya/accumulo/mr/merge/MergeToolTest.java | 495 ---- .../rya/accumulo/mr/merge/RulesetCopyIT.java | 561 ----- .../accumulo/mr/merge/demo/CopyToolDemo.java | 314 --- .../accumulo/mr/merge/demo/MergeToolDemo.java | 323 --- .../mr/merge/demo/util/DemoUtilities.java | 128 -- .../driver/AccumuloDualInstanceDriver.java | 612 ----- .../merge/driver/MiniAccumuloClusterDriver.java | 181 -- .../rya/accumulo/mr/merge/util/TestUtils.java | 250 --- .../rya/accumulo/mr/merge/CopyToolTest.java | 359 +++ .../rya/accumulo/mr/merge/MergeToolTest.java | 495 ++++ .../rya/accumulo/mr/merge/RulesetCopyIT.java | 561 +++++ .../accumulo/mr/merge/demo/CopyToolDemo.java | 314 +++ .../accumulo/mr/merge/demo/MergeToolDemo.java | 323 +++ .../mr/merge/demo/util/DemoUtilities.java | 128 ++ .../driver/AccumuloDualInstanceDriver.java | 612 +++++ .../merge/driver/MiniAccumuloClusterDriver.java | 181 ++ .../rya/accumulo/mr/merge/util/TestUtils.java | 250 +++ .../mvm/rya/prospector/domain/IndexEntry.groovy | 76 - .../domain/IntermediateProspect.groovy | 70 - .../rya/prospector/domain/TripleValueType.java | 26 - .../mvm/rya/prospector/mr/Prospector.groovy | 108 - .../rya/prospector/mr/ProspectorCombiner.groovy | 61 - .../rya/prospector/mr/ProspectorMapper.groovy | 75 - .../rya/prospector/mr/ProspectorReducer.groovy | 57 - .../rya/prospector/plans/IndexWorkPlan.groovy | 51 - .../plans/IndexWorkPlanManager.groovy | 29 - .../rya/prospector/plans/impl/CountPlan.groovy | 220 -- .../ServicesBackedIndexWorkPlanManager.groovy | 38 - .../prospector/service/ProspectorService.groovy | 126 -- .../ProspectorServiceEvalStatsDAO.groovy | 122 - .../mvm/rya/prospector/utils/CustomEntry.groovy | 52 - .../prospector/utils/ProspectorConstants.groovy | 41 - .../rya/prospector/utils/ProspectorUtils.groovy | 138 -- .../rya/prospector/domain/IndexEntry.groovy | 76 + .../domain/IntermediateProspect.groovy | 70 + .../rya/prospector/domain/TripleValueType.java | 26 + .../apache/rya/prospector/mr/Prospector.groovy | 108 + .../rya/prospector/mr/ProspectorCombiner.groovy | 61 + .../rya/prospector/mr/ProspectorMapper.groovy | 75 + .../rya/prospector/mr/ProspectorReducer.groovy | 57 + .../rya/prospector/plans/IndexWorkPlan.groovy | 51 + .../plans/IndexWorkPlanManager.groovy | 29 + .../rya/prospector/plans/impl/CountPlan.groovy | 220 ++ .../ServicesBackedIndexWorkPlanManager.groovy | 38 + .../prospector/service/ProspectorService.groovy | 126 ++ .../ProspectorServiceEvalStatsDAO.groovy | 122 + .../rya/prospector/utils/CustomEntry.groovy | 52 + .../prospector/utils/ProspectorConstants.groovy | 41 + .../rya/prospector/utils/ProspectorUtils.groovy | 138 ++ .../joinselect/AccumuloSelectivityEvalDAO.java | 640 ------ .../mvm/rya/joinselect/CardinalityCalcUtil.java | 267 --- .../mvm/rya/joinselect/mr/FullTableSize.java | 129 -- .../rya/joinselect/mr/JoinSelectAggregate.java | 272 --- .../mvm/rya/joinselect/mr/JoinSelectDriver.java | 60 - .../joinselect/mr/JoinSelectProspectOutput.java | 124 - .../joinselect/mr/JoinSelectSpoTableOutput.java | 126 -- .../joinselect/mr/JoinSelectStatisticsSum.java | 220 -- .../mvm/rya/joinselect/mr/utils/CardList.java | 209 -- .../joinselect/mr/utils/CardinalityType.java | 149 -- .../rya/joinselect/mr/utils/CompositeType.java | 122 - .../mr/utils/JoinSelectConstants.java | 46 - .../mr/utils/JoinSelectStatsUtil.java | 183 -- .../mvm/rya/joinselect/mr/utils/TripleCard.java | 145 -- .../rya/joinselect/mr/utils/TripleEntry.java | 180 -- .../joinselect/AccumuloSelectivityEvalDAO.java | 640 ++++++ .../rya/joinselect/CardinalityCalcUtil.java | 267 +++ .../apache/rya/joinselect/mr/FullTableSize.java | 129 ++ .../rya/joinselect/mr/JoinSelectAggregate.java | 272 +++ .../rya/joinselect/mr/JoinSelectDriver.java | 60 + .../joinselect/mr/JoinSelectProspectOutput.java | 124 + .../joinselect/mr/JoinSelectSpoTableOutput.java | 126 ++ .../joinselect/mr/JoinSelectStatisticsSum.java | 220 ++ .../rya/joinselect/mr/utils/CardList.java | 209 ++ .../joinselect/mr/utils/CardinalityType.java | 149 ++ .../rya/joinselect/mr/utils/CompositeType.java | 122 + .../mr/utils/JoinSelectConstants.java | 46 + .../mr/utils/JoinSelectStatsUtil.java | 183 ++ .../rya/joinselect/mr/utils/TripleCard.java | 145 ++ .../rya/joinselect/mr/utils/TripleEntry.java | 180 ++ .../mvm.rya.prospector.plans.IndexWorkPlan | 1 - ...rg.apache.rya.prospector.plans.IndexWorkPlan | 1 + .../mvm/rya/prospector/mr/ProspectorTest.groovy | 178 -- .../ProspectorServiceEvalStatsDAOTest.groovy | 182 -- .../rya/prospector/mr/ProspectorTest.groovy | 178 ++ .../ProspectorServiceEvalStatsDAOTest.groovy | 182 ++ .../AccumuloSelectivityEvalDAOTest.java | 592 ----- .../mr/CardinalityIdentityReducerTest.java | 141 -- .../joinselect/mr/CardinalityMapperTest.java | 76 - .../rya/joinselect/mr/FullTableSizeTest.java | 64 - .../mvm/rya/joinselect/mr/JoinReducerTest.java | 124 - .../rya/joinselect/mr/JoinSelectMapperTest.java | 94 - .../mr/JoinSelectProspectOutputTest.java | 89 - .../mr/JoinSelectStatisticsSumTest.java | 60 - .../joinselect/mr/JoinSelectStatisticsTest.java | 872 -------- .../AccumuloSelectivityEvalDAOTest.java | 592 +++++ .../mr/CardinalityIdentityReducerTest.java | 141 ++ .../joinselect/mr/CardinalityMapperTest.java | 76 + .../rya/joinselect/mr/FullTableSizeTest.java | 64 + .../rya/joinselect/mr/JoinReducerTest.java | 124 + .../rya/joinselect/mr/JoinSelectMapperTest.java | 94 + .../mr/JoinSelectProspectOutputTest.java | 89 + .../mr/JoinSelectStatisticsSumTest.java | 60 + .../joinselect/mr/JoinSelectStatisticsTest.java | 872 ++++++++ .../mvm/rya/reasoning/AbstractReasoner.java | 233 -- .../main/java/mvm/rya/reasoning/Derivation.java | 324 --- .../src/main/java/mvm/rya/reasoning/Fact.java | 514 ----- .../java/mvm/rya/reasoning/LocalReasoner.java | 667 ------ .../src/main/java/mvm/rya/reasoning/OWL2.java | 38 - .../main/java/mvm/rya/reasoning/OwlClass.java | 489 ---- .../java/mvm/rya/reasoning/OwlProperty.java | 309 --- .../main/java/mvm/rya/reasoning/OwlRule.java | 78 - .../src/main/java/mvm/rya/reasoning/Schema.java | 538 ----- .../java/mvm/rya/reasoning/TypeReasoner.java | 234 -- .../rya/reasoning/mr/AbstractReasoningTool.java | 492 ---- .../mvm/rya/reasoning/mr/ConformanceTest.java | 436 ---- .../rya/reasoning/mr/DuplicateElimination.java | 225 -- .../java/mvm/rya/reasoning/mr/ForwardChain.java | 278 --- .../mvm/rya/reasoning/mr/MRReasoningUtils.java | 336 --- .../java/mvm/rya/reasoning/mr/OutputTool.java | 110 - .../mvm/rya/reasoning/mr/ReasoningDriver.java | 154 -- .../mvm/rya/reasoning/mr/ResourceWritable.java | 145 -- .../mvm/rya/reasoning/mr/RunStatistics.java | 253 --- .../java/mvm/rya/reasoning/mr/SchemaFilter.java | 165 -- .../mvm/rya/reasoning/mr/SchemaWritable.java | 76 - .../apache/rya/reasoning/AbstractReasoner.java | 233 ++ .../org/apache/rya/reasoning/Derivation.java | 324 +++ .../java/org/apache/rya/reasoning/Fact.java | 514 +++++ .../org/apache/rya/reasoning/LocalReasoner.java | 667 ++++++ .../java/org/apache/rya/reasoning/OWL2.java | 38 + .../java/org/apache/rya/reasoning/OwlClass.java | 489 ++++ .../org/apache/rya/reasoning/OwlProperty.java | 309 +++ .../java/org/apache/rya/reasoning/OwlRule.java | 78 + .../java/org/apache/rya/reasoning/Schema.java | 538 +++++ .../org/apache/rya/reasoning/TypeReasoner.java | 234 ++ .../rya/reasoning/mr/AbstractReasoningTool.java | 492 ++++ .../rya/reasoning/mr/ConformanceTest.java | 436 ++++ .../rya/reasoning/mr/DuplicateElimination.java | 225 ++ .../apache/rya/reasoning/mr/ForwardChain.java | 278 +++ .../rya/reasoning/mr/MRReasoningUtils.java | 336 +++ .../org/apache/rya/reasoning/mr/OutputTool.java | 110 + .../rya/reasoning/mr/ReasoningDriver.java | 154 ++ .../rya/reasoning/mr/ResourceWritable.java | 145 ++ .../apache/rya/reasoning/mr/RunStatistics.java | 253 +++ .../apache/rya/reasoning/mr/SchemaFilter.java | 165 ++ .../apache/rya/reasoning/mr/SchemaWritable.java | 76 + .../mvm/rya/reasoning/LocalReasonerTest.java | 512 ----- .../mvm/rya/reasoning/ReasonerFactTest.java | 277 --- .../mvm/rya/reasoning/SchemaReasoningTest.java | 330 --- .../test/java/mvm/rya/reasoning/SchemaTest.java | 284 --- .../test/java/mvm/rya/reasoning/TestUtils.java | 79 - .../reasoning/mr/DuplicateEliminationTest.java | 200 -- .../mvm/rya/reasoning/mr/ForwardChainTest.java | 250 --- .../apache/rya/reasoning/LocalReasonerTest.java | 512 +++++ .../apache/rya/reasoning/ReasonerFactTest.java | 277 +++ .../rya/reasoning/SchemaReasoningTest.java | 330 +++ .../org/apache/rya/reasoning/SchemaTest.java | 284 +++ .../org/apache/rya/reasoning/TestUtils.java | 79 + .../reasoning/mr/DuplicateEliminationTest.java | 200 ++ .../rya/reasoning/mr/ForwardChainTest.java | 250 +++ .../rya/accumulo/mr/AbstractAccumuloMRTool.java | 304 --- .../mr/AccumuloHDFSFileInputFormat.java | 161 -- .../main/java/mvm/rya/accumulo/mr/MRUtils.java | 317 --- .../mvm/rya/accumulo/mr/RdfFileInputFormat.java | 443 ---- .../mvm/rya/accumulo/mr/RyaInputFormat.java | 130 -- .../mvm/rya/accumulo/mr/RyaOutputFormat.java | 562 ----- .../rya/accumulo/mr/RyaStatementWritable.java | 256 --- .../accumulo/mr/examples/TextOutputExample.java | 196 -- .../accumulo/mr/tools/AccumuloRdfCountTool.java | 258 --- .../rya/accumulo/mr/tools/RdfFileInputTool.java | 91 - .../rya/accumulo/mr/tools/Upgrade322Tool.java | 241 -- .../rya/accumulo/mr/AbstractAccumuloMRTool.java | 304 +++ .../mr/AccumuloHDFSFileInputFormat.java | 161 ++ .../org/apache/rya/accumulo/mr/MRUtils.java | 317 +++ .../rya/accumulo/mr/RdfFileInputFormat.java | 443 ++++ .../apache/rya/accumulo/mr/RyaInputFormat.java | 130 ++ .../apache/rya/accumulo/mr/RyaOutputFormat.java | 562 +++++ .../rya/accumulo/mr/RyaStatementWritable.java | 256 +++ .../accumulo/mr/examples/TextOutputExample.java | 196 ++ .../accumulo/mr/tools/AccumuloRdfCountTool.java | 258 +++ .../rya/accumulo/mr/tools/RdfFileInputTool.java | 91 + .../rya/accumulo/mr/tools/Upgrade322Tool.java | 241 ++ .../rya/accumulo/mr/RdfFileInputFormatTest.java | 180 -- .../mvm/rya/accumulo/mr/RyaInputFormatTest.java | 156 -- .../rya/accumulo/mr/RyaOutputFormatTest.java | 288 --- .../accumulo/mr/RyaStatementWritableTest.java | 146 -- .../java/mvm/rya/accumulo/mr/TestUtils.java | 113 - .../mr/tools/AccumuloRdfCountToolTest.java | 283 --- .../accumulo/mr/tools/RdfFileInputToolTest.java | 131 -- .../accumulo/mr/tools/Upgrade322ToolTest.java | 275 --- .../tools/UpgradeObjectSerializationTest.java | 119 - .../rya/accumulo/mr/RdfFileInputFormatTest.java | 180 ++ .../rya/accumulo/mr/RyaInputFormatTest.java | 156 ++ .../rya/accumulo/mr/RyaOutputFormatTest.java | 288 +++ .../accumulo/mr/RyaStatementWritableTest.java | 146 ++ .../org/apache/rya/accumulo/mr/TestUtils.java | 113 + .../mr/tools/AccumuloRdfCountToolTest.java | 283 +++ .../accumulo/mr/tools/RdfFileInputToolTest.java | 131 ++ .../accumulo/mr/tools/Upgrade322ToolTest.java | 275 +++ .../tools/UpgradeObjectSerializationTest.java | 119 + .../mvm/rya/alx/command/AbstractRyaCommand.java | 58 - .../alx/command/GetStatementsRyaCommand.java | 80 - .../mvm/rya/alx/command/InfoRyaCommand.java | 46 - .../rya/alx/command/AbstractRyaCommand.java | 58 + .../alx/command/GetStatementsRyaCommand.java | 80 + .../apache/rya/alx/command/InfoRyaCommand.java | 46 + .../mvm/rya/alx/util/ConfigurationFactory.java | 53 - .../rya/alx/util/ConfigurationFactory.java | 53 + .../mvm/rya/camel/cbsail/CbSailComponent.java | 59 - .../mvm/rya/camel/cbsail/CbSailEndpoint.java | 119 - .../mvm/rya/camel/cbsail/CbSailProducer.java | 175 -- .../rya/camel/cbsail/CbSailComponent.java | 59 + .../apache/rya/camel/cbsail/CbSailEndpoint.java | 119 + .../apache/rya/camel/cbsail/CbSailProducer.java | 175 ++ .../rya/camel/cbsail/CbSailIntegrationTest.java | 117 - .../mvm/rya/camel/cbsail/CbSailPojoMain.java | 45 - .../java/mvm/rya/camel/cbsail/CbSailTest.java | 205 -- .../rya/camel/cbsail/CbSailIntegrationTest.java | 117 + .../apache/rya/camel/cbsail/CbSailPojoMain.java | 45 + .../org/apache/rya/camel/cbsail/CbSailTest.java | 205 ++ .../mvm/rya/accumulo/pig/AccumuloStorage.java | 383 ---- .../mvm/rya/accumulo/pig/IndexWritingTool.java | 348 --- .../rya/accumulo/pig/SparqlQueryPigEngine.java | 268 --- .../pig/SparqlToPigTransformVisitor.java | 345 --- .../accumulo/pig/StatementPatternStorage.java | 307 --- .../pig/optimizer/SimilarVarJoinOptimizer.java | 210 -- .../rya/accumulo/pig/AccumuloStorage.java | 383 ++++ .../rya/accumulo/pig/IndexWritingTool.java | 348 +++ .../rya/accumulo/pig/SparqlQueryPigEngine.java | 268 +++ .../pig/SparqlToPigTransformVisitor.java | 345 +++ .../accumulo/pig/StatementPatternStorage.java | 307 +++ .../pig/optimizer/SimilarVarJoinOptimizer.java | 210 ++ .../rya/accumulo/pig/AccumuloStorageTest.java | 284 --- .../rya/accumulo/pig/IndexWritingToolTest.java | 326 --- .../accumulo/pig/SparqlQueryPigEngineTest.java | 76 - .../pig/SparqlToPigTransformVisitorTest.java | 402 ---- .../pig/StatementPatternStorageTest.java | 185 -- .../rya/accumulo/pig/AccumuloStorageTest.java | 284 +++ .../rya/accumulo/pig/IndexWritingToolTest.java | 326 +++ .../accumulo/pig/SparqlQueryPigEngineTest.java | 76 + .../pig/SparqlToPigTransformVisitorTest.java | 402 ++++ .../pig/StatementPatternStorageTest.java | 185 ++ .../rya/rdftriplestore/RdfCloudTripleStore.java | 173 -- .../RdfCloudTripleStoreConnection.java | 625 ------ .../rya/rdftriplestore/RyaSailRepository.java | 53 - .../RyaSailRepositoryConnection.java | 109 - .../evaluation/ExternalBatchingIterator.java | 33 - .../ExternalMultipleBindingSetsIterator.java | 109 - .../evaluation/FilterRangeVisitor.java | 97 - .../evaluation/MultipleBindingSetsIterator.java | 108 - .../ParallelEvaluationStrategyImpl.java | 281 --- .../evaluation/ParallelJoinIterator.java | 139 -- .../evaluation/PushJoinDownVisitor.java | 57 - .../evaluation/QueryJoinOptimizer.java | 284 --- .../evaluation/QueryJoinSelectOptimizer.java | 260 --- ...RdfCloudTripleStoreEvaluationStatistics.java | 281 --- ...pleStoreSelectivityEvaluationStatistics.java | 128 -- .../evaluation/ReorderJoinVisitor.java | 70 - .../evaluation/SeparateFilterJoinsVisitor.java | 55 - .../inference/AbstractInferVisitor.java | 108 - .../rdftriplestore/inference/DoNotExpandSP.java | 51 - .../inference/InferConstants.java | 34 - .../rya/rdftriplestore/inference/InferJoin.java | 50 - .../rdftriplestore/inference/InferUnion.java | 48 - .../inference/InferenceEngine.java | 586 ----- .../inference/InferenceEngineException.java | 43 - .../inference/InverseOfVisitor.java | 80 - .../rdftriplestore/inference/InverseURI.java | 80 - .../inference/PropertyChainVisitor.java | 114 - .../rdftriplestore/inference/SameAsVisitor.java | 187 -- .../inference/SubClassOfVisitor.java | 105 - .../inference/SubPropertyOfVisitor.java | 118 - .../inference/SymmetricPropertyVisitor.java | 78 - .../inference/TransitivePropertyVisitor.java | 69 - .../namespace/NamespaceManager.java | 167 -- .../utils/CombineContextsRdfInserter.java | 165 -- .../rdftriplestore/utils/DefaultStatistics.java | 58 - .../utils/FixedStatementPattern.java | 59 - .../utils/TransitivePropertySP.java | 52 - .../rya/rdftriplestore/RdfCloudTripleStore.java | 173 ++ .../RdfCloudTripleStoreConnection.java | 625 ++++++ .../rya/rdftriplestore/RyaSailRepository.java | 53 + .../RyaSailRepositoryConnection.java | 109 + .../evaluation/ExternalBatchingIterator.java | 33 + .../ExternalMultipleBindingSetsIterator.java | 109 + .../evaluation/FilterRangeVisitor.java | 97 + .../evaluation/MultipleBindingSetsIterator.java | 108 + .../ParallelEvaluationStrategyImpl.java | 281 +++ .../evaluation/ParallelJoinIterator.java | 139 ++ .../evaluation/PushJoinDownVisitor.java | 57 + .../evaluation/QueryJoinOptimizer.java | 284 +++ .../evaluation/QueryJoinSelectOptimizer.java | 260 +++ ...RdfCloudTripleStoreEvaluationStatistics.java | 281 +++ ...pleStoreSelectivityEvaluationStatistics.java | 128 ++ .../evaluation/ReorderJoinVisitor.java | 70 + .../evaluation/SeparateFilterJoinsVisitor.java | 55 + .../inference/AbstractInferVisitor.java | 108 + .../rdftriplestore/inference/DoNotExpandSP.java | 51 + .../inference/InferConstants.java | 34 + .../rya/rdftriplestore/inference/InferJoin.java | 50 + .../rdftriplestore/inference/InferUnion.java | 48 + .../inference/InferenceEngine.java | 586 +++++ .../inference/InferenceEngineException.java | 43 + .../inference/InverseOfVisitor.java | 80 + .../rdftriplestore/inference/InverseURI.java | 80 + .../inference/PropertyChainVisitor.java | 114 + .../rdftriplestore/inference/SameAsVisitor.java | 187 ++ .../inference/SubClassOfVisitor.java | 105 + .../inference/SubPropertyOfVisitor.java | 118 + .../inference/SymmetricPropertyVisitor.java | 78 + .../inference/TransitivePropertyVisitor.java | 69 + .../namespace/NamespaceManager.java | 167 ++ .../utils/CombineContextsRdfInserter.java | 165 ++ .../rdftriplestore/utils/DefaultStatistics.java | 58 + .../utils/FixedStatementPattern.java | 59 + .../utils/TransitivePropertySP.java | 52 + .../java/mvm/rya/ArbitraryLengthQueryTest.java | 500 ----- sail/src/test/java/mvm/rya/HashJoinTest.java | 374 ---- .../test/java/mvm/rya/IterativeJoinTest.java | 365 --- sail/src/test/java/mvm/rya/MergeJoinTest.java | 370 --- .../rya/RdfCloudTripleStoreConnectionTest.java | 1472 ------------ .../java/mvm/rya/RdfCloudTripleStoreTest.java | 699 ------ .../mvm/rya/RdfCloudTripleStoreUtilsTest.java | 86 - .../QueryJoinSelectOptimizerTest.java | 992 -------- ...toreSelectivityEvaluationStatisticsTest.java | 304 --- .../inference/PropertyChainTest.java | 140 -- .../rya/triplestore/inference/SameAsTest.java | 115 - .../apache/rya/ArbitraryLengthQueryTest.java | 500 +++++ .../test/java/org/apache/rya/HashJoinTest.java | 374 ++++ .../java/org/apache/rya/IterativeJoinTest.java | 365 +++ .../test/java/org/apache/rya/MergeJoinTest.java | 370 +++ .../rya/RdfCloudTripleStoreConnectionTest.java | 1472 ++++++++++++ .../org/apache/rya/RdfCloudTripleStoreTest.java | 699 ++++++ .../rya/RdfCloudTripleStoreUtilsTest.java | 86 + .../QueryJoinSelectOptimizerTest.java | 992 ++++++++ ...toreSelectivityEvaluationStatisticsTest.java | 304 +++ .../inference/PropertyChainTest.java | 140 ++ .../rya/triplestore/inference/SameAsTest.java | 115 + .../cloudbase/sail/AbstractRDFWebServlet.java | 111 - .../web/cloudbase/sail/DeleteDataServlet.java | 66 - .../rdf/web/cloudbase/sail/LoadDataServlet.java | 76 - .../web/cloudbase/sail/QueryDataServlet.java | 185 -- .../cloudbase/sail/QuerySerqlDataServlet.java | 136 -- .../rdf/web/cloudbase/sail/RDFWebConstants.java | 35 - .../mvm/cloud/rdf/web/sail/RdfController.java | 349 --- .../mvm/cloud/rdf/web/sail/ResultFormat.java | 27 - .../rdf/web/sail/SecurityProviderImpl.java | 34 - .../cloudbase/sail/AbstractRDFWebServlet.java | 111 + .../web/cloudbase/sail/DeleteDataServlet.java | 66 + .../rdf/web/cloudbase/sail/LoadDataServlet.java | 76 + .../web/cloudbase/sail/QueryDataServlet.java | 185 ++ .../cloudbase/sail/QuerySerqlDataServlet.java | 136 ++ .../rdf/web/cloudbase/sail/RDFWebConstants.java | 35 + .../cloud/rdf/web/sail/RdfController.java | 349 +++ .../apache/cloud/rdf/web/sail/ResultFormat.java | 27 + .../rdf/web/sail/SecurityProviderImpl.java | 34 + .../cloudbase/sail/DeleteDataServletRun.java | 476 ---- .../web/cloudbase/sail/LoadDataServletRun.java | 66 - .../web/cloudbase/sail/QueryDataServletRun.java | 467 ---- .../rdf/web/sail/RdfControllerAccumuloTest.java | 219 -- .../cloud/rdf/web/sail/RdfControllerTest.java | 160 -- .../cloudbase/sail/DeleteDataServletRun.java | 476 ++++ .../web/cloudbase/sail/LoadDataServletRun.java | 66 + .../web/cloudbase/sail/QueryDataServletRun.java | 467 ++++ .../rdf/web/sail/RdfControllerAccumuloTest.java | 219 ++ .../cloud/rdf/web/sail/RdfControllerTest.java | 160 ++ 1192 files changed, 132476 insertions(+), 132476 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/44a2dcf0/common/rya.api/src/main/java/mvm/rya/api/InvalidValueTypeMarkerRuntimeException.java ---------------------------------------------------------------------- diff --git a/common/rya.api/src/main/java/mvm/rya/api/InvalidValueTypeMarkerRuntimeException.java b/common/rya.api/src/main/java/mvm/rya/api/InvalidValueTypeMarkerRuntimeException.java deleted file mode 100644 index eea50f4..0000000 --- a/common/rya.api/src/main/java/mvm/rya/api/InvalidValueTypeMarkerRuntimeException.java +++ /dev/null @@ -1,55 +0,0 @@ -package mvm.rya.api; - -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, - * software distributed under the License is distributed on an - * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY - * KIND, either express or implied. See the License for the - * specific language governing permissions and limitations - * under the License. - */ - - - -/** - * Class InvalidValueTypeMarkerRuntimeException - * Date: Jan 7, 2011 - * Time: 12:58:27 PM - */ -public class InvalidValueTypeMarkerRuntimeException extends RuntimeException { - private int valueTypeMarker = -1; - - public InvalidValueTypeMarkerRuntimeException(int valueTypeMarker) { - super(); - this.valueTypeMarker = valueTypeMarker; - } - - public InvalidValueTypeMarkerRuntimeException(int valueTypeMarker, String s) { - super(s); - this.valueTypeMarker = valueTypeMarker; - } - - public InvalidValueTypeMarkerRuntimeException(int valueTypeMarker, String s, Throwable throwable) { - super(s, throwable); - this.valueTypeMarker = valueTypeMarker; - } - - public InvalidValueTypeMarkerRuntimeException(int valueTypeMarker, Throwable throwable) { - super(throwable); - this.valueTypeMarker = valueTypeMarker; - } - - public int getValueTypeMarker() { - return valueTypeMarker; - } -}
