now including the actual project
Project: http://git-wip-us.apache.org/repos/asf/incubator-rya/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-rya/commit/92ddfa59 Tree: http://git-wip-us.apache.org/repos/asf/incubator-rya/tree/92ddfa59 Diff: http://git-wip-us.apache.org/repos/asf/incubator-rya/diff/92ddfa59 Branch: refs/heads/master Commit: 92ddfa591ba05138a2eda1725a565692fa5fba94 Parents: b8bea9b Author: pujav65 <[email protected]> Authored: Wed Oct 28 15:23:30 2015 -0400 Committer: pujav65 <[email protected]> Committed: Wed Oct 28 15:23:30 2015 -0400 ---------------------------------------------------------------------- LICENSE | 202 + README.md | 286 + common/pom.xml | 17 + common/rya.api/.gitignore | 1 + common/rya.api/pom.xml | 60 + .../InvalidValueTypeMarkerRuntimeException.java | 54 + .../api/RdfCloudTripleStoreConfiguration.java | 506 + .../rya/api/RdfCloudTripleStoreConstants.java | 150 + .../rya/api/RdfCloudTripleStoreStatement.java | 71 + .../mvm/rya/api/RdfCloudTripleStoreUtils.java | 419 + .../rya/api/date/DateTimeTtlValueConverter.java | 79 + .../api/date/TimestampTtlStrValueConverter.java | 55 + .../api/date/TimestampTtlValueConverter.java | 55 + .../mvm/rya/api/date/TtlValueConverter.java | 40 + .../src/main/java/mvm/rya/api/domain/Node.java | 37 + .../main/java/mvm/rya/api/domain/RangeURI.java | 51 + .../java/mvm/rya/api/domain/RangeValue.java | 71 + .../main/java/mvm/rya/api/domain/RyaRange.java | 31 + .../main/java/mvm/rya/api/domain/RyaSchema.java | 42 + .../java/mvm/rya/api/domain/RyaStatement.java | 251 + .../main/java/mvm/rya/api/domain/RyaType.java | 110 + .../java/mvm/rya/api/domain/RyaTypePrefix.java | 58 + .../java/mvm/rya/api/domain/RyaTypeRange.java | 98 + .../main/java/mvm/rya/api/domain/RyaURI.java | 62 + .../java/mvm/rya/api/domain/RyaURIPrefix.java | 46 + .../java/mvm/rya/api/domain/RyaURIRange.java | 94 + .../api/domain/utils/RyaStatementWritable.java | 139 + .../mvm/rya/api/layout/TableLayoutStrategy.java | 39 + .../api/layout/TablePrefixLayoutStrategy.java | 84 + .../mvm/rya/api/persist/RdfDAOException.java | 43 + .../mvm/rya/api/persist/RdfEvalStatsDAO.java | 53 + .../java/mvm/rya/api/persist/RyaConfigured.java | 34 + .../main/java/mvm/rya/api/persist/RyaDAO.java | 125 + .../mvm/rya/api/persist/RyaDAOException.java | 42 + .../rya/api/persist/RyaNamespaceManager.java | 40 + .../api/persist/index/RyaSecondaryIndexer.java | 25 + .../persist/joinselect/SelectivityEvalDAO.java | 36 + .../rya/api/persist/query/BatchRyaQuery.java | 114 + .../mvm/rya/api/persist/query/RyaQuery.java | 96 + .../rya/api/persist/query/RyaQueryEngine.java | 95 + .../rya/api/persist/query/RyaQueryOptions.java | 245 + .../rya/api/persist/query/join/HashJoin.java | 157 + .../api/persist/query/join/IterativeJoin.java | 232 + .../mvm/rya/api/persist/query/join/Join.java | 43 + .../rya/api/persist/query/join/MergeJoin.java | 243 + .../mvm/rya/api/persist/utils/RyaDAOHelper.java | 175 + .../strategy/AbstractTriplePatternStrategy.java | 92 + .../mvm/rya/api/query/strategy/ByteRange.java | 44 + .../query/strategy/TriplePatternStrategy.java | 48 + .../HashedPoWholeRowTriplePatternStrategy.java | 134 + .../HashedSpoWholeRowTriplePatternStrategy.java | 137 + .../OspWholeRowTriplePatternStrategy.java | 112 + .../PoWholeRowTriplePatternStrategy.java | 127 + .../SpoWholeRowTriplePatternStrategy.java | 129 + .../resolver/CustomRyaTypeResolverMapping.java | 56 + .../rya/api/resolver/RdfToRyaConversions.java | 92 + .../java/mvm/rya/api/resolver/RyaContext.java | 191 + .../rya/api/resolver/RyaToRdfConversions.java | 74 + .../mvm/rya/api/resolver/RyaTripleContext.java | 122 + .../mvm/rya/api/resolver/RyaTypeResolver.java | 59 + .../api/resolver/RyaTypeResolverException.java | 42 + .../api/resolver/RyaTypeResolverMapping.java | 56 + .../resolver/impl/BooleanRyaTypeResolver.java | 60 + .../api/resolver/impl/ByteRyaTypeResolver.java | 62 + .../resolver/impl/CustomDatatypeResolver.java | 69 + .../resolver/impl/DateTimeRyaTypeResolver.java | 75 + .../resolver/impl/DoubleRyaTypeResolver.java | 67 + .../api/resolver/impl/FloatRyaTypeResolver.java | 63 + .../resolver/impl/IntegerRyaTypeResolver.java | 66 + .../api/resolver/impl/LongRyaTypeResolver.java | 67 + .../api/resolver/impl/RyaTypeResolverImpl.java | 123 + .../rya/api/resolver/impl/RyaURIResolver.java | 43 + .../ServiceBackedRyaTypeResolverMappings.java | 44 + .../api/resolver/impl/ShortRyaTypeResolver.java | 64 + .../mvm/rya/api/resolver/triple/TripleRow.java | 106 + .../rya/api/resolver/triple/TripleRowRegex.java | 83 + .../api/resolver/triple/TripleRowResolver.java | 42 + .../triple/TripleRowResolverException.java | 42 + .../impl/WholeRowHashedTripleResolver.java | 153 + .../triple/impl/WholeRowTripleResolver.java | 138 + .../mvm/rya/api/security/SecurityProvider.java | 8 + .../api/utils/CloseableIterableIteration.java | 75 + .../mvm/rya/api/utils/EnumerationWrapper.java | 57 + .../java/mvm/rya/api/utils/IteratorWrapper.java | 57 + .../rya/api/utils/NullableStatementImpl.java | 104 + .../api/utils/PeekingCloseableIteration.java | 73 + .../RyaStatementAddBindingSetFunction.java | 39 + ...ementRemoveBindingSetCloseableIteration.java | 60 + .../mvm/rya/api/domain/RyaURIPrefixTest.java | 36 + .../mvm/rya/api/persist/query/RyaQueryTest.java | 62 + .../AbstractTriplePatternStrategyTest.java | 191 + ...shedPoWholeRowTriplePatternStrategyTest.java | 174 + ...hedSpoWholeRowTriplePatternStrategyTest.java | 198 + .../wholerow/MockRdfCloudConfiguration.java | 12 + .../OspWholeRowTriplePatternStrategyTest.java | 135 + .../PoWholeRowTriplePatternStrategyTest.java | 159 + .../SpoWholeRowTriplePatternStrategyTest.java | 185 + .../mvm/rya/api/resolver/RyaContextTest.java | 85 + .../impl/CustomDatatypeResolverTest.java | 39 + .../impl/DateTimeRyaTypeResolverTest.java | 176 + .../impl/DoubleRyaTypeResolverTest.java | 45 + .../impl/IntegerRyaTypeResolverTest.java | 43 + .../resolver/impl/LongRyaTypeResolverTest.java | 48 + .../api/resolver/impl/RyaURIResolverTest.java | 39 + .../impl/HashedWholeRowTripleResolverTest.java | 123 + .../triple/impl/WholeRowTripleResolverTest.java | 126 + .../test/java/mvm/rya/api/utils/RdfIOTest.java | 67 + common/rya.provenance/pom.xml | 39 + .../provenance/LoggingProvenanceCollector.java | 40 + .../ProvenanceCollectionException.java | 19 + .../provenance/ProvenanceCollector.java | 14 + .../TriplestoreProvenanceCollector.java | 48 + .../provenance/rdf/BaseProvenanceModel.java | 48 + .../provenance/rdf/RDFProvenanceModel.java | 13 + .../TriplestoreProvenanceCollectorTest.java | 31 + .../provenance/rdf/BaseProvenanceModelTest.java | 18 + dao/accumulo.rya/pom.xml | 128 + .../AccumuloNamespaceTableIterator.java | 98 + .../rya/accumulo/AccumuloRdfConfiguration.java | 85 + .../mvm/rya/accumulo/AccumuloRdfConstants.java | 39 + .../rya/accumulo/AccumuloRdfEvalStatsDAO.java | 172 + .../rya/accumulo/AccumuloRdfQueryIterator.java | 297 + .../java/mvm/rya/accumulo/AccumuloRdfUtils.java | 71 + .../java/mvm/rya/accumulo/AccumuloRyaDAO.java | 522 + .../accumulo/DefineTripleQueryRangeFactory.java | 152 + .../mvm/rya/accumulo/RyaTableKeyValues.java | 114 + .../rya/accumulo/RyaTableMutationsFactory.java | 101 + .../experimental/AbstractAccumuloIndexer.java | 39 + .../accumulo/experimental/AccumuloIndexer.java | 13 + .../rya/accumulo/mr/AbstractAccumuloMRTool.java | 163 + .../accumulo/mr/eval/AccumuloRdfCountTool.java | 257 + .../mr/fileinput/BulkNtripsInputTool.java | 368 + .../mr/fileinput/RdfFileInputByLineTool.java | 250 + .../mr/fileinput/RdfFileInputFormat.java | 145 + .../accumulo/mr/fileinput/RdfFileInputTool.java | 174 + .../rya/accumulo/mr/upgrade/Upgrade322Tool.java | 239 + .../mr/utils/AccumuloHDFSFileInputFormat.java | 205 + .../rya/accumulo/mr/utils/AccumuloProps.java | 57 + .../java/mvm/rya/accumulo/mr/utils/MRUtils.java | 118 + .../accumulo/query/AccumuloRyaQueryEngine.java | 400 + .../query/KeyValueToRyaStatementFunction.java | 71 + .../accumulo/query/RangeBindingSetEntries.java | 57 + .../RyaStatementBindingSetKeyValueIterator.java | 153 + .../query/RyaStatementKeyValueIterator.java | 106 + .../query/ScannerBaseCloseableIterable.java | 55 + .../mvm/rya/accumulo/utils/TimeRangeFilter.java | 86 + .../accumulo/AccumuloRdfConfigurationTest.java | 58 + .../mvm/rya/accumulo/AccumuloRyaDAOTest.java | 664 + .../DefineTripleQueryRangeFactoryTest.java | 265 + .../mr/eval/AccumuloRdfCountToolTest.java | 281 + .../mr/fileinput/RdfFileInputToolTest.java | 145 + .../accumulo/mr/upgrade/Upgrade322ToolTest.java | 318 + .../upgrade/UpgradeObjectSerializationTest.java | 118 + .../src/test/resources/namedgraphs.trig | 7 + .../src/test/resources/test.ntriples | 1 + dao/cloudbase.rya/pom.xml | 103 + .../mvm/rya/cloudbase/BatchScannerIterator.java | 59 + .../CloudbaseNamespaceTableIterator.java | 78 + .../cloudbase/CloudbaseRdfConfiguration.java | 44 + .../rya/cloudbase/CloudbaseRdfConstants.java | 20 + .../rya/cloudbase/CloudbaseRdfEvalStatsDAO.java | 138 + .../mvm/rya/cloudbase/CloudbaseRdfUtils.java | 50 + .../java/mvm/rya/cloudbase/CloudbaseRyaDAO.java | 428 + .../mvm/rya/cloudbase/RyaTableKeyValues.java | 93 + .../rya/cloudbase/RyaTableMutationsFactory.java | 81 + .../mr/eval/CloudbaseRdfCountTool.java | 350 + .../mr/fileinput/BulkNtripsInputTool.java | 318 + .../mr/fileinput/RdfFileInputByLineTool.java | 230 + .../mr/fileinput/RdfFileInputFormat.java | 115 + .../mr/fileinput/RdfFileInputTool.java | 185 + .../fileinput/ShardedBulkNtripsInputTool.java | 314 + .../mr/upgrade/UpgradeCloudbaseRdfTables.java | 350 + .../mvm/rya/cloudbase/mr/utils/MRUtils.java | 94 + .../query/BatchScannerCloseableIterable.java | 34 + .../query/CloudbaseRyaQueryEngine.java | 385 + .../query/KeyValueToRyaStatementFunction.java | 47 + .../cloudbase/query/RangeBindingSetEntries.java | 37 + .../RyaStatementBindingSetKeyValueIterator.java | 129 + .../query/RyaStatementKeyValueIterator.java | 82 + .../query/ScannerCloseableIterable.java | 35 + .../rya/cloudbase/CloudbaseResearchMain.java | 77 + .../mvm/rya/cloudbase/CloudbaseRyaDAOTest.java | 588 + .../DefineTripleQueryRangeFactoryTest.java | 242 + dao/mongodb.rya/pom.xml | 30 + .../mvm/rya/mongodb/MongoDBQueryEngine.java | 187 + .../rya/mongodb/MongoDBRdfConfiguration.java | 101 + .../java/mvm/rya/mongodb/MongoDBRyaDAO.java | 202 + .../mongodb/dao/MongoDBNamespaceManager.java | 15 + .../rya/mongodb/dao/MongoDBStorageStrategy.java | 21 + .../dao/SimpleMongoDBNamespaceManager.java | 169 + .../dao/SimpleMongoDBStorageStrategy.java | 132 + .../NonCloseableRyaStatementCursorIterator.java | 37 + .../RyaStatementBindingSetCursorIterator.java | 88 + .../iter/RyaStatementCursorIterable.java | 47 + .../iter/RyaStatementCursorIterator.java | 84 + dao/pom.xml | 17 + extras/cloudbase.rya.giraph/pom.xml | 69 + .../format/CloudbaseRyaVertexInputFormat.java | 88 + .../format/CloudbaseRyaVertexOutputFormat.java | 94 + .../format/CloudbaseVertexInputFormat.java | 179 + .../format/CloudbaseVertexOutputFormat.java | 189 + .../giraph/format/PrintVertexOutputFormat.java | 94 + .../rya/cloudbase/giraph/format/BspCase.java | 253 + .../format/TestCloudbaseVertexFormat.java | 211 + extras/generic.mr/generic.mr.accumulo/pom.xml | 58 + .../generic/mr/accumulo/AccumuloMRInfo.groovy | 146 + .../services/mvm.rya.generic.mr.api.MRInfo | 1 + extras/generic.mr/generic.mr.api/pom.xml | 32 + .../groovy/mvm/rya/generic/mr/api/MRInfo.groovy | 43 + .../mvm/rya/generic/mr/api/MRInfoContext.groovy | 28 + extras/generic.mr/generic.mr.cloudbase/pom.xml | 33 + .../generic/mr/cloudbase/CloudbaseMRInfo.groovy | 146 + .../services/mvm.rya.generic.mr.api.MRInfo | 1 + extras/generic.mr/pom.xml | 27 + extras/indexing/pom.xml | 201 + .../documentIndex/DocIndexIteratorUtil.java | 11 + .../DocumentIndexIntersectingIterator.java | 850 + .../rya/accumulo/documentIndex/TextColumn.java | 88 + .../rya/accumulo/mr/NullFreeTextIndexer.java | 69 + .../mvm/rya/accumulo/mr/NullGeoIndexer.java | 120 + .../rya/accumulo/mr/NullTemporalIndexer.java | 134 + .../mvm/rya/accumulo/mr/RyaOutputFormat.java | 328 + .../mvm/rya/accumulo/mr/StatementWritable.java | 85 + .../fileinput/BulkNtripsInputToolIndexing.java | 226 + .../mr/fileinput/RyaBatchWriterInputTool.java | 242 + .../AccumuloPrecompQueryIndexer.java | 306 + .../java/mvm/rya/indexing/DocIdIndexer.java | 33 + .../rya/indexing/FilterFunctionOptimizer.java | 338 + .../java/mvm/rya/indexing/FreeTextIndexer.java | 61 + .../main/java/mvm/rya/indexing/GeoIndexer.java | 200 + .../ExternalIndexMatcher.java | 18 + .../GeneralizedExternalProcessor.java | 731 + .../IndexPlanValidator/IndexListPruner.java | 15 + .../IndexPlanValidator/IndexPlanValidator.java | 190 + .../IndexPlanValidator/IndexTupleGenerator.java | 15 + .../IndexedExecutionPlanGenerator.java | 187 + .../IndexedQueryPlanSelector.java | 13 + .../ThreshholdPlanSelector.java | 221 + .../TupleExecutionPlanGenerator.java | 200 + .../IndexPlanValidator/TupleReArranger.java | 328 + .../IndexPlanValidator/TupleValidator.java | 15 + .../ValidIndexCombinationGenerator.java | 651 + .../VarConstantIndexListPruner.java | 151 + .../java/mvm/rya/indexing/IndexingExpr.java | 76 + .../rya/indexing/IndexingFunctionRegistry.java | 117 + .../java/mvm/rya/indexing/IteratorFactory.java | 139 + .../main/java/mvm/rya/indexing/KeyParts.java | 313 + .../mvm/rya/indexing/PrecompQueryIndexer.java | 44 + .../java/mvm/rya/indexing/RyaSailFactory.java | 64 + .../java/mvm/rya/indexing/SearchFunction.java | 25 + .../mvm/rya/indexing/SearchFunctionFactory.java | 51 + .../mvm/rya/indexing/StatementContraints.java | 72 + .../java/mvm/rya/indexing/TemporalIndexer.java | 166 + .../java/mvm/rya/indexing/TemporalInstant.java | 63 + .../java/mvm/rya/indexing/TemporalInterval.java | 161 + .../mvm/rya/indexing/accumulo/ConfigUtils.java | 425 + .../java/mvm/rya/indexing/accumulo/Md5Hash.java | 44 + .../indexing/accumulo/StatementSerializer.java | 226 + .../accumulo/entity/AccumuloDocIdIndexer.java | 430 + .../accumulo/entity/EntityCentricIndex.java | 232 + .../entity/EntityLocalityGroupSetter.java | 151 + .../accumulo/entity/EntityOptimizer.java | 416 + .../accumulo/entity/EntityTupleSet.java | 244 + .../rya/indexing/accumulo/entity/StarQuery.java | 616 + .../freetext/AccumuloFreeTextIndexer.java | 615 + .../accumulo/freetext/ColumnPrefixes.java | 119 + .../accumulo/freetext/FreeTextTupleSet.java | 141 + .../accumulo/freetext/LuceneTokenizer.java | 56 + .../accumulo/freetext/SimpleTokenizer.java | 42 + .../indexing/accumulo/freetext/Tokenizer.java | 30 + .../freetext/iterators/AndingIterator.java | 562 + .../freetext/iterators/BooleanTreeIterator.java | 321 + .../accumulo/freetext/query/ASTExpression.java | 62 + .../accumulo/freetext/query/ASTNodeUtils.java | 209 + .../accumulo/freetext/query/ASTSimpleNode.java | 36 + .../accumulo/freetext/query/ASTTerm.java | 78 + .../freetext/query/JJTQueryParserState.java | 143 + .../indexing/accumulo/freetext/query/Node.java | 56 + .../accumulo/freetext/query/ParseException.java | 207 + .../accumulo/freetext/query/QueryParser.java | 412 + .../accumulo/freetext/query/QueryParser.jj | 176 + .../accumulo/freetext/query/QueryParser.jjt | 71 + .../freetext/query/QueryParserConstants.java | 79 + .../freetext/query/QueryParserTokenManager.java | 508 + .../query/QueryParserTreeConstants.java | 39 + .../freetext/query/SimpleCharStream.java | 491 + .../accumulo/freetext/query/SimpleNode.java | 99 + .../indexing/accumulo/freetext/query/Token.java | 151 + .../accumulo/freetext/query/TokenMgrError.java | 167 + .../rya/indexing/accumulo/geo/GeoConstants.java | 44 + .../accumulo/geo/GeoMesaGeoIndexer.java | 446 + .../indexing/accumulo/geo/GeoParseUtils.java | 26 + .../rya/indexing/accumulo/geo/GeoTupleSet.java | 344 + .../temporal/AccumuloTemporalIndexer.java | 804 + .../temporal/TemporalInstantRfc3339.java | 198 + .../accumulo/temporal/TemporalTupleSet.java | 300 + .../indexing/external/ExternalIndexMain.java | 218 + .../indexing/external/ExternalProcessor.java | 725 + .../mvm/rya/indexing/external/ExternalSail.java | 85 + .../indexing/external/ExternalSailExample.java | 123 + .../indexing/external/PrecompJoinOptimizer.java | 753 + .../external/QueryVariableNormalizer.java | 1160 ++ .../external/tupleSet/AccumuloIndexSet.java | 625 + .../external/tupleSet/ExternalTupleSet.java | 216 + .../tupleSet/SimpleExternalTupleSet.java | 87 + .../indexing/mongodb/AbstractMongoIndexer.java | 54 + .../mongodb/GeoMongoDBStorageStrategy.java | 166 + .../rya/indexing/mongodb/MongoGeoIndexer.java | 243 + .../rya/indexing/mongodb/MongoGeoTupleSet.java | 341 + .../ValidIndexCombinationGeneratorTest.java | 488 + .../DocumentIndexIntersectingIteratorTest.java | 1883 ++ .../GeneralizedExternalProcessorTest.java | 305 + .../IndexPlanValidatorTest.java | 1128 ++ .../IndexedExecutionPlanGeneratorTest.java | 403 + .../ThreshholdPlanSelectorTest.java | 818 + .../TupleExecutionPlanGeneratorTest.java | 344 + .../IndexPlanValidator/TupleReArrangerTest.java | 121 + .../ValidIndexCombinationGeneratorTest.java | 600 + .../VarConstantIndexListPrunerTest.java | 309 + .../accumulo/StatementSerializerTest.java | 105 + .../accumulo/entity/AccumuloDocIndexerTest.java | 2105 +++ .../accumulo/entity/EntityOptimizerTest.java | 1337 ++ .../indexing/accumulo/entity/StarQueryTest.java | 270 + .../freetext/AccumuloFreeTextIndexerTest.java | 220 + .../freetext/query/QueryParserTest.java | 129 + .../indexing/accumulo/geo/GeoIndexerSfTest.java | 315 + .../indexing/accumulo/geo/GeoIndexerTest.java | 369 + .../temporal/AccumuloTemporalIndexerTest.java | 1020 ++ .../accumulo/temporal/TemporalInstantTest.java | 76 + .../accumulo/temporal/TemporalIntervalTest.java | 158 + .../external/AccumuloConstantIndexSetTest.java | 811 + .../indexing/external/AccumuloIndexSetTest.java | 4329 +++++ .../external/AccumuloIndexSetTest2.java | 783 + .../PrecompJoinOptimizerIntegrationTest.java | 530 + .../external/PrecompJoinOptimizerTest.java | 501 + .../tupleSet/ExternalProcessorTest.java | 1653 ++ .../tupleSet/QueryVariableNormalizerTest.java | 964 + .../tupleSet/VarConstExternalProcessorTest.java | 470 + .../VarConstQueryVariableNormalizerTest.java | 727 + extras/indexingSailExample/pom.xml | 80 + .../src/main/assembly/assembly.xml | 50 + .../src/main/java/EntityDirectExample.java | 292 + .../src/main/java/MongoRyaDirectExample.java | 288 + .../src/main/java/RyaDirectExample.java | 681 + .../src/main/scripts/RunRyaDirectExample.bat | 25 + extras/pom.xml | 27 + extras/rya.console/.gitignore | 8 + extras/rya.console/pom.xml | 146 + .../java/mvm/rya/console/RyaBannerProvider.java | 61 + .../mvm/rya/console/RyaConsoleCommands.java | 211 + .../rya/console/RyaHistoryFileNameProvider.java | 42 + .../java/mvm/rya/console/RyaPromptProvider.java | 42 + .../META-INF/spring/spring-shell-plugin.xml | 10 + extras/rya.geo/pom.xml | 25 + .../src/main/java/mvm/rya/geo/GeoDistance.java | 34 + .../java/mvm/rya/geo/GeoRyaTypeResolver.java | 16 + .../src/main/java/mvm/rya/geo/RyaGeoSchema.java | 16 + .../src/main/java/mvm/rya/geo/Verify.java | 68 + .../src/main/java/mvm/rya/geo/WithinRange.java | 69 + .../mvm.rya.api.resolver.RyaTypeResolver | 1 + ...f.query.algebra.evaluation.function.Function | 1 + .../mvm/rya/geo/GeoRyaTypeResolverTest.java | 25 + .../test/java/mvm/rya/geo/WithinRangeTest.java | 43 + extras/rya.manual/pom.xml | 294 + extras/rya.manual/src/main/java/temp/TempJ.java | 29 + extras/rya.manual/src/main/webapp/.livereload | 19 + .../WEB-INF/scalate/layouts/default.scaml | 97 + .../webapp/WEB-INF/scalate/layouts/print.ssp | 778 + .../rya.manual/src/main/webapp/WEB-INF/web.xml | 50 + extras/rya.manual/src/main/webapp/_banner.ssp | 8 + .../rya.manual/src/main/webapp/_navigation.conf | 24 + .../rya.manual/src/main/webapp/_quicklinks.ssp | 5 + extras/rya.manual/src/main/webapp/alx.conf | 59 + .../src/main/webapp/build-source.conf | 19 + .../src/main/webapp/css/pygmentize.css | 134 + .../src/main/webapp/css/scalate/console.css | 71 + extras/rya.manual/src/main/webapp/css/style.css | 1588 ++ extras/rya.manual/src/main/webapp/eval.conf | 56 + extras/rya.manual/src/main/webapp/images/bg.png | Bin 0 -> 244 bytes .../src/main/webapp/images/bg02-blue-left.png | Bin 0 -> 1068 bytes .../src/main/webapp/images/bg02-blue-right.png | Bin 0 -> 1114 bytes .../main/webapp/images/bg02-white-left-nogr.png | Bin 0 -> 951 bytes .../webapp/images/bg02-white-right-nogr.png | Bin 0 -> 958 bytes .../src/main/webapp/images/big-bullet.png | Bin 0 -> 285 bytes .../src/main/webapp/images/left-box-bottom.png | Bin 0 -> 588 bytes .../src/main/webapp/images/left-box-right.png | Bin 0 -> 213 bytes .../src/main/webapp/images/left-box-top.png | Bin 0 -> 466 bytes .../rya.manual/src/main/webapp/images/logo.png | Bin 0 -> 18119 bytes .../rya.manual/src/main/webapp/images/logo2.png | Bin 0 -> 9271 bytes extras/rya.manual/src/main/webapp/index.conf | 4 + extras/rya.manual/src/main/webapp/infer.conf | 13 + .../src/main/webapp/loadPrecomputedJoin.conf | 27 + extras/rya.manual/src/main/webapp/loaddata.conf | 117 + extras/rya.manual/src/main/webapp/overview.conf | 4 + .../rya.manual/src/main/webapp/querydata.conf | 115 + .../rya.manual/src/main/webapp/quickstart.conf | 42 + .../rya.manual/src/main/webapp/sm-addauth.conf | 98 + .../src/main/webapp/sm-firststeps.conf | 55 + extras/rya.manual/src/main/webapp/sm-infer.conf | 313 + .../src/main/webapp/sm-namedgraph.conf | 129 + .../src/main/webapp/sm-simpleaqr.conf | 54 + .../src/main/webapp/sm-sparqlquery.conf | 58 + .../src/main/webapp/sm-updatedata.conf | 56 + extras/rya.prospector/pom.xml | 131 + .../mvm/rya/prospector/domain/IndexEntry.groovy | 57 + .../domain/IntermediateProspect.groovy | 51 + .../rya/prospector/domain/TripleValueType.java | 6 + .../mvm/rya/prospector/mr/Prospector.groovy | 89 + .../rya/prospector/mr/ProspectorCombiner.groovy | 42 + .../rya/prospector/mr/ProspectorMapper.groovy | 56 + .../rya/prospector/mr/ProspectorReducer.groovy | 38 + .../rya/prospector/plans/IndexWorkPlan.groovy | 32 + .../plans/IndexWorkPlanManager.groovy | 10 + .../rya/prospector/plans/impl/CountPlan.groovy | 201 + .../ServicesBackedIndexWorkPlanManager.groovy | 19 + .../prospector/service/ProspectorService.groovy | 107 + .../ProspectorServiceEvalStatsDAO.groovy | 103 + .../mvm/rya/prospector/utils/CustomEntry.groovy | 33 + .../prospector/utils/ProspectorConstants.groovy | 22 + .../rya/prospector/utils/ProspectorUtils.groovy | 119 + .../joinselect/AccumuloSelectivityEvalDAO.java | 639 + .../mvm/rya/joinselect/CardinalityCalcUtil.java | 266 + .../mvm/rya/joinselect/mr/FullTableSize.java | 128 + .../rya/joinselect/mr/JoinSelectAggregate.java | 270 + .../mvm/rya/joinselect/mr/JoinSelectDriver.java | 59 + .../joinselect/mr/JoinSelectProspectOutput.java | 122 + .../joinselect/mr/JoinSelectSpoTableOutput.java | 124 + .../joinselect/mr/JoinSelectStatisticsSum.java | 219 + .../mvm/rya/joinselect/mr/utils/CardList.java | 208 + .../joinselect/mr/utils/CardinalityType.java | 148 + .../rya/joinselect/mr/utils/CompositeType.java | 121 + .../mr/utils/JoinSelectConstants.java | 45 + .../mr/utils/JoinSelectStatsUtil.java | 182 + .../mvm/rya/joinselect/mr/utils/TripleCard.java | 144 + .../rya/joinselect/mr/utils/TripleEntry.java | 179 + .../mvm.rya.prospector.plans.IndexWorkPlan | 1 + .../mvm/rya/prospector/mr/ProspectorTest.groovy | 178 + .../ProspectorServiceEvalStatsDAOTest.groovy | 182 + .../AccumuloSelectivityEvalDAOTest.java | 591 + .../mr/CardinalityIdentityReducerTest.java | 140 + .../joinselect/mr/CardinalityMapperTest.java | 75 + .../rya/joinselect/mr/FullTableSizeTest.java | 63 + .../mvm/rya/joinselect/mr/JoinReducerTest.java | 123 + .../rya/joinselect/mr/JoinSelectMapperTest.java | 93 + .../mr/JoinSelectProspectOutputTest.java | 69 + .../mr/JoinSelectStatisticsSumTest.java | 59 + .../joinselect/mr/JoinSelectStatisticsTest.java | 870 + .../src/test/resources/stats_cluster_config.xml | 76 + extras/tinkerpop.rya/pom.xml | 136 + .../config/RyaGraphConfiguration.groovy | 84 + .../mvm/rya/blueprints/sail/RyaSailEdge.groovy | 75 + .../blueprints/sail/RyaSailEdgeSequence.groovy | 91 + .../mvm/rya/blueprints/sail/RyaSailGraph.groovy | 112 + .../rya/blueprints/sail/RyaSailVertex.groovy | 70 + .../sail/RyaSailVertexSequence.groovy | 75 + .../mvm/rya/blueprints/sail/RyaSailEdge.java | 100 + .../mvm/rya/blueprints/sail/RyaSailVertex.java | 104 + .../mvm/rya/blueprints/TstGremlinRya.groovy | 111 + .../config/RyaGraphConfigurationTest.groovy | 129 + .../sail/RyaSailVertexSequenceTest.groovy | 100 + .../src/test/resources/log4j.properties | 19 + iterators/accumulo.iterators/pom.xml | 34 + .../mvm/rya/iterators/LimitingAgeOffFilter.java | 138 + .../rya/iterators/LimitingAgeOffFilterTest.java | 80 + iterators/cloudbase.iterators/pom.xml | 29 + .../mvm/rya/iterators/LimitingAgeOffFilter.java | 76 + .../rya/iterators/LimitingAgeOffFilterTest.java | 59 + iterators/pom.xml | 25 + osgi/alx.rya.console/pom.xml | 41 + .../mvm/rya/alx/command/AbstractRyaCommand.java | 57 + .../alx/command/GetStatementsRyaCommand.java | 79 + .../mvm/rya/alx/command/InfoRyaCommand.java | 45 + .../blueprint/alx.rya.console-blueprint.xml | 14 + osgi/alx.rya/pom.xml | 76 + .../src/main/features/alx.rya-features.xml | 84 + .../mvm/rya/alx/util/ConfigurationFactory.java | 52 + .../META-INF/spring/alx.rya-spring-osgi.xml | 42 + .../META-INF/spring/alx.rya-spring.xml | 60 + .../src/main/resources/ROOT/crossdomain.xml | 5 + osgi/camel.rya/pom.xml | 82 + .../mvm/rya/camel/cbsail/CbSailComponent.java | 58 + .../mvm/rya/camel/cbsail/CbSailEndpoint.java | 118 + .../mvm/rya/camel/cbsail/CbSailProducer.java | 174 + .../services/org/apache/camel/component/cbsail | 1 + .../rya/camel/cbsail/CbSailIntegrationTest.java | 116 + .../mvm/rya/camel/cbsail/CbSailPojoMain.java | 44 + .../java/mvm/rya/camel/cbsail/CbSailTest.java | 204 + osgi/pom.xml | 54 + .../sesame-runtime-osgi/openrdf-sesame-osgi.bnd | 7 + osgi/sesame-runtime-osgi/pom.xml | 116 + partition/common-query-ext/pom.xml | 71 + .../ext/EncodedSortedRangeIterator.java | 44 + .../src/test/java/GVDateFilterTest.java | 156 + .../src/test/java/GVFrequencyFilterTest.java | 144 + .../src/test/java/IteratorTest.java | 554 + .../src/test/java/JTSFilterTest.java | 181 + .../src/test/java/OGCFilterTest.java | 163 + .../src/test/java/SampleData.java | 228 + .../src/test/java/SampleGVData.java | 182 + .../src/test/java/SampleJTSData.java | 171 + partition/common-query/pom.xml | 103 + .../iterators/CellLevelFilteringIterator.java | 163 + .../core/iterators/CellLevelRecordIterator.java | 144 + .../core/iterators/ConversionIterator.java | 151 + .../iterators/GMDenIntersectingIterator.java | 363 + .../core/iterators/IntersectingIterator.java | 557 + .../core/iterators/IntersectionRange.java | 330 + .../core/iterators/IteratorConstants.java | 11 + .../core/iterators/SortedMinIterator.java | 173 + .../core/iterators/SortedRangeIterator.java | 136 + .../core/iterators/UniqueIterator.java | 95 + .../core/iterators/conversion/Operation.java | 109 + .../core/iterators/filter/CBConverter.java | 117 + .../iterators/filter/general/GVDateFilter.java | 169 + .../filter/general/GVFrequencyFilter.java | 92 + .../core/iterators/filter/jts/JTSFilter.java | 191 + .../core/iterators/filter/ogc/OGCFilter.java | 241 + .../ogc/operation/AbstractComparisonOp.java | 80 + .../filter/ogc/operation/AbstractLogicalOp.java | 40 + .../iterators/filter/ogc/operation/And.java | 29 + .../iterators/filter/ogc/operation/BBOX.java | 125 + .../filter/ogc/operation/IOperation.java | 30 + .../iterators/filter/ogc/operation/Not.java | 35 + .../core/iterators/filter/ogc/operation/Or.java | 29 + .../filter/ogc/operation/PropertyIsBetween.java | 76 + .../filter/ogc/operation/PropertyIsEqualTo.java | 30 + .../ogc/operation/PropertyIsGreaterThan.java | 29 + .../PropertyIsGreaterThanOrEqualTo.java | 29 + .../ogc/operation/PropertyIsLessThan.java | 31 + .../operation/PropertyIsLessThanOrEqualTo.java | 29 + .../filter/ogc/operation/PropertyIsLike.java | 144 + .../ogc/operation/PropertyIsNotEqualTo.java | 30 + .../filter/ogc/operation/PropertyIsNull.java | 38 + .../filter/ogc/operation/ShapeFactory.java | 133 + .../core/iterators/filter/ogc/util/GeoUtil.java | 32 + .../src/test/java/GVDateFilterTest.java | 156 + .../src/test/java/GVFrequencyFilterTest.java | 144 + .../src/test/java/IteratorTest.java | 554 + .../src/test/java/JTSFilterTest.java | 181 + .../src/test/java/OGCFilterTest.java | 163 + .../common-query/src/test/java/SampleData.java | 228 + .../src/test/java/SampleGVData.java | 182 + .../src/test/java/SampleJTSData.java | 171 + partition/iterator-test/filter.txt | 6 + partition/iterator-test/pom.xml | 99 + .../src/main/java/dss/webservice/itr/Main.java | 348 + .../src/main/java/dss/webservice/itr/Test.java | 9 + .../dss/webservice/itr/test/AddTestRecords.java | 43 + .../dss/webservice/itr/test/BaseTileTest.java | 132 + .../dss/webservice/itr/test/ConversionTest.java | 159 + partition/iterator-test/test.sh | 3 + partition/mr.partition.rdf/pom.xml | 79 + .../mr.partition.rdf/src/main/assembly/job.xml | 38 + .../src/main/groovy/convertrdfdir.groovy | 33 + .../mvm/mmrts/rdf/partition/mr/MrTstBed.java | 104 + .../mr/SparqlPartitionStoreInputFormat.java | 411 + .../rdf/partition/mr/SparqlTestDriver.java | 155 + .../mvm/mmrts/rdf/partition/mr/TestDriver.java | 154 + .../mr/compat/ChangeShardDateFormatTool.java | 229 + .../partition/mr/compat/MoveShardIndexTool.java | 171 + .../mr/fileinput/RdfFileInputFormat.java | 155 + .../fileinput/RdfFileInputToCloudbaseTool.java | 210 + .../mr/fileinput/RdfFileInputToFileTool.java | 159 + .../mr/fileinput/bulk/BulkNtripsInputTool.java | 326 + .../bulk/EmbedKeyRangePartitioner.java | 28 + .../iterators/SortedEncodedRangeIterator.java | 45 + .../AggregateTriplesBySubjectCombiner.java | 31 + .../AggregateTriplesBySubjectReducer.java | 37 + .../mr/transform/KeyValueToMapWrMapper.java | 78 + .../mr/transform/SparqlCloudbaseIFJob.java | 118 + .../transform/SparqlCloudbaseIFTransformer.java | 331 + .../SparqlCloudbaseIFTransformerConstants.java | 12 + .../compat/ChangeShardDateFormatToolTest.java | 33 + .../mr/fileinput/RdfFileInputToolTest.java | 80 + .../bulk/EmbedKeyRangePartitionerTest.java | 20 + partition/partition.rdf/pom.xml | 281 + .../InvalidValueTypeMarkerRuntimeException.java | 34 + .../rdf/partition/PartitionConnection.java | 306 + .../mmrts/rdf/partition/PartitionConstants.java | 141 + .../mvm/mmrts/rdf/partition/PartitionSail.java | 122 + .../rdf/partition/PartitionTripleSource.java | 40 + .../converter/ContextColVisConverter.java | 14 + .../partition/iterators/NamespaceIterator.java | 93 + .../evaluation/FilterTimeIndexVisitor.java | 113 + .../evaluation/PartitionEvaluationStrategy.java | 70 + .../ShardSubjectLookupStatementIterator.java | 493 + .../evaluation/SubjectGroupingOptimizer.java | 178 + .../query/evaluation/select/FilterIterator.java | 100 + .../evaluation/select/SelectAllIterator.java | 54 + .../query/evaluation/select/SelectIterator.java | 270 + .../select/SubjectSelectIterator.java | 40 + .../select/utils/DocumentIterator.java | 107 + .../query/operators/ShardSubjectLookup.java | 167 + .../shard/DateHashModShardValueGenerator.java | 52 + .../partition/shard/ShardValueGenerator.java | 12 + .../partition/utils/ContextsStatementImpl.java | 30 + .../rdf/partition/utils/CountPredObjPairs.java | 39 + .../rdf/partition/utils/PartitionUtils.java | 9 + .../mvm/mmrts/rdf/partition/utils/RdfIO.java | 166 + .../main/resources/partitionTableLoad.cbexec | 4 + .../mmrts/rdf/partition/LoadPartitionData.java | 79 + .../mmrts/rdf/partition/LoadPartitionData2.java | 69 + .../mvm/mmrts/rdf/partition/LoadSampleData.java | 64 + .../mvm/mmrts/rdf/partition/MemStoreTst.java | 71 + .../rdf/partition/PartitionConnectionTest.java | 771 + .../mmrts/rdf/partition/QueryPartitionData.java | 675 + .../java/mvm/mmrts/rdf/partition/TstBed.java | 90 + .../mvm/mmrts/rdf/partition/TstBedGMDen.java | 94 + .../mmrts/rdf/partition/TstDocumentReader.java | 217 + .../mvm/mmrts/rdf/partition/TstScanner.java | 59 + .../DateHashModShardValueGeneratorTest.java | 30 + .../mmrts/rdf/partition/utils/RdfIOTest.java | 82 + partition/web.partition.rdf/cimRdf.xml | 15740 +++++++++++++++++ partition/web.partition.rdf/pom.xml | 63 + .../web/partition/AbstractRDFWebServlet.java | 66 + .../rdf/web/partition/DeleteDataServlet.java | 46 + .../rdf/web/partition/LoadDataServlet.java | 56 + .../rdf/web/partition/QueryDataServlet.java | 158 + .../web/partition/QuerySerqlDataServlet.java | 116 + .../rdf/web/partition/RDFWebConstants.java | 15 + .../src/main/webapp/WEB-INF/web.xml | 77 + .../src/main/webapp/crossdomain.xml | 5 + .../src/main/webapp/serqlQuery.jsp | 36 + .../src/main/webapp/sparqlQuery.jsp | 47 + .../cloudbase/sail/DeleteDataServletRun.java | 455 + .../web/cloudbase/sail/LoadDataServletRun.java | 51 + .../web/cloudbase/sail/QueryDataServletRun.java | 444 + .../src/test/resources/cdrdf.xml | 20 + .../src/test/resources/n3trips.txt | 4 + pig/accumulo.pig/pom.xml | 103 + .../mvm/rya/accumulo/pig/AccumuloStorage.java | 382 + .../mvm/rya/accumulo/pig/IndexWritingTool.java | 347 + .../rya/accumulo/pig/SparqlQueryPigEngine.java | 267 + .../pig/SparqlToPigTransformVisitor.java | 344 + .../accumulo/pig/StatementPatternStorage.java | 303 + .../pig/optimizer/SimilarVarJoinOptimizer.java | 209 + .../rya/accumulo/pig/AccumuloStorageTest.java | 283 + .../rya/accumulo/pig/IndexWritingToolTest.java | 306 + .../accumulo/pig/SparqlQueryPigEngineTest.java | 75 + .../pig/SparqlToPigTransformVisitorTest.java | 401 + .../pig/StatementPatternStorageTest.java | 184 + .../src/test/resources/ResultsFile1.txt | 8 + .../src/test/resources/testQuery.txt | 7 + .../src/test/resources/testQuery2.txt | 4 + pig/cloudbase.pig/pom.xml | 65 + .../mvm/rya/cloudbase/pig/CloudbaseStorage.java | 318 + .../rya/cloudbase/pig/SparqlQueryPigEngine.java | 237 + .../pig/SparqlToPigTransformVisitor.java | 323 + .../cloudbase/pig/StatementPatternStorage.java | 278 + .../rya/cloudbase/pig/dep/CloudbaseStorage.java | 299 + .../pig/dep/StatementPatternStorage.java | 178 + .../pig/optimizer/SimilarVarJoinOptimizer.java | 189 + .../mapred/PreferLocalMapTaskSelector.java | 39 + .../cloudbase/pig/CloudbaseInputFormatMain.java | 50 + .../rya/cloudbase/pig/CloudbaseStorageTest.java | 250 + .../cloudbase/pig/SparqlQueryPigEngineTest.java | 55 + .../pig/SparqlToPigTransformVisitorTest.java | 367 + .../pig/StatementPatternStorageTest.java | 148 + pig/pom.xml | 16 + pom.xml | 489 + sail/pom.xml | 16 + sail/rya.sail.impl/pom.xml | 126 + .../rya/rdftriplestore/RdfCloudTripleStore.java | 178 + .../RdfCloudTripleStoreConnection.java | 622 + .../RdfCloudTripleStoreFactory.java | 55 + .../RdfCloudTripleStoreSailConfig.java | 132 + .../rya/rdftriplestore/RyaSailRepository.java | 52 + .../RyaSailRepositoryConnection.java | 108 + .../evaluation/ExternalBatchingIterator.java | 32 + .../ExternalMultipleBindingSetsIterator.java | 108 + .../evaluation/FilterRangeVisitor.java | 96 + .../evaluation/MultipleBindingSetsIterator.java | 107 + .../ParallelEvaluationStrategyImpl.java | 280 + .../evaluation/ParallelJoinIterator.java | 138 + .../evaluation/PushJoinDownVisitor.java | 56 + .../evaluation/QueryJoinOptimizer.java | 283 + .../evaluation/QueryJoinSelectOptimizer.java | 259 + ...RdfCloudTripleStoreEvaluationStatistics.java | 280 + ...pleStoreSelectivityEvaluationStatistics.java | 127 + .../evaluation/ReorderJoinVisitor.java | 69 + .../evaluation/SeparateFilterJoinsVisitor.java | 54 + .../inference/AbstractInferVisitor.java | 107 + .../rdftriplestore/inference/DoNotExpandSP.java | 50 + .../inference/InferConstants.java | 33 + .../rya/rdftriplestore/inference/InferJoin.java | 49 + .../rdftriplestore/inference/InferUnion.java | 47 + .../inference/InferenceEngine.java | 409 + .../inference/InferenceEngineException.java | 42 + .../inference/InverseOfVisitor.java | 79 + .../rdftriplestore/inference/SameAsVisitor.java | 186 + .../inference/SubClassOfVisitor.java | 107 + .../inference/SubPropertyOfVisitor.java | 120 + .../inference/SymmetricPropertyVisitor.java | 77 + .../inference/TransitivePropertyVisitor.java | 68 + .../namespace/NamespaceManager.java | 166 + .../utils/CombineContextsRdfInserter.java | 164 + .../rdftriplestore/utils/DefaultStatistics.java | 57 + .../utils/FixedStatementPattern.java | 58 + .../utils/TransitivePropertySP.java | 51 + .../META-INF/org.openrdf.store.schemas | 1 + .../META-INF/schemas/cloudbasestore-schema.ttl | 20 + .../org.openrdf.sail.config.SailFactory | 1 + .../src/main/resources/ehcache.xml | 26 + .../java/mvm/rya/ArbitraryLengthQueryTest.java | 499 + .../src/test/java/mvm/rya/HashJoinTest.java | 373 + .../test/java/mvm/rya/IterativeJoinTest.java | 364 + .../src/test/java/mvm/rya/MergeJoinTest.java | 369 + .../rya/RdfCloudTripleStoreConnectionTest.java | 1362 ++ .../java/mvm/rya/RdfCloudTripleStoreTest.java | 698 + .../mvm/rya/RdfCloudTripleStoreUtilsTest.java | 86 + .../QueryJoinSelectOptimizerTest.java | 991 ++ ...toreSelectivityEvaluationStatisticsTest.java | 303 + .../rya/triplestore/inference/SameAsTest.java | 114 + sail/rya.sail.impl/src/test/resources/cdrdf.xml | 40 + .../src/test/resources/namedgraphs.trig | 37 + sail/rya.sail.impl/src/test/resources/ntriples | 1 + .../src/test/resources/reification.xml | 35 + .../src/test/resources/univ-bench.owl | 466 + src/license/apacheV2Header.ftl | 16 + utils/cloudbase.utils/pom.xml | 67 + .../utils/bulk/KeyRangePartitioner.java | 35 + .../utils/filters/TimeRangeFilter.java | 64 + .../input/CloudbaseBatchScannerInputFormat.java | 872 + .../utils/scanner/BatchScannerList.java | 108 + .../cloudbase/utils/scanner/RangesScanner.java | 236 + .../cloudbase/utils/shard/HashAlgorithm.java | 9 + .../utils/shard/HashCodeHashAlgorithm.java | 14 + .../utils/shard/ShardedBatchWriter.java | 51 + .../cloudbase/utils/shard/ShardedConnector.java | 158 + ...mentTabletServerBatchReaderIteratorTest.java | 15 + .../utils/filters/TimeRangeFilterTest.java | 53 + .../utils/shard/ShardedConnectorTest.java | 76 + utils/pom.xml | 22 + web/pom.xml | 16 + web/web.rya/pom.xml | 177 + web/web.rya/resources/environment.properties | 10 + .../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 | 343 + .../mvm/cloud/rdf/web/sail/ResultFormat.java | 26 + .../rdf/web/sail/SecurityProviderImpl.java | 14 + .../webapp/WEB-INF/spring/spring-accumulo.xml | 31 + .../webapp/WEB-INF/spring/spring-cloudbase.xml | 30 + .../webapp/WEB-INF/spring/spring-mongodb.xml | 23 + .../WEB-INF/spring/spring-root-extensions.xml | 85 + .../main/webapp/WEB-INF/spring/spring-root.xml | 48 + .../webapp/WEB-INF/spring/spring-security.xml | 14 + web/web.rya/src/main/webapp/WEB-INF/web.xml | 146 + web/web.rya/src/main/webapp/crossdomain.xml | 5 + web/web.rya/src/main/webapp/sparqlQuery.jsp | 60 + .../cloudbase/sail/DeleteDataServletRun.java | 475 + .../web/cloudbase/sail/LoadDataServletRun.java | 65 + .../web/cloudbase/sail/QueryDataServletRun.java | 466 + .../web/sail/RdfControllerIntegrationTest.java | 66 + .../cloud/rdf/web/sail/RdfControllerTest.java | 159 + web/web.rya/src/test/resources/cdrdf.xml | 40 + .../controllerIntegrationTest-accumulo.xml | 49 + .../controllerIntegrationTest-root.xml | 41 + .../test/resources/controllerTest-context.xml | 39 + .../test/resources/dummyData/memorystore.data | Bin 0 -> 290 bytes web/web.rya/src/test/resources/namedgraphs.trig | 37 + web/web.rya/src/test/resources/test.nt | 3 + 766 files changed, 142627 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/92ddfa59/LICENSE ---------------------------------------------------------------------- diff --git a/LICENSE b/LICENSE new file mode 100644 index 0000000..d645695 --- /dev/null +++ b/LICENSE @@ -0,0 +1,202 @@ + + Apache License + Version 2.0, January 2004 + http://www.apache.org/licenses/ + + TERMS AND CONDITIONS FOR USE, REPRODUCTION, AND DISTRIBUTION + + 1. Definitions. + + "License" shall mean the terms and conditions for use, reproduction, + and distribution as defined by Sections 1 through 9 of this document. + + "Licensor" shall mean the copyright owner or entity authorized by + the copyright owner that is granting the License. + + "Legal Entity" shall mean the union of the acting entity and all + other entities that control, are controlled by, or are under common + control with that entity. For the purposes of this definition, + "control" means (i) the power, direct or indirect, to cause the + direction or management of such entity, whether by contract or + otherwise, or (ii) ownership of fifty percent (50%) or more of the + outstanding shares, or (iii) beneficial ownership of such entity. + + "You" (or "Your") shall mean an individual or Legal Entity + exercising permissions granted by this License. + + "Source" form shall mean the preferred form for making modifications, + including but not limited to software source code, documentation + source, and configuration files. + + "Object" form shall mean any form resulting from mechanical + transformation or translation of a Source form, including but + not limited to compiled object code, generated documentation, + and conversions to other media types. + + "Work" shall mean the work of authorship, whether in Source or + Object form, made available under the License, as indicated by a + copyright notice that is included in or attached to the work + (an example is provided in the Appendix below). + + "Derivative Works" shall mean any work, whether in Source or Object + form, that is based on (or derived from) the Work and for which the + editorial revisions, annotations, elaborations, or other modifications + represent, as a whole, an original work of authorship. For the purposes + of this License, Derivative Works shall not include works that remain + separable from, or merely link (or bind by name) to the interfaces of, + the Work and Derivative Works thereof. + + "Contribution" shall mean any work of authorship, including + the original version of the Work and any modifications or additions + to that Work or Derivative Works thereof, that is intentionally + submitted to Licensor for inclusion in the Work by the copyright owner + or by an individual or Legal Entity authorized to submit on behalf of + the copyright owner. For the purposes of this definition, "submitted" + means any form of electronic, verbal, or written communication sent + to the Licensor or its representatives, including but not limited to + communication on electronic mailing lists, source code control systems, + and issue tracking systems that are managed by, or on behalf of, the + Licensor for the purpose of discussing and improving the Work, but + excluding communication that is conspicuously marked or otherwise + designated in writing by the copyright owner as "Not a Contribution." + + "Contributor" shall mean Licensor and any individual or Legal Entity + on behalf of whom a Contribution has been received by Licensor and + subsequently incorporated within the Work. + + 2. Grant of Copyright License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + copyright license to reproduce, prepare Derivative Works of, + publicly display, publicly perform, sublicense, and distribute the + Work and such Derivative Works in Source or Object form. + + 3. Grant of Patent License. Subject to the terms and conditions of + this License, each Contributor hereby grants to You a perpetual, + worldwide, non-exclusive, no-charge, royalty-free, irrevocable + (except as stated in this section) patent license to make, have made, + use, offer to sell, sell, import, and otherwise transfer the Work, + where such license applies only to those patent claims licensable + by such Contributor that are necessarily infringed by their + Contribution(s) alone or by combination of their Contribution(s) + with the Work to which such Contribution(s) was submitted. If You + institute patent litigation against any entity (including a + cross-claim or counterclaim in a lawsuit) alleging that the Work + or a Contribution incorporated within the Work constitutes direct + or contributory patent infringement, then any patent licenses + granted to You under this License for that Work shall terminate + as of the date such litigation is filed. + + 4. Redistribution. You may reproduce and distribute copies of the + Work or Derivative Works thereof in any medium, with or without + modifications, and in Source or Object form, provided that You + meet the following conditions: + + (a) You must give any other recipients of the Work or + Derivative Works a copy of this License; and + + (b) You must cause any modified files to carry prominent notices + stating that You changed the files; and + + (c) You must retain, in the Source form of any Derivative Works + that You distribute, all copyright, patent, trademark, and + attribution notices from the Source form of the Work, + excluding those notices that do not pertain to any part of + the Derivative Works; and + + (d) If the Work includes a "NOTICE" text file as part of its + distribution, then any Derivative Works that You distribute must + include a readable copy of the attribution notices contained + within such NOTICE file, excluding those notices that do not + pertain to any part of the Derivative Works, in at least one + of the following places: within a NOTICE text file distributed + as part of the Derivative Works; within the Source form or + documentation, if provided along with the Derivative Works; or, + within a display generated by the Derivative Works, if and + wherever such third-party notices normally appear. The contents + of the NOTICE file are for informational purposes only and + do not modify the License. You may add Your own attribution + notices within Derivative Works that You distribute, alongside + or as an addendum to the NOTICE text from the Work, provided + that such additional attribution notices cannot be construed + as modifying the License. + + You may add Your own copyright statement to Your modifications and + may provide additional or different license terms and conditions + for use, reproduction, or distribution of Your modifications, or + for any such Derivative Works as a whole, provided Your use, + reproduction, and distribution of the Work otherwise complies with + the conditions stated in this License. + + 5. Submission of Contributions. Unless You explicitly state otherwise, + any Contribution intentionally submitted for inclusion in the Work + by You to the Licensor shall be under the terms and conditions of + this License, without any additional terms or conditions. + Notwithstanding the above, nothing herein shall supersede or modify + the terms of any separate license agreement you may have executed + with Licensor regarding such Contributions. + + 6. Trademarks. This License does not grant permission to use the trade + names, trademarks, service marks, or product names of the Licensor, + except as required for reasonable and customary use in describing the + origin of the Work and reproducing the content of the NOTICE file. + + 7. Disclaimer of Warranty. Unless required by applicable law or + agreed to in writing, Licensor provides the Work (and each + Contributor provides its Contributions) on an "AS IS" BASIS, + WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or + implied, including, without limitation, any warranties or conditions + of TITLE, NON-INFRINGEMENT, MERCHANTABILITY, or FITNESS FOR A + PARTICULAR PURPOSE. You are solely responsible for determining the + appropriateness of using or redistributing the Work and assume any + risks associated with Your exercise of permissions under this License. + + 8. Limitation of Liability. In no event and under no legal theory, + whether in tort (including negligence), contract, or otherwise, + unless required by applicable law (such as deliberate and grossly + negligent acts) or agreed to in writing, shall any Contributor be + liable to You for damages, including any direct, indirect, special, + incidental, or consequential damages of any character arising as a + result of this License or out of the use or inability to use the + Work (including but not limited to damages for loss of goodwill, + work stoppage, computer failure or malfunction, or any and all + other commercial damages or losses), even if such Contributor + has been advised of the possibility of such damages. + + 9. Accepting Warranty or Additional Liability. While redistributing + the Work or Derivative Works thereof, You may choose to offer, + and charge a fee for, acceptance of support, warranty, indemnity, + or other liability obligations and/or rights consistent with this + License. However, in accepting such obligations, You may act only + on Your own behalf and on Your sole responsibility, not on behalf + of any other Contributor, and only if You agree to indemnify, + defend, and hold each Contributor harmless for any liability + incurred by, or claims asserted against, such Contributor by reason + of your accepting any such warranty or additional liability. + + END OF TERMS AND CONDITIONS + + APPENDIX: How to apply the Apache License to your work. + + To apply the Apache License to your work, attach the following + boilerplate notice, with the fields enclosed by brackets "[]" + replaced with your own identifying information. (Don't include + the brackets!) The text should be enclosed in the appropriate + comment syntax for the file format. We also recommend that a + file or class name and description of purpose be included on the + same "printed page" as the copyright notice for easier + identification within third-party archives. + + Copyright [yyyy] [name of copyright owner] + + Licensed 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. http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/92ddfa59/README.md ---------------------------------------------------------------------- diff --git a/README.md b/README.md new file mode 100644 index 0000000..04628cc --- /dev/null +++ b/README.md @@ -0,0 +1,286 @@ +# RYA + +## Overview + +RYA is a scalable RDF Store that is built on top of a Columnar Index Store (such as Accumulo, Hbase(not currently supported)). It is implemented as an extension to OpenRdf to provide easy query mechanisms (SPARQL, SERQL, etc) and Rdf data storage (RDF/XML, NTriples, etc). + +RYA stands for RDF y(and) Accumulo. + +## Upgrade Path + +Since the data encodings changed in the 3.2.2 release, you will need to run the Upgrade322Tool MapReduce job to perform the upgrade. + +1. Build the project with -Pmr to build the mapreduce artifacts +2. Make sure to clone the rya tables before doing the upgrade +3. Run + <pre> hadoop jar accumulo.rya-mr.jar mvm.rya.accumulo.mr.upgrade.Upgrade322Tool -Dac.instance={} -Dac.username={} -Dac.pwd={} </pre> + +## Quick Start + +This tutorial will outline the steps needed to get quickly started with the Rya store using the web based endpoint. + +### Prerequisites + +* Columnar Store (either Accumulo) The tutorial will go forward using Accumulo +* Rya code (Git: [email protected]:texeltek/rya.git) +* Maven 2.2 + + +### Building from Source + +Using Git, pull down the latest code from the url above. + +Run the command to build the code {{mvn clean install}} + +If all goes well, the build should be successful and a war should be produced in {{web/web.rya/target/web.rya.war}} + +Note: To perform a build of the geomesa/lucene indexing, run the build with the profile 'indexing' (-P indexing) + +Note: If you are building on windows, you will need hadoop-common 2.6.0's {{winutils.exe}} and {{hadoop.dll}}. You can download it from [here](https://github.com/amihalik/hadoop-common-2.6.0-bin/archive/master.zip). This build requires the [Visual C++ Redistributable for Visual Studio 2015 (x64)](https://www.microsoft.com/en-us/download/details.aspx?id=48145). Also you will need to set your path and Hadoop home using the commands below: + + set HADOOP_HOME=c:\hadoop-common-2.6.0-bin + set PATH=%PATH%;c:\hadoop-common-2.6.0-bin\bin + +### Deployment + +(Using tomcat) + +Unwar the above war into the webapps directory. + +To point the web.rya war to the appropriate Accumulo instance, make a properties file {{environment.properties}} and put it in the classpath. Here is an example: + + instance.name=accumulo #Accumulo instance name + instance.zk=localhost:2181 #Accumulo Zookeepers + instance.username=root #Accumulo username + instance.password=secret #Accumulo pwd + rya.tableprefix=triplestore_ #Rya Table Prefix + rya.displayqueryplan=true #To display the query plan + + +Start the Tomcat server. {{./bin/startup.sh}} + +## Usage + +### Load Data + +#### Web REST endpoint + +The War sets up a Web REST endpoint at {{http://server/web.rya/loadrdf}} that allows POST data to get loaded into the Rdf Store. This short tutorial will use Java code to post data. + +First, you will need data to load and will need to figure out what format that data is in. + +For this sample, we will use the following N-Triples: + + <http://mynamespace/ProductType1> <http://www.w3.org/1999/02/22-rdf-syntax-ns#type> <http://mynamespace/ProductType> . + <http://mynamespace/ProductType1> <http://www.w3.org/2000/01/rdf-schema#label> "Thing" . + <http://mynamespace/ProductType1> <http://purl.org/dc/elements/1.1/publisher> <http://mynamespace/Publisher1> . + + +Save this file somewhere $RDF_DATA + +Second, use the following Java code to load data to the REST endpoint: + + import java.io.BufferedReader; + import java.io.InputStream; + import java.io.InputStreamReader; + import java.io.OutputStream; + import java.net.URL; + import java.net.URLConnection; + + public class LoadDataServletRun { + + public static void main(String[] args) { + try { + final InputStream resourceAsStream = Thread.currentThread().getContextClassLoader() + .getResourceAsStream("$RDF_DATA"); + URL url = new URL("http://server/web.rya/loadrdf"; + + "?format=N-Triples" + + ""); + URLConnection urlConnection = url.openConnection(); + urlConnection.setRequestProperty("Content-Type", "text/plain"); + urlConnection.setDoOutput(true); + + final OutputStream os = urlConnection.getOutputStream(); + + int read; + while((read = resourceAsStream.read()) >= 0) { + os.write(read); + } + resourceAsStream.close(); + os.flush(); + + BufferedReader rd = new BufferedReader(new InputStreamReader( + urlConnection.getInputStream())); + String line; + while ((line = rd.readLine()) != null) { + System.out.println(line); + } + rd.close(); + os.close(); + } catch (Exception e) { + e.printStackTrace(); + } + } + } + + +Compile and run this code above, changing the references for $RDF_DATA and the url that your Rdf War is running at. + +The default "format" is RDF/XML, but these formats are supported : RDFXML, NTRIPLES, TURTLE, N3, TRIX, TRIG. + +#### Bulk Loading data + +Bulk loading data is done through Map Reduce jobs + +##### Bulk Load RDF data + + This Map Reduce job will read a full file into memory and parse it into statements. The statements are saved into the store. Here is an example for storing in Accumulo: +{code} +hadoop jar target/accumulo.rya-3.0.4-SNAPSHOT-shaded.jar mvm.rya.accumulo.mr.fileinput.BulkNtripsInputTool -Dac.zk=localhost:2181 -Dac.instance=accumulo -Dac.username=root -Dac.pwd=secret -Drdf.tablePrefix=triplestore_ -Dio.sort.mb=64 /tmp/temp.ntrips +{code} + +Options: +* rdf.tablePrefix : The tables (spo, po, osp) are prefixed with this qualifier. The tables become: (rdf.tablePrefix)spo,(rdf.tablePrefix)po,(rdf.tablePrefix)osp +* ac.* : Accumulo connection parameters +* rdf.format : See RDFFormat from openrdf, samples include (Trig, N-Triples, RDF/XML) +* io.sort.mb : Higher the value, the faster the job goes. Just remember that you will need this much ram at least per mapper + +The argument is the directory/file to load. This file needs to be loaded into HDFS before running. + +#### Direct OpenRDF API + +Here is some sample code to load data directly through the OpenRDF API. (Loading N-Triples data) +You will need at least accumulo.rya-<version>, rya.api, rya.sail.impl on the classpath and transitive dependencies. I find that Maven is the easiest way to get a project dependency tree set up. + + + final RdfCloudTripleStore store = new RdfCloudTripleStore(); + AccumuloRdfConfiguration conf = new AccumuloRdfConfiguration(); + AccumuloRyaDAO dao = new AccumuloRdfDAO(); + Connector connector = new ZooKeeperInstance("instance", "zkserver:port").getConnector("user", "password"); + dao.setConnector(connector); + conf.setTablePrefix("rya_"); + dao.setConf(conf); + store.setRdfDao(dao); + + Repository myRepository = new RyaSailRepository(store); + myRepository.initialize(); + RepositoryConnection conn = myRepository.getConnection(); + + //load data from file + final File file = new File("ntriples.ntrips"); + conn.add(new FileInputStream(file), file.getName(), + RDFFormat.NTRIPLES, new Resource[]{}); + + conn.commit(); + + conn.close(); + myRepository.shutDown(); + + + +### Query Data + +#### Web JSP endpoint + +Open a url to {{http://server/web.rya/sparqlQuery.jsp}}. This simple form can run Sparql. + +### Web REST endpoint + +The War sets up a Web REST endpoint at {{http://server/web.rya/queryrdf}} that allows GET requests with queries. + +For this sample, we will assume you already loaded data from the [loaddata.html] tutorial + +Save this file somewhere $RDF_DATA + +Second, use the following Java code to load data to the REST endpoint: + + import java.io.BufferedReader; + import java.io.InputStreamReader; + import java.net.URL; + import java.net.URLConnection; + import java.net.URLEncoder; + + public class QueryDataServletRun { + + public static void main(String[] args) { + try { + String query = "select * where {\n" + + "<http://mynamespace/ProductType1> ?p ?o.\n" + + "}"; + + String queryenc = URLEncoder.encode(query, "UTF-8"); + + URL url = new URL("http://server/rdfTripleStore/queryrdf?query="; + queryenc); + URLConnection urlConnection = url.openConnection(); + urlConnection.setDoOutput(true); + + BufferedReader rd = new BufferedReader(new InputStreamReader( + urlConnection.getInputStream())); + String line; + while ((line = rd.readLine()) != null) { + System.out.println(line); + } + rd.close(); + } catch (Exception e) { + e.printStackTrace(); + } + } + } + + +Compile and run this code above, changing the url that your Rdf War is running at. + +#### Direct Code + +Here is a code snippet for directly running against Accumulo with the code. You will need at least accumulo.rya.jar, rya.api, rya.sail.impl on the classpath and transitive dependencies. I find that Maven is the easiest way to get a project dependency tree set up. + + + Connector connector = new ZooKeeperInstance("cbinstance", "zkserver:port").getConnector("cbuser", "cbpassword"); + + final RdfCloudTripleStore store = new RdfCloudTripleStore(); + AccumuloRyaDAO crdfdao = new AccumuloRyaDAO(); + crdfdao.setConnector(connector); + + AccumuloRdfConfiguration conf = new AccumuloRdfConfiguration(); + conf.setTablePrefix("rts_"); + conf.setDisplayQueryPlan(true); + crdfdao.setConf(conf); + store.setRdfDao(crdfdao); + + InferenceEngine inferenceEngine = new InferenceEngine(); + inferenceEngine.setRdfDao(crdfdao); + inferenceEngine.setConf(conf); + store.setInferenceEngine(inferenceEngine); + + Repository myRepository = new RyaSailRepository(store); + myRepository.initialize(); + + String query = "select * where {\n" + + "<http://mynamespace/ProductType1> ?p ?o.\n" + + "}"; + RepositoryConnection conn = myRepository.getConnection(); + System.out.println(query); + TupleQuery tupleQuery = conn.prepareTupleQuery( + QueryLanguage.SPARQL, query); + ValueFactory vf = ValueFactoryImpl.getInstance(); + + TupleQueryResultHandler writer = new SPARQLResultsXMLWriter(System.out); + tupleQuery.evaluate(new TupleQueryResultHandler() { + + int count = 0; + + @Override + public void startQueryResult(List<String> strings) throws TupleQueryResultHandlerException { + } + + @Override + public void endQueryResult() throws TupleQueryResultHandlerException { + } + + @Override + public void handleSolution(BindingSet bindingSet) throws TupleQueryResultHandlerException { + System.out.println(bindingSet); + } + }); + + conn.close(); + myRepository.shutDown(); http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/92ddfa59/common/pom.xml ---------------------------------------------------------------------- diff --git a/common/pom.xml b/common/pom.xml new file mode 100644 index 0000000..d0d5a9c --- /dev/null +++ b/common/pom.xml @@ -0,0 +1,17 @@ +<?xml version="1.0" encoding="utf-8"?> +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> + + <modelVersion>4.0.0</modelVersion> + <parent> + <groupId>mvm.rya</groupId> + <artifactId>parent</artifactId> + <version>3.2.9</version> + </parent> + <artifactId>rya.common</artifactId> + <packaging>pom</packaging> + <name>${project.groupId}.${project.artifactId}</name> + <modules> + <module>rya.api</module> + <module>rya.provenance</module> + </modules> +</project> http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/92ddfa59/common/rya.api/.gitignore ---------------------------------------------------------------------- diff --git a/common/rya.api/.gitignore b/common/rya.api/.gitignore new file mode 100644 index 0000000..b83d222 --- /dev/null +++ b/common/rya.api/.gitignore @@ -0,0 +1 @@ +/target/ http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/92ddfa59/common/rya.api/pom.xml ---------------------------------------------------------------------- diff --git a/common/rya.api/pom.xml b/common/rya.api/pom.xml new file mode 100644 index 0000000..f2278dd --- /dev/null +++ b/common/rya.api/pom.xml @@ -0,0 +1,60 @@ +<?xml version="1.0" encoding="UTF-8"?> +<project xmlns="http://maven.apache.org/POM/4.0.0"; xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd";> + <parent> + <groupId>mvm.rya</groupId> + <artifactId>rya.common</artifactId> + <version>3.2.9</version> + </parent> + <modelVersion>4.0.0</modelVersion> + + <artifactId>rya.api</artifactId> + <name>${project.groupId}.${project.artifactId}</name> + <dependencies> + <dependency> + <groupId>org.calrissian.mango</groupId> + <artifactId>mango-core</artifactId> + </dependency> + <dependency> + <groupId>org.openrdf.sesame</groupId> + <artifactId>sesame-model</artifactId> + <version>${openrdf.sesame.version}</version> + </dependency> + <dependency> + <groupId>junit</groupId> + <artifactId>junit</artifactId> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.openrdf.sesame</groupId> + <artifactId>sesame-query</artifactId> + <version>${openrdf.sesame.version}</version> + </dependency> + <dependency> + <groupId>org.openrdf.sesame</groupId> + <artifactId>sesame-queryalgebra-model</artifactId> + <version>${openrdf.sesame.version}</version> + </dependency> + <dependency> + <groupId>org.openrdf.sesame</groupId> + <artifactId>sesame-queryalgebra-evaluation</artifactId> + <version>${openrdf.sesame.version}</version> + </dependency> + <dependency> + <groupId>com.google.guava</groupId> + <artifactId>guava</artifactId> + </dependency> + <dependency> + <groupId>org.apache.hadoop</groupId> + <artifactId>hadoop-common</artifactId> + </dependency> + <dependency> + <groupId>org.apache.hadoop</groupId> + <artifactId>hadoop-core</artifactId> + </dependency> + <dependency> + <groupId>joda-time</groupId> + <artifactId>joda-time</artifactId> + </dependency> + </dependencies> + +</project> http://git-wip-us.apache.org/repos/asf/incubator-rya/blob/92ddfa59/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 new file mode 100644 index 0000000..4d8ce5a --- /dev/null +++ b/common/rya.api/src/main/java/mvm/rya/api/InvalidValueTypeMarkerRuntimeException.java @@ -0,0 +1,54 @@ +package mvm.rya.api; + +/* + * #%L + * mvm.rya.rya.api + * %% + * Copyright (C) 2014 Rya + * %% + * Licensed 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. + * #L% + */ + +/** + * 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; + } +}
