http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/turtle/BatchedTurtleOutputFormat.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/turtle/BatchedTurtleOutputFormat.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/turtle/BatchedTurtleOutputFormat.java deleted file mode 100644 index c7564ac..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/turtle/BatchedTurtleOutputFormat.java +++ /dev/null @@ -1,50 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.turtle; - -import java.io.Writer; - -import org.apache.hadoop.mapreduce.RecordWriter; -import org.apache.jena.hadoop.rdf.io.output.AbstractBatchedNodeTupleOutputFormat; -import org.apache.jena.hadoop.rdf.io.output.writers.turtle.BatchedTurtleWriter; -import org.apache.jena.hadoop.rdf.types.TripleWritable; - -import com.hp.hpl.jena.graph.Triple; - -/** - * Output format for Turtle that uses a batched approach, note that this will - * produce invalid data where blank nodes span batches so it is typically better - * to use the {@link TurtleOutputFormat} instead - * - * @param <TKey> - * Key type - */ -public class BatchedTurtleOutputFormat<TKey> extends AbstractBatchedNodeTupleOutputFormat<TKey, Triple, TripleWritable> { - - @Override - protected RecordWriter<TKey, TripleWritable> getRecordWriter(Writer writer, long batchSize) { - return new BatchedTurtleWriter<TKey>(writer, batchSize); - } - - @Override - protected String getFileExtension() { - return ".ttl"; - } - -}
http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/turtle/TurtleOutputFormat.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/turtle/TurtleOutputFormat.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/turtle/TurtleOutputFormat.java deleted file mode 100644 index c0202d8..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/turtle/TurtleOutputFormat.java +++ /dev/null @@ -1,56 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.turtle; - -import java.io.Writer; - -import org.apache.hadoop.conf.Configuration; -import org.apache.hadoop.mapreduce.RecordWriter; -import org.apache.jena.hadoop.rdf.io.output.AbstractStreamRdfNodeTupleOutputFormat; -import org.apache.jena.hadoop.rdf.io.output.writers.StreamRdfTripleWriter; -import org.apache.jena.hadoop.rdf.types.TripleWritable; -import org.apache.jena.riot.system.StreamRDF; -import org.apache.jena.riot.writer.WriterStreamRDFBlocks; - -import com.hp.hpl.jena.graph.Triple; - -/** - * Turtle output format - * - * @param <TKey> - * Key type - */ -public class TurtleOutputFormat<TKey> extends AbstractStreamRdfNodeTupleOutputFormat<TKey, Triple, TripleWritable> { - - @Override - protected String getFileExtension() { - return ".ttl"; - } - - @Override - protected RecordWriter<TKey, TripleWritable> getRecordWriter(StreamRDF stream, Writer writer, Configuration config) { - return new StreamRdfTripleWriter<TKey>(stream, writer); - } - - @Override - protected StreamRDF getStream(Writer writer, Configuration config) { - return new WriterStreamRDFBlocks(writer); - } - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedNodeTupleWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedNodeTupleWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedNodeTupleWriter.java deleted file mode 100644 index c4eafd8..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedNodeTupleWriter.java +++ /dev/null @@ -1,113 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers; - -import java.io.IOException; -import java.io.Writer; - -import org.apache.hadoop.mapreduce.RecordWriter; -import org.apache.hadoop.mapreduce.TaskAttemptContext; -import org.apache.jena.hadoop.rdf.types.AbstractNodeTupleWritable; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - - -/** - * An abstract implementation of a record writer that writes records in batches. - * <p> - * It is important to note that the writer will write output periodically once - * sufficient tuples have been gathered. If there is an incomplete batch when - * the {@link #close(TaskAttemptContext)} method is called then the final batch - * will be written then. Writing in batches increases the chances that the - * writer will be able to effectively use the syntax compressions of the RDF - * serialization being used. - * </p> - * <p> - * The implementation only writes the value portion of the key value pair since - * it is the value portion that is used to convey the node tuples - * </p> - * - * - * - * @param <TKey> - * @param <TValue> - * @param <T> - */ -public abstract class AbstractBatchedNodeTupleWriter<TKey, TValue, T extends AbstractNodeTupleWritable<TValue>> extends - RecordWriter<TKey, T> { - private static final Logger LOG = LoggerFactory.getLogger(AbstractBatchedNodeTupleWriter.class); - - private Writer writer; - private long batchSize; - - protected AbstractBatchedNodeTupleWriter(Writer writer, long batchSize) { - if (writer == null) - throw new NullPointerException("writer cannot be null"); - if (batchSize <= 0) - throw new IllegalArgumentException("batchSize must be >= 1"); - this.writer = writer; - this.batchSize = batchSize; - } - - @Override - public final void write(TKey key, T value) throws IOException, InterruptedException { - LOG.debug("write({}={})", key, value); - if (this.add(value) >= this.batchSize) { - long size = this.writeOutput(writer); - if (size > 0) - throw new IOException("Derived implementation failed to empty the current batch after writing"); - } - } - - /** - * Adds the tuple to the batch of tuples that will be written when the batch - * threshold is reached or when the {@link #close(TaskAttemptContext)} - * method is called. - * - * @param value - * Tuple - * @return The current size of the batch waiting to be written - */ - protected abstract long add(T value); - - @Override - public void close(TaskAttemptContext context) throws IOException, InterruptedException { - if (this.writer != null) { - long size = this.writeOutput(writer); - if (size > 0) - throw new IOException("Derived implementation failed to empty the current batch after writing"); - this.writer.close(); - this.writer = null; - } - } - - /** - * Writes the current batch of tuples to the writer, the writer should not - * be closed and the batch should be emptied by the implementation. - * <p> - * If the current batch is empty then this should be a no-op - * </p> - * - * @param writer - * Writer - * @return Current batch size which should always be zero - */ - protected abstract long writeOutput(Writer writer); - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedQuadWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedQuadWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedQuadWriter.java deleted file mode 100644 index 13c2799..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedQuadWriter.java +++ /dev/null @@ -1,80 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers; - -import java.io.Writer; -import java.util.List; - -import org.apache.commons.collections.IteratorUtils; -import org.apache.jena.hadoop.rdf.types.QuadWritable; -import org.apache.jena.riot.Lang; -import org.apache.jena.riot.RDFDataMgr; -import org.apache.jena.riot.RDFWriterRegistry; - -import com.hp.hpl.jena.graph.Node; -import com.hp.hpl.jena.sparql.core.DatasetGraph; -import com.hp.hpl.jena.sparql.core.DatasetGraphFactory; -import com.hp.hpl.jena.sparql.core.Quad; - -/** - * Abstract batched record writer for quad formats - * - * - * - * @param <TKey> - */ -public abstract class AbstractBatchedQuadWriter<TKey> extends AbstractBatchedNodeTupleWriter<TKey, Quad, QuadWritable> { - - private DatasetGraph g = DatasetGraphFactory.createMem(); - - protected AbstractBatchedQuadWriter(Writer writer, long batchSize) { - super(writer, batchSize); - } - - @Override - protected final long add(QuadWritable value) { - g.add(value.get()); - return g.size(); - } - - @SuppressWarnings("deprecation") - @Override - protected final long writeOutput(Writer writer) { - if (this.g.size() == 0) - return 0; - RDFDataMgr.write(writer, this.g, RDFWriterRegistry.defaultSerialization(this.getRdfLanguage())); - - // Clear the dataset graph - @SuppressWarnings("unchecked") - List<Node> graphNames = IteratorUtils.toList(this.g.listGraphNodes()); - for (Node graphName : graphNames) { - this.g.removeGraph(graphName); - } - this.g.getDefaultGraph().clear(); - - return this.g.size(); - } - - /** - * Gets the RDF language used for output - * - * @return RDF language - */ - protected abstract Lang getRdfLanguage(); -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedTripleWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedTripleWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedTripleWriter.java deleted file mode 100644 index 881cf15..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractBatchedTripleWriter.java +++ /dev/null @@ -1,68 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.types.TripleWritable; -import org.apache.jena.riot.Lang; -import org.apache.jena.riot.RDFDataMgr; - -import com.hp.hpl.jena.graph.Graph; -import com.hp.hpl.jena.graph.Triple; -import com.hp.hpl.jena.sparql.graph.GraphFactory; - -/** - * Abstract batched record writer for triple formats - * - * - * - * @param <TKey> - */ -public abstract class AbstractBatchedTripleWriter<TKey> extends AbstractBatchedNodeTupleWriter<TKey, Triple, TripleWritable> { - - private Graph g = GraphFactory.createDefaultGraph(); - - protected AbstractBatchedTripleWriter(Writer writer, long batchSize) { - super(writer, batchSize); - } - - @Override - protected final long add(TripleWritable value) { - g.add(value.get()); - return g.size(); - } - - @SuppressWarnings("deprecation") - @Override - protected final long writeOutput(Writer writer) { - if (this.g.size() == 0) - return 0; - RDFDataMgr.write(writer, this.g, this.getRdfLanguage()); - this.g.clear(); - return this.g.size(); - } - - /** - * Gets the RDF language used for output - * - * @return RDF language - */ - protected abstract Lang getRdfLanguage(); -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedNodeTupleWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedNodeTupleWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedNodeTupleWriter.java deleted file mode 100644 index 89b8f4b..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedNodeTupleWriter.java +++ /dev/null @@ -1,152 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers; - -import java.io.IOException; -import java.io.Writer; - -import org.apache.hadoop.mapreduce.RecordWriter; -import org.apache.hadoop.mapreduce.TaskAttemptContext; -import org.apache.jena.atlas.io.AWriter; -import org.apache.jena.atlas.io.Writer2; -import org.apache.jena.hadoop.rdf.types.AbstractNodeTupleWritable; -import org.apache.jena.riot.out.NodeFormatter; -import org.apache.jena.riot.out.NodeFormatterNT; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import com.hp.hpl.jena.graph.Node; - -/** - * An abstract implementation of a record writer that writes records to a line - * based tuple formats. - * <p> - * The implementation only writes the value portion of the key value pair since - * it is the value portion that is used to convey the node tuples - * </p> - * - * - * @param <TKey> - * Key type - * @param <TValue> - * Tuple type - * @param <T> - * Writable node tuple type - * - */ -public abstract class AbstractLineBasedNodeTupleWriter<TKey, TValue, T extends AbstractNodeTupleWritable<TValue>> extends - RecordWriter<TKey, T> { - /** - * Default separator written between nodes - */ - public static final String DEFAULT_SEPARATOR = " "; - /** - * Default terminator written at the end of each line - */ - public static final String DEFAULT_TERMINATOR = "."; - - private static final Logger log = LoggerFactory.getLogger(AbstractLineBasedNodeTupleWriter.class); - - private AWriter writer; - private NodeFormatter formatter; - - /** - * Creates a new tuple writer using the default NTriples node formatter - * - * @param writer - * Writer - */ - public AbstractLineBasedNodeTupleWriter(Writer writer) { - this(writer, new NodeFormatterNT()); - } - - /** - * Creates a new tuple writer - * - * @param writer - * Writer - * @param formatter - * Node formatter - */ - public AbstractLineBasedNodeTupleWriter(Writer writer, NodeFormatter formatter) { - if (writer == null) - throw new NullPointerException("writer cannot be null"); - if (formatter == null) - throw new NullPointerException("formatter cannot be null"); - this.formatter = formatter; - this.writer = Writer2.wrap(writer); - } - - @Override - public void write(TKey key, T value) throws IOException, InterruptedException { - log.debug("write({}={})", key, value); - - Node[] ns = this.getNodes(value); - String sep = this.getSeparator(); - NodeFormatter formatter = this.getNodeFormatter(); - for (int i = 0; i < ns.length; i++) { - formatter.format(this.writer, ns[i]); - this.writer.print(sep); - } - this.writer.println(this.getTerminator()); - this.writer.flush(); - } - - /** - * Gets the nodes of the tuple in the order they should be written - * - * @param tuple - * Tuple - * @return Nodes - */ - protected abstract Node[] getNodes(T tuple); - - /** - * Gets the node formatter to use for formatting nodes - * - * @return Node formatter - */ - protected NodeFormatter getNodeFormatter() { - return this.formatter; - } - - /** - * Gets the separator that is written between nodes - * - * @return Separator - */ - protected String getSeparator() { - return DEFAULT_SEPARATOR; - } - - /** - * Gets the terminator that is written at the end of each tuple - * - * @return Terminator - */ - protected String getTerminator() { - return DEFAULT_TERMINATOR; - } - - @Override - public void close(TaskAttemptContext context) throws IOException, InterruptedException { - log.debug("close({})", context); - writer.close(); - } -} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedQuadWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedQuadWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedQuadWriter.java deleted file mode 100644 index 9ecef61..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedQuadWriter.java +++ /dev/null @@ -1,71 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.types.QuadWritable; -import org.apache.jena.riot.out.NodeFormatter; -import org.apache.jena.riot.out.NodeFormatterNT; - -import com.hp.hpl.jena.graph.Node; -import com.hp.hpl.jena.sparql.core.Quad; - -/** - * An abstract writer for line based quad formats - * - * - * @param <TKey> - * - */ -public abstract class AbstractLineBasedQuadWriter<TKey> extends AbstractLineBasedNodeTupleWriter<TKey, Quad, QuadWritable> { - - /** - * Creates a new writer using the default NTriples node formatter - * - * @param writer - * Writer - */ - public AbstractLineBasedQuadWriter(Writer writer) { - this(writer, new NodeFormatterNT()); - } - - /** - * Creates a new writer using the specified node formatter - * - * @param writer - * Writer - * @param formatter - * Node formatter - */ - public AbstractLineBasedQuadWriter(Writer writer, NodeFormatter formatter) { - super(writer, formatter); - } - - @Override - protected Node[] getNodes(QuadWritable tuple) { - Quad q = tuple.get(); - if (q.isDefaultGraph()) { - return new Node[] { q.getSubject(), q.getPredicate(), q.getObject() }; - } else { - return new Node[] { q.getSubject(), q.getPredicate(), q.getObject(), q.getGraph() }; - } - } - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedTripleWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedTripleWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedTripleWriter.java deleted file mode 100644 index 161c067..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractLineBasedTripleWriter.java +++ /dev/null @@ -1,68 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.types.TripleWritable; -import org.apache.jena.riot.out.NodeFormatter; -import org.apache.jena.riot.out.NodeFormatterNT; - -import com.hp.hpl.jena.graph.Node; -import com.hp.hpl.jena.graph.Triple; - -/** - * An abstract writer for line based triple formats - * - * @param <TKey> - * Key type - * - */ -public abstract class AbstractLineBasedTripleWriter<TKey> extends - AbstractLineBasedNodeTupleWriter<TKey, Triple, TripleWritable> { - - /** - * Creates a new writer using the default NTriples node formatter - * - * @param writer - * Writer - */ - public AbstractLineBasedTripleWriter(Writer writer) { - this(writer, new NodeFormatterNT()); - } - - /** - * Creates a new writer using the specified node formatter - * - * @param writer - * Writer - * @param formatter - * Node formatter - */ - public AbstractLineBasedTripleWriter(Writer writer, NodeFormatter formatter) { - super(writer, formatter); - } - - @Override - protected Node[] getNodes(TripleWritable tuple) { - Triple t = tuple.get(); - return new Node[] { t.getSubject(), t.getPredicate(), t.getObject() }; - } - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractNodeWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractNodeWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractNodeWriter.java deleted file mode 100644 index 9d8eeb2..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractNodeWriter.java +++ /dev/null @@ -1,192 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers; - -import java.io.IOException; -import java.io.Writer; - -import org.apache.hadoop.io.NullWritable; -import org.apache.hadoop.mapreduce.RecordWriter; -import org.apache.hadoop.mapreduce.TaskAttemptContext; -import org.apache.jena.atlas.io.AWriter; -import org.apache.jena.atlas.io.Writer2; -import org.apache.jena.atlas.lib.Tuple; -import org.apache.jena.hadoop.rdf.types.NodeTupleWritable; -import org.apache.jena.hadoop.rdf.types.NodeWritable; -import org.apache.jena.hadoop.rdf.types.QuadWritable; -import org.apache.jena.hadoop.rdf.types.TripleWritable; -import org.apache.jena.riot.out.NodeFormatter; -import org.apache.jena.riot.out.NodeFormatterNT; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - -import com.hp.hpl.jena.graph.Node; -import com.hp.hpl.jena.graph.Triple; -import com.hp.hpl.jena.sparql.core.Quad; - -/** - * Abstract implementation of a record writer which writes pairs of nodes and - * arbitrary values to text based files - * - * - * - * @param <TValue> - */ -public abstract class AbstractNodeWriter<TValue> extends RecordWriter<NodeWritable, TValue> { - - /** - * Default separator written between nodes and their associated values - */ - public static final String DEFAULT_SEPARATOR = "\t"; - - private static final Logger log = LoggerFactory.getLogger(AbstractNodeWriter.class); - - protected AWriter writer; - private NodeFormatter formatter; - - /** - * Creates a new tuple writer using the default NTriples node formatter - * - * @param writer - * Writer - */ - public AbstractNodeWriter(Writer writer) { - this(writer, new NodeFormatterNT()); - } - - /** - * Creates a new tuple writer - * - * @param writer - * Writer - * @param formatter - * Node formatter - */ - public AbstractNodeWriter(Writer writer, NodeFormatter formatter) { - if (writer == null) - throw new NullPointerException("writer cannot be null"); - if (formatter == null) - throw new NullPointerException("formatter cannot be null"); - this.formatter = formatter; - this.writer = Writer2.wrap(writer); - } - - @Override - public final void write(NodeWritable key, TValue value) throws IOException, InterruptedException { - this.writeKey(key); - this.writer.write(this.getSeparator()); - this.writeValue(value); - this.writer.write('\n'); - } - - /** - * Writes the given key - * - * @param key - * Key - */ - protected void writeKey(NodeWritable key) { - writeNode(key.get()); - } - - /** - * Writes a Node - * - * @param n - * Node - */ - protected void writeNode(Node n) { - this.getNodeFormatter().format(this.writer, n); - } - - /** - * Writes a sequence of nodes - * - * @param ns - * Nodes - */ - protected void writeNodes(Node... ns) { - String sep = this.getSeparator(); - for (int i = 0; i < ns.length; i++) { - writeNode(ns[i]); - if (i < ns.length - 1) - this.writer.write(sep); - } - } - - /** - * Writes the given value - * <p> - * If the value is one of the RDF primitives - {@link NodeWritable}, - * {@link TripleWritable}, {@link QuadWritable} and - * {@link NodeTupleWritable} - then it is formatted as a series of nodes - * separated by the separator. Otherwise it is formatted by simply calling - * {@code toString()} on it. - * </p> - * - * @param value - * Values - */ - protected void writeValue(TValue value) { - // Handle null specially - if (value instanceof NullWritable || value == null) - return; - - // Handle RDF primitives specially and format them as proper nodes - if (value instanceof NodeWritable) { - this.writeKey((NodeWritable) value); - } else if (value instanceof TripleWritable) { - Triple t = ((TripleWritable) value).get(); - this.writeNodes(t.getSubject(), t.getPredicate(), t.getObject()); - } else if (value instanceof QuadWritable) { - Quad q = ((QuadWritable) value).get(); - this.writeNodes(q.getGraph(), q.getSubject(), q.getPredicate(), q.getObject()); - } else if (value instanceof NodeTupleWritable) { - Tuple<Node> tuple = ((NodeTupleWritable) value).get(); - this.writeNodes(tuple.tuple()); - } else { - // For arbitrary values just toString() them - this.writer.write(value.toString()); - } - } - - @Override - public void close(TaskAttemptContext context) throws IOException, InterruptedException { - log.debug("close({})", context); - writer.close(); - } - - /** - * Gets the node formatter to use for formatting nodes - * - * @return Node formatter - */ - protected NodeFormatter getNodeFormatter() { - return this.formatter; - } - - /** - * Gets the separator that is written between nodes - * - * @return Separator - */ - protected String getSeparator() { - return DEFAULT_SEPARATOR; - } -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractStreamRdfNodeTupleWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractStreamRdfNodeTupleWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractStreamRdfNodeTupleWriter.java deleted file mode 100644 index aa178b2..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractStreamRdfNodeTupleWriter.java +++ /dev/null @@ -1,71 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers; - -import java.io.IOException; -import java.io.Writer; - -import org.apache.hadoop.mapreduce.RecordWriter; -import org.apache.hadoop.mapreduce.TaskAttemptContext; -import org.apache.jena.hadoop.rdf.types.AbstractNodeTupleWritable; -import org.apache.jena.riot.system.StreamRDF; - -public abstract class AbstractStreamRdfNodeTupleWriter<TKey, TTuple, TValue extends AbstractNodeTupleWritable<TTuple>> - extends RecordWriter<TKey, TValue> { - - private StreamRDF stream; - private Writer writer; - - public AbstractStreamRdfNodeTupleWriter(StreamRDF stream, Writer writer) { - if (stream == null) - throw new NullPointerException("stream cannot be null"); - if (writer == null) - throw new NullPointerException("writer cannot be null"); - this.stream = stream; - this.stream.start(); - this.writer = writer; - } - - @Override - public void close(TaskAttemptContext context) throws IOException, - InterruptedException { - this.stream.finish(); - this.writer.close(); - } - - @Override - public void write(TKey key, TValue value) throws IOException, - InterruptedException { - this.sendOutput(key, value, this.stream); - } - - /** - * Method that handles an actual key value pair passing it to the - * {@link StreamRDF} instance as appropriate - * - * @param key - * Key - * @param value - * Value - * @param stream - * RDF Stream - */ - protected abstract void sendOutput(TKey key, TValue value, StreamRDF stream); - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileNodeTupleWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileNodeTupleWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileNodeTupleWriter.java deleted file mode 100644 index d48546b..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileNodeTupleWriter.java +++ /dev/null @@ -1,96 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers; - -import java.io.IOException; -import java.io.Writer; - -import org.apache.hadoop.mapreduce.RecordWriter; -import org.apache.hadoop.mapreduce.TaskAttemptContext; -import org.apache.jena.hadoop.rdf.types.AbstractNodeTupleWritable; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - - -/** - * An abstract implementation of a record writer that writes records to whole - * file formats. - * <p> - * It is important to note that the writer does not actually write any output - * until the {@link #close(TaskAttemptContext)} method is called as it must - * write the entire output in one go otherwise the output would be invalid. Also - * writing in one go increases the chances that the writer will be able to - * effectively use the syntax compressions of the RDF serialization being used. - * </p> - * <p> - * The implementation only writes the value portion of the key value pair since - * it is the value portion that is used to convey the node tuples - * </p> - * - * - * - * @param <TKey> - * @param <TValue> - * @param <T> - */ -public abstract class AbstractWholeFileNodeTupleWriter<TKey, TValue, T extends AbstractNodeTupleWritable<TValue>> extends - RecordWriter<TKey, T> { - private static final Logger LOG = LoggerFactory.getLogger(AbstractWholeFileNodeTupleWriter.class); - - private Writer writer; - - protected AbstractWholeFileNodeTupleWriter(Writer writer) { - if (writer == null) - throw new NullPointerException("writer cannot be null"); - this.writer = writer; - } - - @Override - public final void write(TKey key, T value) throws IOException, InterruptedException { - LOG.debug("write({}={})", key, value); - this.add(value); - } - - /** - * Adds the tuple to the cache of tuples that will be written when the - * {@link #close(TaskAttemptContext)} method is called - * - * @param value - */ - protected abstract void add(T value); - - @Override - public void close(TaskAttemptContext context) throws IOException, InterruptedException { - if (this.writer != null) { - this.writeOutput(writer); - this.writer.close(); - this.writer = null; - } - } - - /** - * Writes the cached tuples to the writer, the writer should not be closed - * by this method implementation - * - * @param writer - * Writer - */ - protected abstract void writeOutput(Writer writer); - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileQuadWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileQuadWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileQuadWriter.java deleted file mode 100644 index 5fc0024..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileQuadWriter.java +++ /dev/null @@ -1,66 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.types.QuadWritable; -import org.apache.jena.riot.Lang; -import org.apache.jena.riot.RDFDataMgr; -import org.apache.jena.riot.RDFWriterRegistry; - -import com.hp.hpl.jena.sparql.core.DatasetGraph; -import com.hp.hpl.jena.sparql.core.DatasetGraphFactory; -import com.hp.hpl.jena.sparql.core.Quad; - -/** - * An abstract record writer for whole file triple formats - * - * - * - * @param <TKey> - * Key type - */ -public abstract class AbstractWholeFileQuadWriter<TKey> extends AbstractWholeFileNodeTupleWriter<TKey, Quad, QuadWritable> { - - private DatasetGraph g = DatasetGraphFactory.createMem(); - - protected AbstractWholeFileQuadWriter(Writer writer) { - super(writer); - } - - @Override - protected final void add(QuadWritable value) { - this.g.add(value.get()); - } - - @SuppressWarnings("deprecation") - @Override - protected void writeOutput(Writer writer) { - RDFDataMgr.write(writer, this.g, RDFWriterRegistry.defaultSerialization(this.getRdfLanguage())); - } - - /** - * Gets the RDF language to write the output in - * - * @return RDF language - */ - protected abstract Lang getRdfLanguage(); - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileTripleWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileTripleWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileTripleWriter.java deleted file mode 100644 index bb26093..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/AbstractWholeFileTripleWriter.java +++ /dev/null @@ -1,65 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.types.TripleWritable; -import org.apache.jena.riot.Lang; -import org.apache.jena.riot.RDFDataMgr; - -import com.hp.hpl.jena.graph.Graph; -import com.hp.hpl.jena.graph.Triple; -import com.hp.hpl.jena.sparql.graph.GraphFactory; - -/** - * An abstract record writer for whole file triple formats - * - * - * - * @param <TKey> - * Key type - */ -public abstract class AbstractWholeFileTripleWriter<TKey> extends AbstractWholeFileNodeTupleWriter<TKey, Triple, TripleWritable> { - - private Graph g = GraphFactory.createDefaultGraph(); - - protected AbstractWholeFileTripleWriter(Writer writer) { - super(writer); - } - - @Override - protected final void add(TripleWritable value) { - this.g.add(value.get()); - } - - @SuppressWarnings("deprecation") - @Override - protected final void writeOutput(Writer writer) { - RDFDataMgr.write(writer, this.g, this.getRdfLanguage()); - } - - /** - * Gets the RDF language to write the output in - * - * @return RDF language - */ - protected abstract Lang getRdfLanguage(); - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/QuadsToTriplesWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/QuadsToTriplesWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/QuadsToTriplesWriter.java deleted file mode 100644 index e932e1f..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/QuadsToTriplesWriter.java +++ /dev/null @@ -1,59 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ -package org.apache.jena.hadoop.rdf.io.output.writers; - -import java.io.IOException; - -import org.apache.hadoop.mapreduce.RecordWriter; -import org.apache.hadoop.mapreduce.TaskAttemptContext; -import org.apache.jena.hadoop.rdf.types.QuadWritable; -import org.apache.jena.hadoop.rdf.types.TripleWritable; - -/** - * A record writer that converts quads into triples by stripping off the graph - * field - * - * @param <TKey> - * Key type - */ -public class QuadsToTriplesWriter<TKey> extends RecordWriter<TKey, QuadWritable> { - - private RecordWriter<TKey, TripleWritable> writer; - - /** - * Creates a new writer - * - * @param tripleWriter - * Triple writer to use - */ - public QuadsToTriplesWriter(RecordWriter<TKey, TripleWritable> tripleWriter) { - if (tripleWriter == null) - throw new NullPointerException("tripleWriter cannot be null"); - this.writer = tripleWriter; - } - - @Override - public void write(TKey key, QuadWritable value) throws IOException, InterruptedException { - this.writer.write(key, new TripleWritable(value.get().asTriple())); - } - - @Override - public void close(TaskAttemptContext context) throws IOException, InterruptedException { - this.writer.close(context); - } -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/StreamRdfQuadWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/StreamRdfQuadWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/StreamRdfQuadWriter.java deleted file mode 100644 index e9156d2..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/StreamRdfQuadWriter.java +++ /dev/null @@ -1,45 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.types.QuadWritable; -import org.apache.jena.riot.system.StreamRDF; - -import com.hp.hpl.jena.sparql.core.Quad; - -/** - * A writer for {@link StreamRDF} based quad writers - * - * @param <TKey> - * Key type - */ -public class StreamRdfQuadWriter<TKey> extends - AbstractStreamRdfNodeTupleWriter<TKey, Quad, QuadWritable> { - - public StreamRdfQuadWriter(StreamRDF stream, Writer writer) { - super(stream, writer); - } - - @Override - protected void sendOutput(TKey key, QuadWritable value, StreamRDF stream) { - stream.quad(value.get()); - } -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/StreamRdfTripleWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/StreamRdfTripleWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/StreamRdfTripleWriter.java deleted file mode 100644 index 174edf3..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/StreamRdfTripleWriter.java +++ /dev/null @@ -1,44 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.types.TripleWritable; -import org.apache.jena.riot.system.StreamRDF; - -import com.hp.hpl.jena.graph.Triple; - -/** - * A writer for {@link StreamRDF} based triple writers - * - * @param <TKey> - * Key type - */ -public class StreamRdfTripleWriter<TKey> extends AbstractStreamRdfNodeTupleWriter<TKey, Triple, TripleWritable> { - - public StreamRdfTripleWriter(StreamRDF stream, Writer writer) { - super(stream, writer); - } - - @Override - protected void sendOutput(TKey key, TripleWritable value, StreamRDF stream) { - stream.triple(value.get()); - } -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/jsonld/JsonLDQuadWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/jsonld/JsonLDQuadWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/jsonld/JsonLDQuadWriter.java deleted file mode 100644 index 1b4b62f..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/jsonld/JsonLDQuadWriter.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers.jsonld; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.io.output.writers.AbstractWholeFileQuadWriter; -import org.apache.jena.riot.Lang; -import org.apache.jena.riot.RDFLanguages; - -public class JsonLDQuadWriter<TKey> extends AbstractWholeFileQuadWriter<TKey> { - - public JsonLDQuadWriter(Writer writer) { - super(writer); - } - - @Override - protected Lang getRdfLanguage() { - return RDFLanguages.JSONLD; - } - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/jsonld/JsonLDTripleWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/jsonld/JsonLDTripleWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/jsonld/JsonLDTripleWriter.java deleted file mode 100644 index 8d2079d..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/jsonld/JsonLDTripleWriter.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers.jsonld; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.io.output.writers.AbstractWholeFileTripleWriter; -import org.apache.jena.riot.Lang; -import org.apache.jena.riot.RDFLanguages; - -public class JsonLDTripleWriter<TKey> extends AbstractWholeFileTripleWriter<TKey> { - - public JsonLDTripleWriter(Writer writer) { - super(writer); - } - - @Override - protected Lang getRdfLanguage() { - return RDFLanguages.JSONLD; - } - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/nquads/NQuadsWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/nquads/NQuadsWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/nquads/NQuadsWriter.java deleted file mode 100644 index 8df606d..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/nquads/NQuadsWriter.java +++ /dev/null @@ -1,57 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers.nquads; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.io.output.writers.AbstractLineBasedQuadWriter; -import org.apache.jena.riot.out.CharSpace; -import org.apache.jena.riot.out.NodeFormatterNT; - -/** - * A record writer for NQuads - * - * - * - * @param <TKey> - */ -public class NQuadsWriter<TKey> extends AbstractLineBasedQuadWriter<TKey> { - - /** - * Creates a new writer - * - * @param writer - * Writer - */ - public NQuadsWriter(Writer writer) { - super(writer, new NodeFormatterNT()); - } - - /** - * Creates a new writer using the given character space - * - * @param writer - * Writer - * @param charSpace - * Character space - */ - public NQuadsWriter(Writer writer, CharSpace charSpace) { - super(writer, new NodeFormatterNT(charSpace)); - } -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/ntriples/NTriplesNodeWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/ntriples/NTriplesNodeWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/ntriples/NTriplesNodeWriter.java deleted file mode 100644 index 6413f21..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/ntriples/NTriplesNodeWriter.java +++ /dev/null @@ -1,59 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers.ntriples; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.io.output.writers.AbstractNodeWriter; -import org.apache.jena.riot.out.CharSpace; -import org.apache.jena.riot.out.NodeFormatterNT; - -/** - * A NTriples based node writer - * - * - * - * @param <TValue> - * Value type - */ -public class NTriplesNodeWriter<TValue> extends AbstractNodeWriter<TValue> { - - /** - * Creates a new writer - * - * @param writer - * Writer - */ - public NTriplesNodeWriter(Writer writer) { - super(writer); - } - - /** - * Creates a new writer - * - * @param writer - * Writer - * @param charSpace - * Character space to use - */ - public NTriplesNodeWriter(Writer writer, CharSpace charSpace) { - super(writer, new NodeFormatterNT(charSpace)); - } - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/ntriples/NTriplesWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/ntriples/NTriplesWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/ntriples/NTriplesWriter.java deleted file mode 100644 index 2b3c0b4..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/ntriples/NTriplesWriter.java +++ /dev/null @@ -1,58 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers.ntriples; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.io.output.writers.AbstractLineBasedTripleWriter; -import org.apache.jena.riot.out.CharSpace; -import org.apache.jena.riot.out.NodeFormatterNT; - -/** - * A record writer for NTriples - * - * - * @param <TKey> - * Key type - * - */ -public class NTriplesWriter<TKey> extends AbstractLineBasedTripleWriter<TKey> { - - /** - * Creates a new writer - * - * @param writer - * Writer - */ - public NTriplesWriter(Writer writer) { - super(writer, new NodeFormatterNT()); - } - - /** - * Creates a new writer using the given character space - * - * @param writer - * Writer - * @param charSpace - * Character space - */ - public NTriplesWriter(Writer writer, CharSpace charSpace) { - super(writer, new NodeFormatterNT(charSpace)); - } -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/rdfjson/RdfJsonWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/rdfjson/RdfJsonWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/rdfjson/RdfJsonWriter.java deleted file mode 100644 index 30bd4fa..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/rdfjson/RdfJsonWriter.java +++ /dev/null @@ -1,51 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers.rdfjson; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.io.output.writers.AbstractWholeFileTripleWriter; -import org.apache.jena.riot.Lang; - -/** - * A record writer for RDF/JSON - * - * - * @param <TKey> - * Key type - * - */ -public class RdfJsonWriter<TKey> extends AbstractWholeFileTripleWriter<TKey> { - - /** - * Creates a new record writer - * - * @param writer - * Writer - */ - public RdfJsonWriter(Writer writer) { - super(writer); - } - - @Override - protected Lang getRdfLanguage() { - return Lang.RDFJSON; - } - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/rdfxml/RdfXmlWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/rdfxml/RdfXmlWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/rdfxml/RdfXmlWriter.java deleted file mode 100644 index f202914..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/rdfxml/RdfXmlWriter.java +++ /dev/null @@ -1,51 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers.rdfxml; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.io.output.writers.AbstractWholeFileTripleWriter; -import org.apache.jena.riot.Lang; - -/** - * A record writer for RDF/XML - * - * - * @param <TKey> - * Key type - * - */ -public class RdfXmlWriter<TKey> extends AbstractWholeFileTripleWriter<TKey> { - - /** - * Creates a new record writer - * - * @param writer - * Writer - */ - public RdfXmlWriter(Writer writer) { - super(writer); - } - - @Override - protected Lang getRdfLanguage() { - return Lang.RDFXML; - } - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/thrift/ThriftQuadWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/thrift/ThriftQuadWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/thrift/ThriftQuadWriter.java deleted file mode 100644 index 599dba9..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/thrift/ThriftQuadWriter.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers.thrift; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.io.output.writers.AbstractWholeFileQuadWriter; -import org.apache.jena.riot.Lang; -import org.apache.jena.riot.RDFLanguages; - -public class ThriftQuadWriter<TKey> extends AbstractWholeFileQuadWriter<TKey> { - - public ThriftQuadWriter(Writer writer) { - super(writer); - } - - @Override - protected Lang getRdfLanguage() { - return RDFLanguages.THRIFT; - } - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/thrift/ThriftTripleWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/thrift/ThriftTripleWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/thrift/ThriftTripleWriter.java deleted file mode 100644 index 0089459..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/thrift/ThriftTripleWriter.java +++ /dev/null @@ -1,38 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers.thrift; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.io.output.writers.AbstractWholeFileTripleWriter; -import org.apache.jena.riot.Lang; -import org.apache.jena.riot.RDFLanguages; - -public class ThriftTripleWriter<TKey> extends AbstractWholeFileTripleWriter<TKey> { - - public ThriftTripleWriter(Writer writer) { - super(writer); - } - - @Override - protected Lang getRdfLanguage() { - return RDFLanguages.THRIFT; - } - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/trig/BatchedTriGWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/trig/BatchedTriGWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/trig/BatchedTriGWriter.java deleted file mode 100644 index 4c0c75f..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/trig/BatchedTriGWriter.java +++ /dev/null @@ -1,52 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers.trig; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.io.output.writers.AbstractBatchedQuadWriter; -import org.apache.jena.riot.Lang; - -/** - * A record writer for TriG that uses the batched approach, note that this - * approach will produce invalid data when blank nodes span batches - * - * @param <TKey> - * Key type - */ -public class BatchedTriGWriter<TKey> extends AbstractBatchedQuadWriter<TKey> { - - /** - * Creates a new record writer - * - * @param writer - * Writer - * @param batchSize - * Batch size - */ - public BatchedTriGWriter(Writer writer, long batchSize) { - super(writer, batchSize); - } - - @Override - protected Lang getRdfLanguage() { - return Lang.TRIG; - } - -} http://git-wip-us.apache.org/repos/asf/jena/blob/49c4cffe/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/turtle/BatchedTurtleWriter.java ---------------------------------------------------------------------- diff --git a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/turtle/BatchedTurtleWriter.java b/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/turtle/BatchedTurtleWriter.java deleted file mode 100644 index 86ab2f9..0000000 --- a/jena-hadoop-rdf/jena-elephas-io/src/main/java/org/apache/jena/hadoop/rdf/io/output/writers/turtle/BatchedTurtleWriter.java +++ /dev/null @@ -1,54 +0,0 @@ -/* - * Licensed to the Apache Software Foundation (ASF) under one - * or more contributor license agreements. See the NOTICE file - * distributed with this work for additional information - * regarding copyright ownership. The ASF licenses this file - * to you under the Apache License, Version 2.0 (the - * "License"); you may not use this file except in compliance - * with the License. You may obtain a copy of the License at - * - * http://www.apache.org/licenses/LICENSE-2.0 - * - * Unless required by applicable law or agreed to in writing, software - * distributed under the License is distributed on an "AS IS" BASIS, - * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - * See the License for the specific language governing permissions and - * limitations under the License. - */ - -package org.apache.jena.hadoop.rdf.io.output.writers.turtle; - -import java.io.Writer; - -import org.apache.jena.hadoop.rdf.io.output.writers.AbstractBatchedTripleWriter; -import org.apache.jena.riot.Lang; - -/** - * A record writer for Turtle that uses the batched approach, note that this - * approach will produce invalid data when blank nodes span batches - * - * - * - * @param <TKey> - */ -public class BatchedTurtleWriter<TKey> extends - AbstractBatchedTripleWriter<TKey> { - - /** - * Creates a new record writer - * - * @param writer - * Writer - * @param batchSize - * Batch size - */ - public BatchedTurtleWriter(Writer writer, long batchSize) { - super(writer, batchSize); - } - - @Override - protected Lang getRdfLanguage() { - return Lang.TURTLE; - } - -}
