Merge branch 'hadoop-rdf' This brings the Elephas (RDF for Hadoop) modules onto master ready for an initial inclusion in the next Jena release
Project: http://git-wip-us.apache.org/repos/asf/jena/repo Commit: http://git-wip-us.apache.org/repos/asf/jena/commit/f026f0e7 Tree: http://git-wip-us.apache.org/repos/asf/jena/tree/f026f0e7 Diff: http://git-wip-us.apache.org/repos/asf/jena/diff/f026f0e7 Branch: refs/heads/master Commit: f026f0e7df7306f3414912c0c95cce3b95c4764f Parents: 9213a35 e89032b Author: Rob Vesse <[email protected]> Authored: Tue Jan 27 09:26:52 2015 -0800 Committer: Rob Vesse <[email protected]> Committed: Tue Jan 27 09:26:52 2015 -0800 ---------------------------------------------------------------------- jena-elephas/LICENSE | 176 ++++ jena-elephas/NOTICE | 5 + jena-elephas/jena-elephas-common/pom.xml | 54 ++ .../rdf/types/AbstractNodeTupleWritable.java | 193 +++++ .../rdf/types/CharacteristicSetWritable.java | 298 +++++++ .../rdf/types/CharacteristicWritable.java | 160 ++++ .../hadoop/rdf/types/NodeTupleWritable.java | 80 ++ .../jena/hadoop/rdf/types/NodeWritable.java | 188 +++++ .../jena/hadoop/rdf/types/QuadWritable.java | 136 +++ .../jena/hadoop/rdf/types/TripleWritable.java | 138 ++++ .../comparators/SimpleBinaryComparator.java | 34 + .../rdf/types/converters/ThriftConverter.java | 147 ++++ .../rdf/io/types/CharacteristicTests.java | 210 +++++ .../jena/hadoop/rdf/io/types/RdfTypesTest.java | 406 +++++++++ jena-elephas/jena-elephas-io/pom.xml | 67 ++ .../jena/hadoop/rdf/io/HadoopIOConstants.java | 49 ++ .../jena/hadoop/rdf/io/RdfIOConstants.java | 81 ++ .../io/input/AbstractNLineFileInputFormat.java | 70 ++ .../io/input/AbstractWholeFileInputFormat.java | 42 + .../hadoop/rdf/io/input/QuadsInputFormat.java | 46 ++ .../hadoop/rdf/io/input/TriplesInputFormat.java | 42 + .../rdf/io/input/TriplesOrQuadsInputFormat.java | 47 ++ .../io/input/jsonld/JsonLDQuadInputFormat.java | 39 + .../input/jsonld/JsonLDTripleInputFormat.java | 39 + .../input/nquads/BlockedNQuadsInputFormat.java | 53 ++ .../rdf/io/input/nquads/NQuadsInputFormat.java | 46 ++ .../nquads/WholeFileNQuadsInputFormat.java | 51 ++ .../ntriples/BlockedNTriplesInputFormat.java | 53 ++ .../io/input/ntriples/NTriplesInputFormat.java | 46 ++ .../ntriples/WholeFileNTriplesInputFormat.java | 51 ++ .../io/input/rdfjson/RdfJsonInputFormat.java | 46 ++ .../rdf/io/input/rdfxml/RdfXmlInputFormat.java | 46 ++ .../AbstractBlockBasedNodeTupleReader.java | 344 ++++++++ .../readers/AbstractBlockBasedQuadReader.java | 51 ++ .../readers/AbstractBlockBasedTripleReader.java | 51 ++ .../AbstractLineBasedNodeTupleReader.java | 265 ++++++ .../readers/AbstractLineBasedQuadReader.java | 50 ++ .../readers/AbstractLineBasedTripleReader.java | 51 ++ .../rdf/io/input/readers/AbstractRdfReader.java | 108 +++ .../AbstractWholeFileNodeTupleReader.java | 328 ++++++++ .../readers/AbstractWholeFileQuadReader.java | 51 ++ .../readers/AbstractWholeFileTripleReader.java | 51 ++ .../rdf/io/input/readers/QuadsReader.java | 49 ++ .../io/input/readers/TriplesOrQuadsReader.java | 72 ++ .../rdf/io/input/readers/TriplesReader.java | 49 ++ .../io/input/readers/TriplesToQuadsReader.java | 102 +++ .../input/readers/jsonld/JsonLDQuadReader.java | 32 + .../readers/jsonld/JsonLDTripleReader.java | 30 + .../readers/nquads/BlockedNQuadsReader.java | 45 + .../io/input/readers/nquads/NQuadsReader.java | 49 ++ .../readers/nquads/WholeFileNQuadsReader.java | 42 + .../readers/ntriples/BlockedNTriplesReader.java | 45 + .../input/readers/ntriples/NTriplesReader.java | 48 ++ .../ntriples/WholeFileNTriplesReader.java | 42 + .../io/input/readers/rdfjson/RdfJsonReader.java | 37 + .../io/input/readers/rdfxml/RdfXmlReader.java | 37 + .../input/readers/thrift/ThriftQuadReader.java | 32 + .../readers/thrift/ThriftTripleReader.java | 30 + .../rdf/io/input/readers/trig/TriGReader.java | 37 + .../rdf/io/input/readers/trix/TriXReader.java | 37 + .../io/input/readers/turtle/TurtleReader.java | 37 + .../io/input/thrift/ThriftQuadInputFormat.java | 39 + .../input/thrift/ThriftTripleInputFormat.java | 39 + .../rdf/io/input/trig/TriGInputFormat.java | 46 ++ .../rdf/io/input/trix/TriXInputFormat.java | 42 + .../rdf/io/input/turtle/TurtleInputFormat.java | 46 ++ .../rdf/io/input/util/BlockInputStream.java | 94 +++ .../hadoop/rdf/io/input/util/RdfIOUtils.java | 101 +++ .../rdf/io/input/util/TrackableInputStream.java | 38 + .../rdf/io/input/util/TrackedInputStream.java | 124 +++ .../io/input/util/TrackedPipedQuadsStream.java | 55 ++ .../io/input/util/TrackedPipedRDFStream.java | 64 ++ .../input/util/TrackedPipedTriplesStream.java | 56 ++ .../AbstractBatchedNodeTupleOutputFormat.java | 55 ++ .../rdf/io/output/AbstractNodeOutputFormat.java | 94 +++ .../output/AbstractNodeTupleOutputFormat.java | 109 +++ .../AbstractStreamRdfNodeTupleOutputFormat.java | 73 ++ .../hadoop/rdf/io/output/QuadsOutputFormat.java | 64 ++ .../io/output/TriplesOrQuadsOutputFormat.java | 74 ++ .../rdf/io/output/TriplesOutputFormat.java | 61 ++ .../output/jsonld/JsonLDQuadOutputFormat.java | 44 + .../output/jsonld/JsonLDTripleOutputFormat.java | 44 + .../io/output/nquads/NQuadsOutputFormat.java | 52 ++ .../ntriples/NTriplesNodeOutputFormat.java | 45 + .../output/ntriples/NTriplesOutputFormat.java | 52 ++ .../io/output/rdfjson/RdfJsonOutputFormat.java | 52 ++ .../io/output/rdfxml/RdfXmlOutputFormat.java | 52 ++ .../output/thrift/ThriftQuadOutputFormat.java | 51 ++ .../output/thrift/ThriftTripleOutputFormat.java | 52 ++ .../io/output/trig/BatchedTriGOutputFormat.java | 54 ++ .../rdf/io/output/trig/TriGOutputFormat.java | 58 ++ .../rdf/io/output/trix/TriXOutputFormat.java | 57 ++ .../turtle/BatchedTurtleOutputFormat.java | 50 ++ .../io/output/turtle/TurtleOutputFormat.java | 56 ++ .../writers/AbstractBatchedNodeTupleWriter.java | 113 +++ .../writers/AbstractBatchedQuadWriter.java | 80 ++ .../writers/AbstractBatchedTripleWriter.java | 68 ++ .../AbstractLineBasedNodeTupleWriter.java | 152 ++++ .../writers/AbstractLineBasedQuadWriter.java | 71 ++ .../writers/AbstractLineBasedTripleWriter.java | 68 ++ .../io/output/writers/AbstractNodeWriter.java | 192 +++++ .../AbstractStreamRdfNodeTupleWriter.java | 71 ++ .../AbstractWholeFileNodeTupleWriter.java | 96 +++ .../writers/AbstractWholeFileQuadWriter.java | 66 ++ .../writers/AbstractWholeFileTripleWriter.java | 65 ++ .../io/output/writers/QuadsToTriplesWriter.java | 59 ++ .../io/output/writers/StreamRdfQuadWriter.java | 45 + .../output/writers/StreamRdfTripleWriter.java | 44 + .../output/writers/jsonld/JsonLDQuadWriter.java | 38 + .../writers/jsonld/JsonLDTripleWriter.java | 38 + .../io/output/writers/nquads/NQuadsWriter.java | 57 ++ .../writers/ntriples/NTriplesNodeWriter.java | 59 ++ .../output/writers/ntriples/NTriplesWriter.java | 58 ++ .../output/writers/rdfjson/RdfJsonWriter.java | 51 ++ .../io/output/writers/rdfxml/RdfXmlWriter.java | 51 ++ .../output/writers/thrift/ThriftQuadWriter.java | 38 + .../writers/thrift/ThriftTripleWriter.java | 38 + .../output/writers/trig/BatchedTriGWriter.java | 52 ++ .../writers/turtle/BatchedTurtleWriter.java | 54 ++ .../rdf/io/registry/HadoopRdfIORegistry.java | 310 +++++++ .../hadoop/rdf/io/registry/ReaderFactory.java | 83 ++ .../hadoop/rdf/io/registry/WriterFactory.java | 96 +++ .../readers/AbstractQuadsOnlyReaderFactory.java | 83 ++ .../registry/readers/AbstractReaderFactory.java | 80 ++ .../AbstractTriplesOnlyReaderFactory.java | 83 ++ .../registry/readers/JsonLDReaderFactory.java | 49 ++ .../registry/readers/NQuadsReaderFactory.java | 42 + .../registry/readers/NTriplesReaderFactory.java | 38 + .../registry/readers/RdfJsonReaderFactory.java | 41 + .../registry/readers/RdfXmlReaderFactory.java | 40 + .../registry/readers/ThriftReaderFactory.java | 49 ++ .../io/registry/readers/TriGReaderFactory.java | 42 + .../io/registry/readers/TriXReaderFactory.java | 41 + .../registry/readers/TurtleReaderFactory.java | 40 + .../writers/AbstractQuadsOnlyWriterFactory.java | 86 ++ .../AbstractTriplesOnlyWriterFactory.java | 85 ++ .../registry/writers/AbstractWriterFactory.java | 82 ++ .../registry/writers/JsonLDWriterFactory.java | 52 ++ .../registry/writers/NQuadsWriterFactory.java | 44 + .../registry/writers/NTriplesWriterFactory.java | 44 + .../registry/writers/RdfJsonWriterFactory.java | 43 + .../registry/writers/RdfXmlWriterFactory.java | 44 + .../registry/writers/ThriftWriterFactory.java | 57 ++ .../io/registry/writers/TriGWriterFactory.java | 45 + .../io/registry/writers/TriXWriterFactory.java | 47 ++ .../registry/writers/TurtleWriterFactory.java | 45 + ...he.jena.hadoop.rdf.io.registry.ReaderFactory | 10 + ...he.jena.hadoop.rdf.io.registry.WriterFactory | 10 + .../rdf/io/RdfTriplesInputTestMapper.java | 47 ++ .../AbstractBlockedQuadInputFormatTests.java | 33 + .../AbstractBlockedTripleInputFormatTests.java | 33 + .../AbstractNodeTupleInputFormatTests.java | 612 ++++++++++++++ .../io/input/AbstractQuadsInputFormatTests.java | 70 ++ .../input/AbstractTriplesInputFormatTests.java | 72 ++ .../AbstractWholeFileQuadInputFormatTests.java | 115 +++ ...AbstractWholeFileTripleInputFormatTests.java | 108 +++ .../io/input/bnodes/AbstractBlankNodeTests.java | 636 ++++++++++++++ .../bnodes/AbstractTripleBlankNodeTests.java | 65 ++ .../input/bnodes/JsonLdTripleBlankNodeTest.java | 63 ++ .../io/input/bnodes/NTriplesBlankNodeTest.java | 58 ++ .../io/input/bnodes/RdfJsonBlankNodeTest.java | 58 ++ .../io/input/bnodes/RdfThriftBlankNodeTest.java | 68 ++ .../io/input/bnodes/RdfXmlBlankNodeTest.java | 62 ++ .../io/input/bnodes/TurtleBlankNodeTest.java | 58 ++ ...ractCompressedNodeTupleInputFormatTests.java | 74 ++ ...AbstractCompressedQuadsInputFormatTests.java | 71 ++ ...stractCompressedTriplesInputFormatTests.java | 71 ++ ...CompressedWholeFileQuadInputFormatTests.java | 150 ++++ ...mpressedWholeFileTripleInputFormatTests.java | 144 ++++ ...actCompressedJsonLDQuadInputFormatTests.java | 74 ++ ...tCompressedJsonLDTripleInputFormatTests.java | 74 ++ .../jsonld/BZippedJsonLDQuadInputTest.java | 34 + .../jsonld/BZippedJsonLDTripleInputTest.java | 34 + .../jsonld/DeflatedJsonLDQuadInputTest.java | 34 + .../jsonld/DeflatedJsonLDTripleInputTest.java | 34 + .../jsonld/GZippedJsonLDQuadInputTest.java | 34 + .../jsonld/GZippedJsonLDTripleInputTest.java | 34 + ...bstractCompressedNQuadsInputFormatTests.java | 68 ++ ...mpressedWholeFileNQuadsInputFormatTests.java | 75 ++ .../nquads/BZipppedNQuadsInputTest.java | 38 + .../BZipppedWholeFileNQuadsInputTest.java | 37 + .../nquads/DeflatedNQuadsInputTest.java | 37 + .../DeflatedWholeFileNQuadsInputTest.java | 37 + .../nquads/GZippedNQuadsInputTest.java | 38 + .../nquads/GZippedWholeFileNQuadsInputTest.java | 38 + ...mpressedBlockedNTriplesInputFormatTests.java | 53 ++ ...tractCompressedNTriplesInputFormatTests.java | 68 ++ ...ressedWholeFileNTriplesInputFormatTests.java | 75 ++ .../ntriples/BZippedBlockedNTriplesInput.java | 37 + .../ntriples/BZippedNTriplesInputTest.java | 38 + .../BZippedWholeFileNTriplesInputTest.java | 38 + .../ntriples/DeflatedBlockedNTriplesInput.java | 37 + .../ntriples/DeflatedNTriplesInputTest.java | 38 + .../DeflatedWholeFileNTriplesInputTest.java | 38 + .../ntriples/GZippedBlockedNTriplesInput.java | 37 + .../ntriples/GZippedNTriplesInputTest.java | 41 + .../GZippedWholeFileNTriplesInputTest.java | 38 + ...stractCompressedRdfJsonInputFormatTests.java | 74 ++ .../rdfjson/BZippedRdfJsonInputTest.java | 37 + .../rdfjson/DeflatedRdfJsonInputTest.java | 37 + .../rdfjson/GZippedRdfJsonInputTest.java | 37 + ...bstractCompressedRdfXmlInputFormatTests.java | 75 ++ .../rdfxml/BZippedRdfXmlInputTest.java | 37 + .../rdfxml/DeflatedRdfXmlInputTest.java | 37 + .../rdfxml/GZippedRdfXmlInputTest.java | 37 + ...actCompressedThriftQuadInputFormatTests.java | 72 ++ ...tCompressedThriftTripleInputFormatTests.java | 72 ++ .../thrift/BZippedThriftQuadInputTest.java | 34 + .../thrift/BZippedThriftTripleInputTest.java | 34 + .../thrift/DeflatedThriftQuadInputTest.java | 34 + .../thrift/DeflatedThriftTripleInputTest.java | 34 + .../thrift/GZippedThriftQuadInputTest.java | 34 + .../thrift/GZippedThriftTripleInputTest.java | 34 + .../AbstractCompressedTriGInputFormatTests.java | 72 ++ .../compressed/trig/BZippedTriGInputTest.java | 37 + .../compressed/trig/DeflatedTriGInputTest.java | 37 + .../compressed/trig/GZippedTriGInputTest.java | 37 + .../AbstractCompressedTriXInputFormatTests.java | 72 ++ .../compressed/trix/BZippedTriXInputTest.java | 35 + .../compressed/trix/DeflatedTriXInputTest.java | 35 + .../compressed/trix/GZippedTriXInputTest.java | 35 + ...bstractCompressedTurtleInputFormatTests.java | 75 ++ .../turtle/BZippedTurtleInputTest.java | 37 + .../turtle/DeflatedTurtleInputTest.java | 37 + .../turtle/GZippedTurtleInputTest.java | 37 + .../io/input/jsonld/JsonLDQuadInputTest.java | 50 ++ .../io/input/jsonld/JsonLDTripleInputTest.java | 50 ++ .../io/input/nquads/BlockedNQuadsInputTest.java | 51 ++ .../rdf/io/input/nquads/NQuadsInputTest.java | 44 + .../input/nquads/WholeFileNQuadsInputTest.java | 51 ++ .../ntriples/BlockedNTriplesInputTest.java | 50 ++ .../io/input/ntriples/NTriplesInputTest.java | 44 + .../ntriples/WholeFileNTriplesInputTest.java | 52 ++ .../rdf/io/input/rdfjson/RdfJsonInputTest.java | 51 ++ .../rdf/io/input/rdfxml/RdfXmlInputTest.java | 51 ++ .../io/input/thrift/ThriftQuadInputTest.java | 51 ++ .../io/input/thrift/ThriftTripleInputTest.java | 51 ++ .../hadoop/rdf/io/input/trig/TriGInputTest.java | 50 ++ .../hadoop/rdf/io/input/trix/TriXInputTest.java | 50 ++ .../rdf/io/input/turtle/TurtleInputTest.java | 50 ++ .../util/AbstractTrackableInputStreamTests.java | 701 ++++++++++++++++ .../rdf/io/input/util/BlockInputStreamTest.java | 240 ++++++ .../io/input/util/TrackedInputStreamTest.java | 39 + .../AbstractNodeTupleOutputFormatTests.java | 255 ++++++ .../output/AbstractQuadOutputFormatTests.java | 51 ++ .../output/AbstractTripleOutputFormatTests.java | 47 ++ .../io/output/jsonld/JsonLdQuadOutputTest.java | 47 ++ .../output/jsonld/JsonLdTripleOutputTest.java | 47 ++ .../rdf/io/output/nquads/NQuadsOutputTest.java | 51 ++ .../io/output/ntriples/NTriplesOutputTest.java | 51 ++ .../io/output/rdfjson/RdfJsonOutputTest.java | 51 ++ .../rdf/io/output/rdfxml/RdfXmlOutputTest.java | 51 ++ .../io/output/thrift/ThriftQuadOutputTest.java | 48 ++ .../output/thrift/ThriftTripleOutputTest.java | 48 ++ .../io/output/trig/BatchedTriGOutputTest.java | 92 +++ .../io/output/trig/StreamedTriGOutputTest.java | 92 +++ .../output/trig/TriGBlankNodeOutputTests.java | 120 +++ .../rdf/io/output/trix/TriXOutputTest.java | 47 ++ .../output/turtle/BatchedTurtleOutputTest.java | 92 +++ .../output/turtle/StreamedTurtleOutputTest.java | 92 +++ .../turtle/TurtleBlankNodeOutputTests.java | 118 +++ .../io/registry/TestHadoopRdfIORegistry.java | 186 +++++ jena-elephas/jena-elephas-mapreduce/pom.xml | 87 ++ .../jena/hadoop/rdf/mapreduce/KeyMapper.java | 54 ++ .../hadoop/rdf/mapreduce/KeyPlusNullMapper.java | 55 ++ .../jena/hadoop/rdf/mapreduce/KeyReducer.java | 39 + .../hadoop/rdf/mapreduce/NullPlusKeyMapper.java | 55 ++ .../rdf/mapreduce/NullPlusKeyReducer.java | 59 ++ .../rdf/mapreduce/NullPlusValueMapper.java | 55 ++ .../rdf/mapreduce/NullPlusValueReducer.java | 64 ++ .../rdf/mapreduce/RdfMapReduceConstants.java | 67 ++ .../jena/hadoop/rdf/mapreduce/SwapMapper.java | 55 ++ .../jena/hadoop/rdf/mapreduce/SwapReducer.java | 43 + .../hadoop/rdf/mapreduce/TextCountReducer.java | 49 ++ .../jena/hadoop/rdf/mapreduce/ValueMapper.java | 54 ++ .../rdf/mapreduce/ValuePlusNullMapper.java | 55 ++ .../jena/hadoop/rdf/mapreduce/ValueReducer.java | 44 + ...tractCharacteristicSetGeneratingReducer.java | 179 ++++ .../CharacteristicSetReducer.java | 68 ++ .../QuadCharacteristicSetGeneratingReducer.java | 39 + ...ripleCharacteristicSetGeneratingReducer.java | 40 + .../count/AbstractNodeTupleNodeCountMapper.java | 66 ++ .../rdf/mapreduce/count/NodeCountReducer.java | 50 ++ .../mapreduce/count/QuadNodeCountMapper.java | 44 + .../mapreduce/count/TripleNodeCountMapper.java | 42 + .../datatypes/QuadDataTypeCountMapper.java | 56 ++ .../datatypes/TripleDataTypeCountMapper.java | 56 ++ .../AbstractNodeTupleNamespaceCountMapper.java | 135 +++ .../namespaces/QuadNamespaceCountMapper.java | 44 + .../namespaces/TripleNamespaceCountMapper.java | 44 + .../count/positional/QuadGraphCountMapper.java | 42 + .../count/positional/QuadObjectCountMapper.java | 42 + .../positional/QuadPredicateCountMapper.java | 42 + .../positional/QuadSubjectCountMapper.java | 41 + .../positional/TripleObjectCountMapper.java | 41 + .../positional/TriplePredicateCountMapper.java | 42 + .../positional/TripleSubjectCountMapper.java | 41 + .../filter/AbstractNodeTupleFilterMapper.java | 76 ++ .../filter/AbstractQuadFilterMapper.java | 35 + .../filter/AbstractTripleFilterMapper.java | 35 + .../filter/GroundQuadFilterMapper.java | 47 ++ .../filter/GroundTripleFilterMapper.java | 47 ++ .../mapreduce/filter/ValidQuadFilterMapper.java | 48 ++ .../filter/ValidTripleFilterMapper.java | 47 ++ .../AbstractQuadFilterByPositionMapper.java | 171 ++++ .../AbstractTripleFilterByPositionMapper.java | 141 ++++ .../positional/QuadFilterByGraphUriMapper.java | 76 ++ .../positional/QuadFilterByObjectUriMapper.java | 76 ++ .../positional/QuadFilterByPredicateMapper.java | 76 ++ .../QuadFilterBySubjectUriMapper.java | 76 ++ .../TripleFilterByObjectUriMapper.java | 71 ++ .../TripleFilterByPredicateUriMapper.java | 71 ++ .../TripleFilterBySubjectUriMapper.java | 71 ++ .../group/AbstractNodeTupleGroupingMapper.java | 60 ++ .../group/AbstractQuadGroupingMapper.java | 50 ++ .../group/AbstractTripleGroupingMapper.java | 44 + .../mapreduce/group/QuadGroupByGraphMapper.java | 39 + .../group/QuadGroupByObjectMapper.java | 39 + .../group/QuadGroupByPredicateMapper.java | 39 + .../group/QuadGroupBySubjectMapper.java | 39 + .../group/TripleGroupByObjectMapper.java | 41 + .../group/TripleGroupByPredicateMapper.java | 41 + .../group/TripleGroupBySubjectMapper.java | 41 + .../AbstractNodeTupleSplitToNodesMapper.java | 60 ++ .../AbstractNodeTupleSplitWithNodesMapper.java | 60 ++ .../mapreduce/split/QuadSplitToNodesMapper.java | 43 + .../split/QuadSplitWithNodesMapper.java | 43 + .../split/TripleSplitToNodesMapper.java | 41 + .../split/TripleSplitWithNodesMapper.java | 41 + .../transform/AbstractTriplesToQuadsMapper.java | 60 ++ .../transform/QuadsToTriplesMapper.java | 46 ++ .../TriplesToQuadsBySubjectMapper.java | 40 + .../TriplesToQuadsConstantGraphMapper.java | 75 ++ .../rdf/mapreduce/AbstractMapReduceTests.java | 69 ++ .../rdf/mapreduce/AbstractMapperTests.java | 69 ++ .../rdf/mapreduce/TestDistinctTriples.java | 129 +++ ...CharacteristicSetGeneratingReducerTests.java | 185 +++++ .../CharacteristicSetReducerTest.java | 192 +++++ ...eCharacteristicSetGeneratingReducerTest.java | 59 ++ .../AbstractNodeTupleNodeCountReducedTests.java | 149 ++++ .../count/AbstractNodeTupleNodeCountTests.java | 138 ++++ .../count/QuadNodeCountMapReduceTest.java | 67 ++ .../count/QuadNodeCountMapperTest.java | 59 ++ .../count/TripleNodeCountMapReduceTest.java | 66 ++ .../count/TripleNodeCountMapperTest.java | 58 ++ .../filter/AbstractNodeTupleFilterTests.java | 146 ++++ .../filter/AbstractQuadValidityFilterTests.java | 86 ++ .../AbstractTripleValidityFilterTests.java | 73 ++ .../TripleFilterByNoPredicateMapperTest.java | 49 ++ .../TripleFilterByPredicateMapperTest.java | 80 ++ ...leInvertedFilterByNoPredicateMapperTest.java | 54 ++ ...ipleInvertedFilterByPredicateMapperTest.java | 87 ++ .../filter/ValidQuadFilterMapperTest.java | 40 + .../filter/ValidTripleFilterMapperTest.java | 40 + .../group/AbstractNodeTupleGroupingTests.java | 114 +++ .../group/AbstractQuadGroupingTests.java | 43 + .../group/AbstractTripleGroupingTests.java | 41 + .../group/QuadGroupByGraphMapperTest.java | 46 ++ .../group/QuadGroupByObjectMapperTest.java | 46 ++ .../group/QuadGroupByPredicateMapperTest.java | 46 ++ .../group/QuadGroupBySubjectMapperTest.java | 46 ++ .../group/TripleGroupByObjectMapperTest.java | 46 ++ .../group/TripleGroupByPredicateMapperTest.java | 46 ++ .../group/TripleGroupBySubjectMapperTest.java | 46 ++ .../AbstractNodeTupleSplitToNodesTests.java | 116 +++ .../AbstractNodeTupleSplitWithNodesTests.java | 116 +++ .../split/AbstractQuadSplitToNodesTests.java | 53 ++ .../split/AbstractQuadSplitWithNodesTests.java | 53 ++ .../split/AbstractTripleSplitToNodesTests.java | 52 ++ .../AbstractTripleSplitWithNodesTests.java | 52 ++ .../split/QuadSplitToNodesMapperTest.java | 41 + .../split/QuadSplitWithNodesMapperTest.java | 41 + .../split/TripleSplitToNodesMapperTest.java | 41 + .../split/TripleSplitWithNodesMapperTest.java | 42 + .../transform/QuadsToTriplesMapperTest.java | 113 +++ .../TriplesToQuadsBySubjectMapperTest.java | 113 +++ .../TriplesToQuadsConstantGraphMapperTest.java | 113 +++ jena-elephas/jena-elephas-stats/hadoop-job.xml | 46 ++ jena-elephas/jena-elephas-stats/pom.xml | 102 +++ .../apache/jena/hadoop/rdf/stats/RdfStats.java | 421 ++++++++++ .../jena/hadoop/rdf/stats/jobs/JobFactory.java | 821 +++++++++++++++++++ jena-elephas/pom.xml | 110 +++ jena-jdbc/jena-jdbc-driver-bundle/pom.xml | 2 +- jena-parent/pom.xml | 68 +- pom.xml | 4 + 385 files changed, 28374 insertions(+), 28 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/jena/blob/f026f0e7/jena-parent/pom.xml ----------------------------------------------------------------------
