You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@jena.apache.org by rv...@apache.org on 2015/01/27 18:28:52 UTC
[59/59] [abbrv] jena git commit: Merge branch 'hadoop-rdf'
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 <rv...@apache.org>
Authored: Tue Jan 27 09:26:52 2015 -0800
Committer: Rob Vesse <rv...@apache.org>
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
----------------------------------------------------------------------