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/05/21 11:58:13 UTC
[1/2] jena git commit: JENA-938: Nonfunctional cleanup in jena-elephas
Repository: jena
Updated Branches:
refs/heads/master 36dcea59e -> 11f87bfd4
JENA-938: Nonfunctional cleanup in jena-elephas
Project: http://git-wip-us.apache.org/repos/asf/jena/repo
Commit: http://git-wip-us.apache.org/repos/asf/jena/commit/59150221
Tree: http://git-wip-us.apache.org/repos/asf/jena/tree/59150221
Diff: http://git-wip-us.apache.org/repos/asf/jena/diff/59150221
Branch: refs/heads/master
Commit: 59150221aaacd8b60c803708887bb406237eb35b
Parents: e5035f4
Author: ajs6f <aj...@virginia.edu>
Authored: Tue May 19 14:45:21 2015 -0400
Committer: ajs6f <aj...@virginia.edu>
Committed: Tue May 19 14:45:21 2015 -0400
----------------------------------------------------------------------
.../hadoop/rdf/io/input/QuadsInputFormat.java | 5 +---
.../hadoop/rdf/io/input/TriplesInputFormat.java | 5 +---
.../rdf/io/input/TriplesOrQuadsInputFormat.java | 5 +---
.../io/input/jsonld/JsonLDQuadInputFormat.java | 5 +---
.../input/jsonld/JsonLDTripleInputFormat.java | 5 +---
.../input/nquads/BlockedNQuadsInputFormat.java | 5 +---
.../rdf/io/input/nquads/NQuadsInputFormat.java | 5 +---
.../nquads/WholeFileNQuadsInputFormat.java | 5 +---
.../ntriples/BlockedNTriplesInputFormat.java | 5 +---
.../io/input/ntriples/NTriplesInputFormat.java | 5 +---
.../ntriples/WholeFileNTriplesInputFormat.java | 5 +---
.../io/input/rdfjson/RdfJsonInputFormat.java | 5 +---
.../rdf/io/input/rdfxml/RdfXmlInputFormat.java | 5 +---
.../AbstractBlockBasedNodeTupleReader.java | 10 ++++----
.../AbstractLineBasedNodeTupleReader.java | 12 +++++-----
.../AbstractWholeFileNodeTupleReader.java | 10 ++++----
.../io/input/thrift/ThriftQuadInputFormat.java | 5 +---
.../input/thrift/ThriftTripleInputFormat.java | 5 +---
.../rdf/io/input/trig/TriGInputFormat.java | 5 +---
.../rdf/io/input/trix/TriXInputFormat.java | 5 +---
.../rdf/io/input/turtle/TurtleInputFormat.java | 5 +---
.../rdf/io/output/AbstractNodeOutputFormat.java | 4 ++--
.../output/AbstractNodeTupleOutputFormat.java | 4 ++--
.../writers/AbstractBatchedNodeTupleWriter.java | 4 ++--
.../AbstractLineBasedNodeTupleWriter.java | 5 ++--
.../io/output/writers/AbstractNodeWriter.java | 5 ++--
.../AbstractStreamRdfNodeTupleWriter.java | 6 ++---
.../AbstractWholeFileNodeTupleWriter.java | 4 ++--
.../registry/readers/JsonLDReaderFactory.java | 6 ++---
.../registry/readers/NQuadsReaderFactory.java | 4 +---
.../registry/readers/NTriplesReaderFactory.java | 3 +--
.../registry/readers/RdfJsonReaderFactory.java | 4 +---
.../registry/readers/RdfXmlReaderFactory.java | 4 +---
.../registry/readers/ThriftReaderFactory.java | 6 ++---
.../io/registry/readers/TriGReaderFactory.java | 4 +---
.../io/registry/readers/TriXReaderFactory.java | 4 +---
.../registry/readers/TurtleReaderFactory.java | 4 +---
.../registry/writers/JsonLDWriterFactory.java | 7 ++----
.../registry/writers/NQuadsWriterFactory.java | 4 +---
.../registry/writers/NTriplesWriterFactory.java | 4 +---
.../registry/writers/RdfJsonWriterFactory.java | 4 +---
.../registry/writers/RdfXmlWriterFactory.java | 4 +---
.../registry/writers/ThriftWriterFactory.java | 7 ++----
.../io/registry/writers/TriGWriterFactory.java | 4 +---
.../io/registry/writers/TriXWriterFactory.java | 4 +---
.../registry/writers/TurtleWriterFactory.java | 4 +---
.../AbstractNodeTupleInputFormatTests.java | 25 +++++++++-----------
.../AbstractWholeFileQuadInputFormatTests.java | 2 +-
.../io/input/bnodes/AbstractBlankNodeTests.java | 2 --
...CompressedWholeFileQuadInputFormatTests.java | 2 +-
.../apache/jena/hadoop/rdf/stats/RdfStats.java | 5 ++--
51 files changed, 85 insertions(+), 186 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/QuadsInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/QuadsInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/QuadsInputFormat.java
index b8fdbd5..7136472 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/QuadsInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/QuadsInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -38,8 +36,7 @@ import org.apache.jena.hadoop.rdf.types.QuadWritable;
public class QuadsInputFormat extends AbstractWholeFileInputFormat<LongWritable, QuadWritable> {
@Override
- public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new QuadsReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/TriplesInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/TriplesInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/TriplesInputFormat.java
index 03f394a..62144f3 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/TriplesInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/TriplesInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -34,8 +32,7 @@ import org.apache.jena.hadoop.rdf.types.TripleWritable;
public class TriplesInputFormat extends AbstractWholeFileInputFormat<LongWritable, TripleWritable> {
@Override
- public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new TriplesReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/TriplesOrQuadsInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/TriplesOrQuadsInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/TriplesOrQuadsInputFormat.java
index bfd643e..50da740 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/TriplesOrQuadsInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/TriplesOrQuadsInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -39,8 +37,7 @@ import org.apache.jena.hadoop.rdf.types.QuadWritable;
public class TriplesOrQuadsInputFormat extends AbstractWholeFileInputFormat<LongWritable, QuadWritable> {
@Override
- public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new TriplesOrQuadsReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/jsonld/JsonLDQuadInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/jsonld/JsonLDQuadInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/jsonld/JsonLDQuadInputFormat.java
index 2464946..b4f788c 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/jsonld/JsonLDQuadInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/jsonld/JsonLDQuadInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input.jsonld;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -31,8 +29,7 @@ import org.apache.jena.hadoop.rdf.types.QuadWritable;
public class JsonLDQuadInputFormat extends AbstractWholeFileInputFormat<LongWritable, QuadWritable> {
@Override
- public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new JsonLDQuadReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/jsonld/JsonLDTripleInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/jsonld/JsonLDTripleInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/jsonld/JsonLDTripleInputFormat.java
index 0e08a4b..0166d01 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/jsonld/JsonLDTripleInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/jsonld/JsonLDTripleInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input.jsonld;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -31,8 +29,7 @@ import org.apache.jena.hadoop.rdf.types.TripleWritable;
public class JsonLDTripleInputFormat extends AbstractWholeFileInputFormat<LongWritable, TripleWritable> {
@Override
- public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new JsonLDTripleReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/nquads/BlockedNQuadsInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/nquads/BlockedNQuadsInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/nquads/BlockedNQuadsInputFormat.java
index 6829c4d..801f762 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/nquads/BlockedNQuadsInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/nquads/BlockedNQuadsInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input.nquads;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -45,8 +43,7 @@ import org.apache.jena.hadoop.rdf.types.QuadWritable;
public class BlockedNQuadsInputFormat extends AbstractNLineFileInputFormat<LongWritable, QuadWritable> {
@Override
- public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new BlockedNQuadsReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/nquads/NQuadsInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/nquads/NQuadsInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/nquads/NQuadsInputFormat.java
index 802fbea..e1110b6 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/nquads/NQuadsInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/nquads/NQuadsInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input.nquads;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -38,8 +36,7 @@ import org.apache.jena.hadoop.rdf.types.QuadWritable;
public class NQuadsInputFormat extends AbstractNLineFileInputFormat<LongWritable, QuadWritable> {
@Override
- public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit arg0, TaskAttemptContext arg1)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit arg0, TaskAttemptContext arg1) {
return new NQuadsReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/nquads/WholeFileNQuadsInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/nquads/WholeFileNQuadsInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/nquads/WholeFileNQuadsInputFormat.java
index 128d079..9d5966f 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/nquads/WholeFileNQuadsInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/nquads/WholeFileNQuadsInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input.nquads;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -43,8 +41,7 @@ import org.apache.jena.hadoop.rdf.types.QuadWritable;
public class WholeFileNQuadsInputFormat extends AbstractWholeFileInputFormat<LongWritable, QuadWritable> {
@Override
- public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new WholeFileNQuadsReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/ntriples/BlockedNTriplesInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/ntriples/BlockedNTriplesInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/ntriples/BlockedNTriplesInputFormat.java
index 292167b..3536f5d 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/ntriples/BlockedNTriplesInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/ntriples/BlockedNTriplesInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input.ntriples;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -45,8 +43,7 @@ import org.apache.jena.hadoop.rdf.types.TripleWritable;
public class BlockedNTriplesInputFormat extends AbstractNLineFileInputFormat<LongWritable, TripleWritable> {
@Override
- public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new BlockedNTriplesReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/ntriples/NTriplesInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/ntriples/NTriplesInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/ntriples/NTriplesInputFormat.java
index 1694c87..bbe4c9a 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/ntriples/NTriplesInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/ntriples/NTriplesInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input.ntriples;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -38,8 +36,7 @@ import org.apache.jena.hadoop.rdf.types.TripleWritable;
public class NTriplesInputFormat extends AbstractNLineFileInputFormat<LongWritable, TripleWritable> {
@Override
- public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit inputSplit, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit inputSplit, TaskAttemptContext context) {
return new NTriplesReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/ntriples/WholeFileNTriplesInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/ntriples/WholeFileNTriplesInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/ntriples/WholeFileNTriplesInputFormat.java
index 31c1252..5a06789 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/ntriples/WholeFileNTriplesInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/ntriples/WholeFileNTriplesInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input.ntriples;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -43,8 +41,7 @@ import org.apache.jena.hadoop.rdf.types.TripleWritable;
public class WholeFileNTriplesInputFormat extends AbstractWholeFileInputFormat<LongWritable, TripleWritable> {
@Override
- public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new WholeFileNTriplesReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/rdfjson/RdfJsonInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/rdfjson/RdfJsonInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/rdfjson/RdfJsonInputFormat.java
index e5a7940..29d0f6f 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/rdfjson/RdfJsonInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/rdfjson/RdfJsonInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input.rdfjson;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -38,8 +36,7 @@ import org.apache.jena.hadoop.rdf.types.TripleWritable;
public class RdfJsonInputFormat extends AbstractWholeFileInputFormat<LongWritable, TripleWritable> {
@Override
- public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new RdfJsonReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/rdfxml/RdfXmlInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/rdfxml/RdfXmlInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/rdfxml/RdfXmlInputFormat.java
index 4deb925..f231073 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/rdfxml/RdfXmlInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/rdfxml/RdfXmlInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input.rdfxml;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -38,8 +36,7 @@ import org.apache.jena.hadoop.rdf.types.TripleWritable;
public class RdfXmlInputFormat extends AbstractWholeFileInputFormat<LongWritable, TripleWritable> {
@Override
- public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new RdfXmlReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/readers/AbstractBlockBasedNodeTupleReader.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/readers/AbstractBlockBasedNodeTupleReader.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/readers/AbstractBlockBasedNodeTupleReader.java
index 56d031e..cf5e621 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/readers/AbstractBlockBasedNodeTupleReader.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/readers/AbstractBlockBasedNodeTupleReader.java
@@ -86,7 +86,7 @@ public abstract class AbstractBlockBasedNodeTupleReader<TValue, T extends Abstra
private Throwable parserError = null;
@Override
- public void initialize(InputSplit genericSplit, TaskAttemptContext context) throws IOException, InterruptedException {
+ public void initialize(InputSplit genericSplit, TaskAttemptContext context) throws IOException {
LOG.debug("initialize({}, {})", genericSplit, context);
// Assuming file split
@@ -242,7 +242,7 @@ public abstract class AbstractBlockBasedNodeTupleReader<TValue, T extends Abstra
protected abstract T createInstance(TValue tuple);
@Override
- public boolean nextKeyValue() throws IOException, InterruptedException {
+ public boolean nextKeyValue() throws IOException {
// Reuse key for efficiency
if (key == null) {
key = new LongWritable();
@@ -308,17 +308,17 @@ public abstract class AbstractBlockBasedNodeTupleReader<TValue, T extends Abstra
}
@Override
- public LongWritable getCurrentKey() throws IOException, InterruptedException {
+ public LongWritable getCurrentKey() {
return this.key;
}
@Override
- public T getCurrentValue() throws IOException, InterruptedException {
+ public T getCurrentValue() {
return this.tuple;
}
@Override
- public float getProgress() throws IOException, InterruptedException {
+ public float getProgress() {
float progress = 0.0f;
if (this.key == null) {
// We've either not started or we've finished
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/readers/AbstractLineBasedNodeTupleReader.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/readers/AbstractLineBasedNodeTupleReader.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/readers/AbstractLineBasedNodeTupleReader.java
index 6c1abe9..04adb3b 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/readers/AbstractLineBasedNodeTupleReader.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/readers/AbstractLineBasedNodeTupleReader.java
@@ -69,7 +69,7 @@ public abstract class AbstractLineBasedNodeTupleReader<TValue, T extends Abstrac
private boolean ignoreBadTuples = true;
@Override
- public final void initialize(InputSplit genericSplit, TaskAttemptContext context) throws IOException, InterruptedException {
+ public final void initialize(InputSplit genericSplit, TaskAttemptContext context) throws IOException {
LOG.debug("initialize({}, {})", genericSplit, context);
// Assuming file split
@@ -124,7 +124,7 @@ public abstract class AbstractLineBasedNodeTupleReader<TValue, T extends Abstrac
// This is to do with how line reader reads lines and how
// NLineInputFormat will provide the split information to use
if (skipFirstLine) {
- start += in.readLine(new Text(), 0, (int) Math.min((long) Integer.MAX_VALUE, end - start));
+ start += in.readLine(new Text(), 0, (int) Math.min(Integer.MAX_VALUE, end - start));
}
this.pos = start;
}
@@ -150,7 +150,7 @@ public abstract class AbstractLineBasedNodeTupleReader<TValue, T extends Abstrac
protected abstract T createInstance(TValue tuple);
@Override
- public final boolean nextKeyValue() throws IOException, InterruptedException {
+ public final boolean nextKeyValue() throws IOException {
// Reuse key for efficiency
if (key == null) {
key = new LongWritable();
@@ -225,19 +225,19 @@ public abstract class AbstractLineBasedNodeTupleReader<TValue, T extends Abstrac
}
@Override
- public LongWritable getCurrentKey() throws IOException, InterruptedException {
+ public LongWritable getCurrentKey() {
LOG.debug("getCurrentKey() --> {}", key);
return key;
}
@Override
- public T getCurrentValue() throws IOException, InterruptedException {
+ public T getCurrentValue() {
LOG.debug("getCurrentValue() --> {}", tuple);
return tuple;
}
@Override
- public float getProgress() throws IOException, InterruptedException {
+ public float getProgress() {
float progress = 0.0f;
if (start != end) {
if (end == Long.MAX_VALUE) {
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/readers/AbstractWholeFileNodeTupleReader.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/readers/AbstractWholeFileNodeTupleReader.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/readers/AbstractWholeFileNodeTupleReader.java
index c2da3f7..dd738d6 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/readers/AbstractWholeFileNodeTupleReader.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/readers/AbstractWholeFileNodeTupleReader.java
@@ -88,7 +88,7 @@ public abstract class AbstractWholeFileNodeTupleReader<TValue, T extends Abstrac
private Throwable parserError = null;
@Override
- public void initialize(InputSplit genericSplit, TaskAttemptContext context) throws IOException, InterruptedException {
+ public void initialize(InputSplit genericSplit, TaskAttemptContext context) throws IOException {
LOG.debug("initialize({}, {})", genericSplit, context);
// Assuming file split
@@ -229,7 +229,7 @@ public abstract class AbstractWholeFileNodeTupleReader<TValue, T extends Abstrac
protected abstract T createInstance(TValue tuple);
@Override
- public boolean nextKeyValue() throws IOException, InterruptedException {
+ public boolean nextKeyValue() throws IOException {
// Reuse key for efficiency
if (key == null) {
key = new LongWritable();
@@ -292,17 +292,17 @@ public abstract class AbstractWholeFileNodeTupleReader<TValue, T extends Abstrac
}
@Override
- public LongWritable getCurrentKey() throws IOException, InterruptedException {
+ public LongWritable getCurrentKey() {
return this.key;
}
@Override
- public T getCurrentValue() throws IOException, InterruptedException {
+ public T getCurrentValue() {
return this.tuple;
}
@Override
- public float getProgress() throws IOException, InterruptedException {
+ public float getProgress() {
float progress = 0.0f;
if (this.key == null) {
// We've either not started or we've finished
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/thrift/ThriftQuadInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/thrift/ThriftQuadInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/thrift/ThriftQuadInputFormat.java
index f75542a..59e6d70 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/thrift/ThriftQuadInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/thrift/ThriftQuadInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input.thrift;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -31,8 +29,7 @@ import org.apache.jena.hadoop.rdf.types.QuadWritable;
public class ThriftQuadInputFormat extends AbstractWholeFileInputFormat<LongWritable, QuadWritable> {
@Override
- public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new ThriftQuadReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/thrift/ThriftTripleInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/thrift/ThriftTripleInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/thrift/ThriftTripleInputFormat.java
index b60380d..e135441 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/thrift/ThriftTripleInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/thrift/ThriftTripleInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input.thrift;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -31,8 +29,7 @@ import org.apache.jena.hadoop.rdf.types.TripleWritable;
public class ThriftTripleInputFormat extends AbstractWholeFileInputFormat<LongWritable, TripleWritable> {
@Override
- public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new ThriftTripleReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/trig/TriGInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/trig/TriGInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/trig/TriGInputFormat.java
index 0b36e93..e9785ea 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/trig/TriGInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/trig/TriGInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input.trig;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -38,8 +36,7 @@ import org.apache.jena.hadoop.rdf.types.QuadWritable;
public class TriGInputFormat extends AbstractWholeFileInputFormat<LongWritable, QuadWritable> {
@Override
- public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new TriGReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/trix/TriXInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/trix/TriXInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/trix/TriXInputFormat.java
index 723c5c3..1759958 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/trix/TriXInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/trix/TriXInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input.trix;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -34,8 +32,7 @@ import org.apache.jena.hadoop.rdf.types.QuadWritable;
public class TriXInputFormat extends AbstractWholeFileInputFormat<LongWritable, QuadWritable> {
@Override
- public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, QuadWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new TriXReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/turtle/TurtleInputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/turtle/TurtleInputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/turtle/TurtleInputFormat.java
index c7771b6..2734f24 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/turtle/TurtleInputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/input/turtle/TurtleInputFormat.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.input.turtle;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.InputSplit;
import org.apache.hadoop.mapreduce.RecordReader;
@@ -38,8 +36,7 @@ import org.apache.jena.hadoop.rdf.types.TripleWritable;
public class TurtleInputFormat extends AbstractWholeFileInputFormat<LongWritable, TripleWritable> {
@Override
- public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context)
- throws IOException, InterruptedException {
+ public RecordReader<LongWritable, TripleWritable> createRecordReader(InputSplit split, TaskAttemptContext context) {
return new TurtleReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/AbstractNodeOutputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/AbstractNodeOutputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/AbstractNodeOutputFormat.java
index cfc98bd..aec3309 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/AbstractNodeOutputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/AbstractNodeOutputFormat.java
@@ -50,14 +50,14 @@ public abstract class AbstractNodeOutputFormat<TValue> extends FileOutputFormat<
private static final Logger LOG = LoggerFactory.getLogger(AbstractNodeOutputFormat.class);
@Override
- public RecordWriter<NodeWritable, TValue> getRecordWriter(TaskAttemptContext context) throws IOException, InterruptedException {
+ public RecordWriter<NodeWritable, TValue> getRecordWriter(TaskAttemptContext context) throws IOException {
Configuration config = context.getConfiguration();
boolean isCompressed = getCompressOutput(context);
CompressionCodec codec = null;
String extension = this.getFileExtension();
if (isCompressed) {
Class<? extends CompressionCodec> codecClass = getOutputCompressorClass(context, GzipCodec.class);
- codec = (CompressionCodec) ReflectionUtils.newInstance(codecClass, config);
+ codec = ReflectionUtils.newInstance(codecClass, config);
extension += codec.getDefaultExtension();
}
Path file = getDefaultWorkFile(context, extension);
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/AbstractNodeTupleOutputFormat.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/AbstractNodeTupleOutputFormat.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/AbstractNodeTupleOutputFormat.java
index c4a34f5..fd86f00 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/AbstractNodeTupleOutputFormat.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/AbstractNodeTupleOutputFormat.java
@@ -55,7 +55,7 @@ public abstract class AbstractNodeTupleOutputFormat<TKey, TValue, T extends Abst
private static final Logger LOG = LoggerFactory.getLogger(AbstractNodeTupleOutputFormat.class);
@Override
- public RecordWriter<TKey, T> getRecordWriter(TaskAttemptContext context) throws IOException, InterruptedException {
+ public RecordWriter<TKey, T> getRecordWriter(TaskAttemptContext context) throws IOException {
Configuration config = context.getConfiguration();
boolean isCompressed = getCompressOutput(context);
CompressionCodec codec = null;
@@ -65,7 +65,7 @@ public abstract class AbstractNodeTupleOutputFormat<TKey, TValue, T extends Abst
if (isCompressed) {
// Add compression extension if applicable
Class<? extends CompressionCodec> codecClass = getOutputCompressorClass(context, GzipCodec.class);
- codec = (CompressionCodec) ReflectionUtils.newInstance(codecClass, config);
+ codec = ReflectionUtils.newInstance(codecClass, config);
extension += codec.getDefaultExtension();
}
Path file = getDefaultWorkFile(context, extension);
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedNodeTupleWriter.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedNodeTupleWriter.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedNodeTupleWriter.java
index c4eafd8..cb51b6e 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedNodeTupleWriter.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedNodeTupleWriter.java
@@ -66,7 +66,7 @@ public abstract class AbstractBatchedNodeTupleWriter<TKey, TValue, T extends Abs
}
@Override
- public final void write(TKey key, T value) throws IOException, InterruptedException {
+ public final void write(TKey key, T value) throws IOException {
LOG.debug("write({}={})", key, value);
if (this.add(value) >= this.batchSize) {
long size = this.writeOutput(writer);
@@ -87,7 +87,7 @@ public abstract class AbstractBatchedNodeTupleWriter<TKey, TValue, T extends Abs
protected abstract long add(T value);
@Override
- public void close(TaskAttemptContext context) throws IOException, InterruptedException {
+ public void close(TaskAttemptContext context) throws IOException {
if (this.writer != null) {
long size = this.writeOutput(writer);
if (size > 0)
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedNodeTupleWriter.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedNodeTupleWriter.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedNodeTupleWriter.java
index 9c51264..1df0e62 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedNodeTupleWriter.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedNodeTupleWriter.java
@@ -18,7 +18,6 @@
package org.apache.jena.hadoop.rdf.io.output.writers;
-import java.io.IOException;
import java.io.Writer;
import org.apache.hadoop.mapreduce.RecordWriter;
@@ -93,7 +92,7 @@ public abstract class AbstractLineBasedNodeTupleWriter<TKey, TValue, T extends A
}
@Override
- public void write(TKey key, T value) throws IOException, InterruptedException {
+ public void write(TKey key, T value) {
log.debug("write({}={})", key, value);
Node[] ns = this.getNodes(value);
@@ -144,7 +143,7 @@ public abstract class AbstractLineBasedNodeTupleWriter<TKey, TValue, T extends A
}
@Override
- public void close(TaskAttemptContext context) throws IOException, InterruptedException {
+ public void close(TaskAttemptContext context) {
log.debug("close({})", context);
writer.close();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractNodeWriter.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractNodeWriter.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractNodeWriter.java
index ced8e72..4ab238f 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractNodeWriter.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractNodeWriter.java
@@ -18,7 +18,6 @@
package org.apache.jena.hadoop.rdf.io.output.writers;
-import java.io.IOException;
import java.io.Writer;
import org.apache.hadoop.io.NullWritable;
@@ -87,7 +86,7 @@ public abstract class AbstractNodeWriter<TValue> extends RecordWriter<NodeWritab
}
@Override
- public final void write(NodeWritable key, TValue value) throws IOException, InterruptedException {
+ public final void write(NodeWritable key, TValue value) {
this.writeKey(key);
this.writer.write(this.getSeparator());
this.writeValue(value);
@@ -166,7 +165,7 @@ public abstract class AbstractNodeWriter<TValue> extends RecordWriter<NodeWritab
}
@Override
- public void close(TaskAttemptContext context) throws IOException, InterruptedException {
+ public void close(TaskAttemptContext context) {
log.debug("close({})", context);
writer.close();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractStreamRdfNodeTupleWriter.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractStreamRdfNodeTupleWriter.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractStreamRdfNodeTupleWriter.java
index aa178b2..3b4ec19 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractStreamRdfNodeTupleWriter.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractStreamRdfNodeTupleWriter.java
@@ -43,15 +43,13 @@ public abstract class AbstractStreamRdfNodeTupleWriter<TKey, TTuple, TValue exte
}
@Override
- public void close(TaskAttemptContext context) throws IOException,
- InterruptedException {
+ public void close(TaskAttemptContext context) throws IOException {
this.stream.finish();
this.writer.close();
}
@Override
- public void write(TKey key, TValue value) throws IOException,
- InterruptedException {
+ public void write(TKey key, TValue value) {
this.sendOutput(key, value, this.stream);
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileNodeTupleWriter.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileNodeTupleWriter.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileNodeTupleWriter.java
index d48546b..10ed68b 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileNodeTupleWriter.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileNodeTupleWriter.java
@@ -62,7 +62,7 @@ public abstract class AbstractWholeFileNodeTupleWriter<TKey, TValue, T extends A
}
@Override
- public final void write(TKey key, T value) throws IOException, InterruptedException {
+ public final void write(TKey key, T value) {
LOG.debug("write({}={})", key, value);
this.add(value);
}
@@ -76,7 +76,7 @@ public abstract class AbstractWholeFileNodeTupleWriter<TKey, TValue, T extends A
protected abstract void add(T value);
@Override
- public void close(TaskAttemptContext context) throws IOException, InterruptedException {
+ public void close(TaskAttemptContext context) throws IOException {
if (this.writer != null) {
this.writeOutput(writer);
this.writer.close();
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/JsonLDReaderFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/JsonLDReaderFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/JsonLDReaderFactory.java
index 6b064a4..0e4d7f0 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/JsonLDReaderFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/JsonLDReaderFactory.java
@@ -17,8 +17,6 @@
*/
package org.apache.jena.hadoop.rdf.io.registry.readers;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.RecordReader;
import org.apache.jena.hadoop.rdf.io.input.readers.jsonld.JsonLDQuadReader;
@@ -37,12 +35,12 @@ public class JsonLDReaderFactory extends AbstractReaderFactory {
}
@Override
- public RecordReader<LongWritable, QuadWritable> createQuadReader() throws IOException {
+ public RecordReader<LongWritable, QuadWritable> createQuadReader() {
return new JsonLDQuadReader();
}
@Override
- public RecordReader<LongWritable, TripleWritable> createTripleReader() throws IOException {
+ public RecordReader<LongWritable, TripleWritable> createTripleReader() {
return new JsonLDTripleReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/NQuadsReaderFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/NQuadsReaderFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/NQuadsReaderFactory.java
index 2296296..6601292 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/NQuadsReaderFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/NQuadsReaderFactory.java
@@ -17,8 +17,6 @@
*/
package org.apache.jena.hadoop.rdf.io.registry.readers;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.RecordReader;
import org.apache.jena.hadoop.rdf.io.input.readers.nquads.WholeFileNQuadsReader;
@@ -35,7 +33,7 @@ public class NQuadsReaderFactory extends AbstractQuadsOnlyReaderFactory {
}
@Override
- public RecordReader<LongWritable, QuadWritable> createQuadReader() throws IOException {
+ public RecordReader<LongWritable, QuadWritable> createQuadReader() {
return new WholeFileNQuadsReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/NTriplesReaderFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/NTriplesReaderFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/NTriplesReaderFactory.java
index a98a1ae..2dd8445 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/NTriplesReaderFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/NTriplesReaderFactory.java
@@ -18,7 +18,6 @@
package org.apache.jena.hadoop.rdf.io.registry.readers;
-import java.io.IOException;
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.RecordReader;
import org.apache.jena.hadoop.rdf.io.input.readers.ntriples.WholeFileNTriplesReader;
@@ -32,7 +31,7 @@ public class NTriplesReaderFactory extends AbstractTriplesOnlyReaderFactory {
}
@Override
- public RecordReader<LongWritable, TripleWritable> createTripleReader() throws IOException {
+ public RecordReader<LongWritable, TripleWritable> createTripleReader() {
return new WholeFileNTriplesReader();
}
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/RdfJsonReaderFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/RdfJsonReaderFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/RdfJsonReaderFactory.java
index ccf5feb..08d16f1 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/RdfJsonReaderFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/RdfJsonReaderFactory.java
@@ -17,8 +17,6 @@
*/
package org.apache.jena.hadoop.rdf.io.registry.readers;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.RecordReader;
import org.apache.jena.hadoop.rdf.io.input.readers.rdfjson.RdfJsonReader;
@@ -35,7 +33,7 @@ public class RdfJsonReaderFactory extends AbstractTriplesOnlyReaderFactory {
}
@Override
- public RecordReader<LongWritable, TripleWritable> createTripleReader() throws IOException {
+ public RecordReader<LongWritable, TripleWritable> createTripleReader() {
return new RdfJsonReader();
}
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/RdfXmlReaderFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/RdfXmlReaderFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/RdfXmlReaderFactory.java
index 1aa88d7..bf92597 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/RdfXmlReaderFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/RdfXmlReaderFactory.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.registry.readers;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.RecordReader;
import org.apache.jena.hadoop.rdf.io.input.readers.rdfxml.RdfXmlReader;
@@ -33,7 +31,7 @@ public class RdfXmlReaderFactory extends AbstractTriplesOnlyReaderFactory {
}
@Override
- public RecordReader<LongWritable, TripleWritable> createTripleReader() throws IOException {
+ public RecordReader<LongWritable, TripleWritable> createTripleReader() {
return new RdfXmlReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/ThriftReaderFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/ThriftReaderFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/ThriftReaderFactory.java
index 25e8234..3d7cea5 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/ThriftReaderFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/ThriftReaderFactory.java
@@ -17,8 +17,6 @@
*/
package org.apache.jena.hadoop.rdf.io.registry.readers;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.RecordReader;
import org.apache.jena.hadoop.rdf.io.input.readers.thrift.ThriftQuadReader;
@@ -37,12 +35,12 @@ public class ThriftReaderFactory extends AbstractReaderFactory {
}
@Override
- public RecordReader<LongWritable, QuadWritable> createQuadReader() throws IOException {
+ public RecordReader<LongWritable, QuadWritable> createQuadReader() {
return new ThriftQuadReader();
}
@Override
- public RecordReader<LongWritable, TripleWritable> createTripleReader() throws IOException {
+ public RecordReader<LongWritable, TripleWritable> createTripleReader() {
return new ThriftTripleReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/TriGReaderFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/TriGReaderFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/TriGReaderFactory.java
index 83ea818..2af8e84 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/TriGReaderFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/TriGReaderFactory.java
@@ -17,8 +17,6 @@
*/
package org.apache.jena.hadoop.rdf.io.registry.readers;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.RecordReader;
import org.apache.jena.hadoop.rdf.io.input.readers.trig.TriGReader;
@@ -35,7 +33,7 @@ public class TriGReaderFactory extends AbstractQuadsOnlyReaderFactory {
}
@Override
- public RecordReader<LongWritable, QuadWritable> createQuadReader() throws IOException {
+ public RecordReader<LongWritable, QuadWritable> createQuadReader() {
return new TriGReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/TriXReaderFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/TriXReaderFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/TriXReaderFactory.java
index cb8795c..9534a82 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/TriXReaderFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/TriXReaderFactory.java
@@ -17,8 +17,6 @@
*/
package org.apache.jena.hadoop.rdf.io.registry.readers;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.RecordReader;
import org.apache.jena.hadoop.rdf.io.input.readers.trix.TriXReader;
@@ -35,7 +33,7 @@ public class TriXReaderFactory extends AbstractQuadsOnlyReaderFactory {
}
@Override
- public RecordReader<LongWritable, QuadWritable> createQuadReader() throws IOException {
+ public RecordReader<LongWritable, QuadWritable> createQuadReader() {
return new TriXReader();
}
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/TurtleReaderFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/TurtleReaderFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/TurtleReaderFactory.java
index 7800376..c426c8a 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/TurtleReaderFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/readers/TurtleReaderFactory.java
@@ -18,8 +18,6 @@
package org.apache.jena.hadoop.rdf.io.registry.readers;
-import java.io.IOException;
-
import org.apache.hadoop.io.LongWritable;
import org.apache.hadoop.mapreduce.RecordReader;
import org.apache.jena.hadoop.rdf.io.input.readers.turtle.TurtleReader;
@@ -33,7 +31,7 @@ public class TurtleReaderFactory extends AbstractTriplesOnlyReaderFactory {
}
@Override
- public RecordReader<LongWritable, TripleWritable> createTripleReader() throws IOException {
+ public RecordReader<LongWritable, TripleWritable> createTripleReader() {
return new TurtleReader();
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/JsonLDWriterFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/JsonLDWriterFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/JsonLDWriterFactory.java
index 89e93ed..973f28f 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/JsonLDWriterFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/JsonLDWriterFactory.java
@@ -17,7 +17,6 @@
*/
package org.apache.jena.hadoop.rdf.io.registry.writers;
-import java.io.IOException;
import java.io.Writer;
import org.apache.hadoop.conf.Configuration;
@@ -38,14 +37,12 @@ public class JsonLDWriterFactory extends AbstractWriterFactory {
}
@Override
- public <TKey> RecordWriter<TKey, QuadWritable> createQuadWriter(Writer writer, Configuration config)
- throws IOException {
+ public <TKey> RecordWriter<TKey, QuadWritable> createQuadWriter(Writer writer, Configuration config) {
return new JsonLDQuadWriter<>(writer);
}
@Override
- public <TKey> RecordWriter<TKey, TripleWritable> createTripleWriter(Writer writer, Configuration config)
- throws IOException {
+ public <TKey> RecordWriter<TKey, TripleWritable> createTripleWriter(Writer writer, Configuration config) {
return new JsonLDTripleWriter<>(writer);
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/NQuadsWriterFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/NQuadsWriterFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/NQuadsWriterFactory.java
index abbbd0f..1376190 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/NQuadsWriterFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/NQuadsWriterFactory.java
@@ -17,7 +17,6 @@
*/
package org.apache.jena.hadoop.rdf.io.registry.writers;
-import java.io.IOException;
import java.io.Writer;
import org.apache.hadoop.conf.Configuration;
@@ -36,8 +35,7 @@ public class NQuadsWriterFactory extends AbstractQuadsOnlyWriterFactory {
}
@Override
- public <TKey> RecordWriter<TKey, QuadWritable> createQuadWriter(Writer writer, Configuration config)
- throws IOException {
+ public <TKey> RecordWriter<TKey, QuadWritable> createQuadWriter(Writer writer, Configuration config) {
return new NQuadsWriter<TKey>(writer);
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/NTriplesWriterFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/NTriplesWriterFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/NTriplesWriterFactory.java
index 88c9551..39169ed 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/NTriplesWriterFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/NTriplesWriterFactory.java
@@ -17,7 +17,6 @@
*/
package org.apache.jena.hadoop.rdf.io.registry.writers;
-import java.io.IOException;
import java.io.Writer;
import org.apache.hadoop.conf.Configuration;
@@ -36,8 +35,7 @@ public class NTriplesWriterFactory extends AbstractTriplesOnlyWriterFactory {
}
@Override
- public <TKey> RecordWriter<TKey, TripleWritable> createTripleWriter(Writer writer, Configuration config)
- throws IOException {
+ public <TKey> RecordWriter<TKey, TripleWritable> createTripleWriter(Writer writer, Configuration config) {
return new NTriplesWriter<TKey>(writer);
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/RdfJsonWriterFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/RdfJsonWriterFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/RdfJsonWriterFactory.java
index 8252422..3260183 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/RdfJsonWriterFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/RdfJsonWriterFactory.java
@@ -17,7 +17,6 @@
*/
package org.apache.jena.hadoop.rdf.io.registry.writers;
-import java.io.IOException;
import java.io.Writer;
import org.apache.hadoop.conf.Configuration;
@@ -36,8 +35,7 @@ public class RdfJsonWriterFactory extends AbstractTriplesOnlyWriterFactory {
}
@Override
- public <TKey> RecordWriter<TKey, TripleWritable> createTripleWriter(Writer writer, Configuration config)
- throws IOException {
+ public <TKey> RecordWriter<TKey, TripleWritable> createTripleWriter(Writer writer, Configuration config) {
return new RdfJsonWriter<TKey>(writer);
}
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/RdfXmlWriterFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/RdfXmlWriterFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/RdfXmlWriterFactory.java
index b4ac8e3..a4d482c 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/RdfXmlWriterFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/RdfXmlWriterFactory.java
@@ -17,7 +17,6 @@
*/
package org.apache.jena.hadoop.rdf.io.registry.writers;
-import java.io.IOException;
import java.io.Writer;
import org.apache.hadoop.conf.Configuration;
@@ -36,8 +35,7 @@ public class RdfXmlWriterFactory extends AbstractTriplesOnlyWriterFactory {
}
@Override
- public <TKey> RecordWriter<TKey, TripleWritable> createTripleWriter(Writer writer, Configuration config)
- throws IOException {
+ public <TKey> RecordWriter<TKey, TripleWritable> createTripleWriter(Writer writer, Configuration config) {
return new RdfXmlWriter<TKey>(writer);
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/ThriftWriterFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/ThriftWriterFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/ThriftWriterFactory.java
index 757472c..f5d9b4b 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/ThriftWriterFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/ThriftWriterFactory.java
@@ -17,7 +17,6 @@
*/
package org.apache.jena.hadoop.rdf.io.registry.writers;
-import java.io.IOException;
import java.io.Writer;
import java.nio.charset.Charset;
@@ -41,15 +40,13 @@ public class ThriftWriterFactory extends AbstractWriterFactory {
}
@Override
- public <TKey> RecordWriter<TKey, QuadWritable> createQuadWriter(Writer writer, Configuration config)
- throws IOException {
+ public <TKey> RecordWriter<TKey, QuadWritable> createQuadWriter(Writer writer, Configuration config) {
return new StreamRdfQuadWriter<TKey>(new StreamRDF2Thrift(new WriterOutputStream(writer, Charset.forName("utf-8")),
false), writer);
}
@Override
- public <TKey> RecordWriter<TKey, TripleWritable> createTripleWriter(Writer writer, Configuration config)
- throws IOException {
+ public <TKey> RecordWriter<TKey, TripleWritable> createTripleWriter(Writer writer, Configuration config) {
return new StreamRdfTripleWriter<TKey>(new StreamRDF2Thrift(new WriterOutputStream(writer, Charset.forName("utf-8")),
false), writer);
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/TriGWriterFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/TriGWriterFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/TriGWriterFactory.java
index 6d8b08a..ec490fa 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/TriGWriterFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/TriGWriterFactory.java
@@ -17,7 +17,6 @@
*/
package org.apache.jena.hadoop.rdf.io.registry.writers;
-import java.io.IOException;
import java.io.Writer;
import org.apache.hadoop.conf.Configuration;
@@ -37,8 +36,7 @@ public class TriGWriterFactory extends AbstractQuadsOnlyWriterFactory {
}
@Override
- public <TKey> RecordWriter<TKey, QuadWritable> createQuadWriter(Writer writer, Configuration config)
- throws IOException {
+ public <TKey> RecordWriter<TKey, QuadWritable> createQuadWriter(Writer writer, Configuration config) {
return new StreamRdfQuadWriter<TKey>(new WriterStreamRDFBlocks(writer), writer);
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/TriXWriterFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/TriXWriterFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/TriXWriterFactory.java
index 0e1b7b2..bf628ef 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/TriXWriterFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/TriXWriterFactory.java
@@ -17,7 +17,6 @@
*/
package org.apache.jena.hadoop.rdf.io.registry.writers;
-import java.io.IOException;
import java.io.Writer;
import java.nio.charset.Charset;
@@ -39,8 +38,7 @@ public class TriXWriterFactory extends AbstractQuadsOnlyWriterFactory {
}
@Override
- public <TKey> RecordWriter<TKey, QuadWritable> createQuadWriter(Writer writer, Configuration config)
- throws IOException {
+ public <TKey> RecordWriter<TKey, QuadWritable> createQuadWriter(Writer writer, Configuration config) {
return new StreamRdfQuadWriter<>(new StreamWriterTriX(new WriterOutputStream(writer, Charset.forName("utf-8"))), writer);
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/TurtleWriterFactory.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/TurtleWriterFactory.java b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/TurtleWriterFactory.java
index c837f12..8b0b155 100644
--- a/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/TurtleWriterFactory.java
+++ b/jena-elephas/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/registry/writers/TurtleWriterFactory.java
@@ -17,7 +17,6 @@
*/
package org.apache.jena.hadoop.rdf.io.registry.writers;
-import java.io.IOException;
import java.io.Writer;
import org.apache.hadoop.conf.Configuration;
@@ -37,8 +36,7 @@ public class TurtleWriterFactory extends AbstractTriplesOnlyWriterFactory {
}
@Override
- public <TKey> RecordWriter<TKey, TripleWritable> createTripleWriter(Writer writer, Configuration config)
- throws IOException {
+ public <TKey> RecordWriter<TKey, TripleWritable> createTripleWriter(Writer writer, Configuration config) {
return new StreamRdfTripleWriter<>(new WriterStreamRDFBlocks(writer), writer);
}
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/AbstractNodeTupleInputFormatTests.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/AbstractNodeTupleInputFormatTests.java b/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/AbstractNodeTupleInputFormatTests.java
index e22650f..e26445e 100644
--- a/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/AbstractNodeTupleInputFormatTests.java
+++ b/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/AbstractNodeTupleInputFormatTests.java
@@ -352,11 +352,10 @@ public abstract class AbstractNodeTupleInputFormatTests<TValue, T extends Abstra
* Basic tuples input test
*
* @throws IOException
- * @throws ClassNotFoundException
* @throws InterruptedException
*/
@Test
- public final void single_input_01() throws IOException, InterruptedException, ClassNotFoundException {
+ public final void single_input_01() throws IOException, InterruptedException {
testSingleInput(empty, this.canSplitInputs() ? 0 : 1, EMPTY_SIZE);
}
@@ -368,7 +367,7 @@ public abstract class AbstractNodeTupleInputFormatTests<TValue, T extends Abstra
* @throws InterruptedException
*/
@Test
- public final void single_input_02() throws IOException, InterruptedException, ClassNotFoundException {
+ public final void single_input_02() throws IOException, InterruptedException {
testSingleInput(small, 1, SMALL_SIZE);
}
@@ -380,7 +379,7 @@ public abstract class AbstractNodeTupleInputFormatTests<TValue, T extends Abstra
* @throws InterruptedException
*/
@Test
- public final void single_input_03() throws IOException, InterruptedException, ClassNotFoundException {
+ public final void single_input_03() throws IOException, InterruptedException {
testSingleInput(large, 1, LARGE_SIZE);
}
@@ -392,7 +391,7 @@ public abstract class AbstractNodeTupleInputFormatTests<TValue, T extends Abstra
* @throws InterruptedException
*/
@Test
- public final void single_input_04() throws IOException, InterruptedException, ClassNotFoundException {
+ public final void single_input_04() throws IOException, InterruptedException {
testSingleInput(bad, 1, 0);
}
@@ -404,7 +403,7 @@ public abstract class AbstractNodeTupleInputFormatTests<TValue, T extends Abstra
* @throws InterruptedException
*/
@Test
- public final void single_input_05() throws IOException, InterruptedException, ClassNotFoundException {
+ public final void single_input_05() throws IOException, InterruptedException {
testSingleInput(mixed, 1, MIXED_SIZE / 2);
}
@@ -483,11 +482,10 @@ public abstract class AbstractNodeTupleInputFormatTests<TValue, T extends Abstra
* tuples test with multiple inputs
*
* @throws IOException
- * @throws ClassNotFoundException
* @throws InterruptedException
*/
@Test
- public final void multiple_inputs_01() throws IOException, InterruptedException, ClassNotFoundException {
+ public final void multiple_inputs_01() throws IOException, InterruptedException {
testMultipleInputs(new File[] { empty, small, large }, this.canSplitInputs() ? 2 : 3, EMPTY_SIZE + SMALL_SIZE
+ LARGE_SIZE);
}
@@ -500,7 +498,7 @@ public abstract class AbstractNodeTupleInputFormatTests<TValue, T extends Abstra
* @throws InterruptedException
*/
@Test
- public final void multiple_inputs_02() throws IOException, InterruptedException, ClassNotFoundException {
+ public final void multiple_inputs_02() throws IOException, InterruptedException {
testMultipleInputs(new File[] { folder.getRoot() }, this.canSplitInputs() ? 4 : 5, EMPTY_SIZE + SMALL_SIZE
+ LARGE_SIZE + (MIXED_SIZE / 2));
}
@@ -542,9 +540,8 @@ public abstract class AbstractNodeTupleInputFormatTests<TValue, T extends Abstra
* @param split
* Input split
* @return True if a valid split, false otherwise
- * @throws IOException
*/
- protected boolean isValidSplit(InputSplit split, Configuration config) throws IOException {
+ protected boolean isValidSplit(InputSplit split, Configuration config) {
return split instanceof FileSplit;
}
@@ -565,7 +562,7 @@ public abstract class AbstractNodeTupleInputFormatTests<TValue, T extends Abstra
* @throws ClassNotFoundException
*/
@Test
- public final void split_input_01() throws IOException, InterruptedException, ClassNotFoundException {
+ public final void split_input_01() throws IOException, InterruptedException {
Assume.assumeTrue(this.canSplitInputs());
Configuration config = this.prepareConfiguration();
@@ -582,7 +579,7 @@ public abstract class AbstractNodeTupleInputFormatTests<TValue, T extends Abstra
* @throws ClassNotFoundException
*/
@Test
- public final void split_input_02() throws IOException, InterruptedException, ClassNotFoundException {
+ public final void split_input_02() throws IOException, InterruptedException {
Assume.assumeTrue(this.canSplitInputs());
Configuration config = this.prepareConfiguration();
@@ -600,7 +597,7 @@ public abstract class AbstractNodeTupleInputFormatTests<TValue, T extends Abstra
* @throws ClassNotFoundException
*/
@Test
- public final void split_input_03() throws IOException, InterruptedException, ClassNotFoundException {
+ public final void split_input_03() throws IOException, InterruptedException {
Assume.assumeTrue(this.canSplitInputs());
Configuration config = this.prepareConfiguration();
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/AbstractWholeFileQuadInputFormatTests.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/AbstractWholeFileQuadInputFormatTests.java b/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/AbstractWholeFileQuadInputFormatTests.java
index e71d64a..50a468b 100644
--- a/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/AbstractWholeFileQuadInputFormatTests.java
+++ b/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/AbstractWholeFileQuadInputFormatTests.java
@@ -60,7 +60,7 @@ public abstract class AbstractWholeFileQuadInputFormatTests extends AbstractNode
*/
protected abstract Lang getRdfLanguage();
- private void writeGoodTuples(OutputStream output, int num) throws IOException {
+ private void writeGoodTuples(OutputStream output, int num) {
Dataset ds = DatasetFactory.createMem();
Model m = ModelFactory.createDefaultModel();
Resource currSubj = m.createResource("http://example.org/subjects/0");
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/bnodes/AbstractBlankNodeTests.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/bnodes/AbstractBlankNodeTests.java b/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/bnodes/AbstractBlankNodeTests.java
index b6fca79..16dc15b 100644
--- a/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/bnodes/AbstractBlankNodeTests.java
+++ b/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/bnodes/AbstractBlankNodeTests.java
@@ -52,7 +52,6 @@ import org.apache.jena.graph.NodeFactory ;
import org.apache.jena.hadoop.rdf.io.RdfIOConstants;
import org.apache.jena.hadoop.rdf.types.AbstractNodeTupleWritable;
import org.apache.jena.riot.system.ParserProfile;
-import org.apache.log4j.BasicConfigurator;
import org.junit.Assert;
import org.junit.Assume;
import org.junit.BeforeClass;
@@ -63,7 +62,6 @@ import org.slf4j.LoggerFactory;
/**
* Test case that embodies the scenario described in JENA-820
*/
-@SuppressWarnings("unused")
public abstract class AbstractBlankNodeTests<T, TValue extends AbstractNodeTupleWritable<T>> {
private static final Logger LOGGER = LoggerFactory.getLogger(AbstractBlankNodeTests.class);
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/compressed/AbstractCompressedWholeFileQuadInputFormatTests.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/compressed/AbstractCompressedWholeFileQuadInputFormatTests.java b/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/compressed/AbstractCompressedWholeFileQuadInputFormatTests.java
index bfb06a2..029203b 100644
--- a/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/compressed/AbstractCompressedWholeFileQuadInputFormatTests.java
+++ b/jena-elephas/jena-elephas-io/src/test/java/org/apache/jena/hadoop/rdf/io/input/compressed/AbstractCompressedWholeFileQuadInputFormatTests.java
@@ -95,7 +95,7 @@ public abstract class AbstractCompressedWholeFileQuadInputFormatTests extends
*/
protected abstract Lang getRdfLanguage();
- private void writeGoodTuples(OutputStream output, int num) throws IOException {
+ private void writeGoodTuples(OutputStream output, int num) {
Dataset ds = DatasetFactory.createMem();
Model m = ModelFactory.createDefaultModel();
Resource currSubj = m.createResource("http://example.org/subjects/0");
http://git-wip-us.apache.org/repos/asf/jena/blob/59150221/jena-elephas/jena-elephas-stats/src/main/java/org/apache/jena/hadoop/rdf/stats/RdfStats.java
----------------------------------------------------------------------
diff --git a/jena-elephas/jena-elephas-stats/src/main/java/org/apache/jena/hadoop/rdf/stats/RdfStats.java b/jena-elephas/jena-elephas-stats/src/main/java/org/apache/jena/hadoop/rdf/stats/RdfStats.java
index 3c9e896..49186d4 100644
--- a/jena-elephas/jena-elephas-stats/src/main/java/org/apache/jena/hadoop/rdf/stats/RdfStats.java
+++ b/jena-elephas/jena-elephas-stats/src/main/java/org/apache/jena/hadoop/rdf/stats/RdfStats.java
@@ -127,9 +127,8 @@ public class RdfStats implements Tool {
*
* @param args
* Arguments
- * @throws Exception
*/
- public static void main(String[] args) throws Exception {
+ public static void main(String[] args) {
try {
// Run and exit with result code if no errors bubble up
// Note that the exit code may still be a error code
@@ -163,7 +162,7 @@ public class RdfStats implements Tool {
}
@Override
- public int run(String[] args) throws Exception {
+ public int run(String[] args) {
try {
if (args.length == 0) {
showUsage();
[2/2] jena git commit: Merge branch 'CleanupElephas' of
https://github.com/ajs6f/jena
Posted by rv...@apache.org.
Merge branch 'CleanupElephas' of https://github.com/ajs6f/jena
This close #67
Project: http://git-wip-us.apache.org/repos/asf/jena/repo
Commit: http://git-wip-us.apache.org/repos/asf/jena/commit/11f87bfd
Tree: http://git-wip-us.apache.org/repos/asf/jena/tree/11f87bfd
Diff: http://git-wip-us.apache.org/repos/asf/jena/diff/11f87bfd
Branch: refs/heads/master
Commit: 11f87bfd4087bf028fe4fdd14d644b3b28620013
Parents: 36dcea5 5915022
Author: Rob Vesse <rv...@apache.org>
Authored: Thu May 21 10:57:55 2015 +0100
Committer: Rob Vesse <rv...@apache.org>
Committed: Thu May 21 10:57:55 2015 +0100
----------------------------------------------------------------------
.../hadoop/rdf/io/input/QuadsInputFormat.java | 5 +---
.../hadoop/rdf/io/input/TriplesInputFormat.java | 5 +---
.../rdf/io/input/TriplesOrQuadsInputFormat.java | 5 +---
.../io/input/jsonld/JsonLDQuadInputFormat.java | 5 +---
.../input/jsonld/JsonLDTripleInputFormat.java | 5 +---
.../input/nquads/BlockedNQuadsInputFormat.java | 5 +---
.../rdf/io/input/nquads/NQuadsInputFormat.java | 5 +---
.../nquads/WholeFileNQuadsInputFormat.java | 5 +---
.../ntriples/BlockedNTriplesInputFormat.java | 5 +---
.../io/input/ntriples/NTriplesInputFormat.java | 5 +---
.../ntriples/WholeFileNTriplesInputFormat.java | 5 +---
.../io/input/rdfjson/RdfJsonInputFormat.java | 5 +---
.../rdf/io/input/rdfxml/RdfXmlInputFormat.java | 5 +---
.../AbstractBlockBasedNodeTupleReader.java | 10 ++++----
.../AbstractLineBasedNodeTupleReader.java | 12 +++++-----
.../AbstractWholeFileNodeTupleReader.java | 10 ++++----
.../io/input/thrift/ThriftQuadInputFormat.java | 5 +---
.../input/thrift/ThriftTripleInputFormat.java | 5 +---
.../rdf/io/input/trig/TriGInputFormat.java | 5 +---
.../rdf/io/input/trix/TriXInputFormat.java | 5 +---
.../rdf/io/input/turtle/TurtleInputFormat.java | 5 +---
.../rdf/io/output/AbstractNodeOutputFormat.java | 4 ++--
.../output/AbstractNodeTupleOutputFormat.java | 4 ++--
.../writers/AbstractBatchedNodeTupleWriter.java | 4 ++--
.../AbstractLineBasedNodeTupleWriter.java | 5 ++--
.../io/output/writers/AbstractNodeWriter.java | 5 ++--
.../AbstractStreamRdfNodeTupleWriter.java | 6 ++---
.../AbstractWholeFileNodeTupleWriter.java | 4 ++--
.../registry/readers/JsonLDReaderFactory.java | 6 ++---
.../registry/readers/NQuadsReaderFactory.java | 4 +---
.../registry/readers/NTriplesReaderFactory.java | 3 +--
.../registry/readers/RdfJsonReaderFactory.java | 4 +---
.../registry/readers/RdfXmlReaderFactory.java | 4 +---
.../registry/readers/ThriftReaderFactory.java | 6 ++---
.../io/registry/readers/TriGReaderFactory.java | 4 +---
.../io/registry/readers/TriXReaderFactory.java | 4 +---
.../registry/readers/TurtleReaderFactory.java | 4 +---
.../registry/writers/JsonLDWriterFactory.java | 7 ++----
.../registry/writers/NQuadsWriterFactory.java | 4 +---
.../registry/writers/NTriplesWriterFactory.java | 4 +---
.../registry/writers/RdfJsonWriterFactory.java | 4 +---
.../registry/writers/RdfXmlWriterFactory.java | 4 +---
.../registry/writers/ThriftWriterFactory.java | 7 ++----
.../io/registry/writers/TriGWriterFactory.java | 4 +---
.../io/registry/writers/TriXWriterFactory.java | 4 +---
.../registry/writers/TurtleWriterFactory.java | 4 +---
.../AbstractNodeTupleInputFormatTests.java | 25 +++++++++-----------
.../AbstractWholeFileQuadInputFormatTests.java | 2 +-
.../io/input/bnodes/AbstractBlankNodeTests.java | 2 --
...CompressedWholeFileQuadInputFormatTests.java | 2 +-
.../apache/jena/hadoop/rdf/stats/RdfStats.java | 5 ++--
51 files changed, 85 insertions(+), 186 deletions(-)
----------------------------------------------------------------------