org.eclipse.rdf4j.rio.Rio.createWriter()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(9.8k)|赞(0)|评价(0)|浏览(127)

本文整理了Java中org.eclipse.rdf4j.rio.Rio.createWriter方法的一些代码示例,展示了Rio.createWriter的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Rio.createWriter方法的具体详情如下:
包路径:org.eclipse.rdf4j.rio.Rio
类名称:Rio
方法名:createWriter

Rio.createWriter介绍

[英]Convenience methods for creating RDFWriter objects. This method uses the registry returned by RDFWriterRegistry#getInstance() to get a factory for the specified format and uses this factory to create the appropriate writer.
[中]

代码示例

代码示例来源:origin: Merck/Halyard

public RIOResultWriter(StatusLog log, RDFFormat rdfFormat, OutputStream out) {
  super(log);
  this.out = out;
  this.writer = Rio.createWriter(rdfFormat, out);
}

代码示例来源:origin: org.apache.any23/apache-any23-core

/**
 * Creates a new {@link RDFWriter} instance.
 *
 * @param format output format.
 * @param os output stream.
 * @return writer instance.
 * @throws IllegalArgumentException if format is not supported.
 */
public static RDFWriter getWriter(RDFFormat format, OutputStream os) {
  return Rio.createWriter(format, os);
}

代码示例来源:origin: org.apache.any23/apache-any23-core

/**
 * Creates a new {@link RDFWriter} instance.
 *
 * @param format output format.
 * @param writer data output writer.
 * @return writer instance.
 * @throws IllegalArgumentException if format is not supported.
 */
public static RDFWriter getWriter(RDFFormat format, Writer writer) {
  return Rio.createWriter(format, writer);
}

代码示例来源:origin: Wikidata/Wikidata-Toolkit

public RdfWriter(RDFFormat format, OutputStream output) throws UnsupportedRDFormatException {
  this(Rio.createWriter(format, output));
}

代码示例来源:origin: org.apache.any23/apache-any23-core

public NQuadsWriter(OutputStream os) {
  super( Rio.createWriter(RDFFormat.NQUADS, os) );
}

代码示例来源:origin: fr.lirmm.graphik/graal-io-rdf

public RDFWriter(OutputStream os, RDFFormat format) {
  this.writer = Rio.createWriter(format, os);
  this.writer.startRDF();
}
public RDFWriter(java.io.Writer writer, RDFFormat format) {

代码示例来源:origin: fr.lirmm.graphik/graal-io-rdf

public RDFWriter(java.io.Writer writer, RDFFormat format) {
  this.writer = Rio.createWriter(format, writer);
  this.writer.startRDF();
}
// /////////////////////////////////////////////////////////////////////////

代码示例来源:origin: HuygensING/timbuctoo

public Rdf4jWriter(OutputStream outputStream, RDFFormat rdfFormat) {
 writer = new BufferedWriter(new OutputStreamWriter(outputStream, UTF_8));
 rdfWriter = Rio.createWriter(rdfFormat, writer);
 this.rdfFormat = rdfFormat;
 valueFactory = SimpleValueFactory.getInstance();
 rdfWriter.startRDF();
}

代码示例来源:origin: org.eclipse.rdf4j/rdf4j-client

public static void main(String[] args)
  throws IOException, RDFParseException, RDFHandlerException, UnsupportedRDFormatException
{
  if (args.length < 2) {
    System.out.println("Usage: java org.eclipse.rdf4j.rio.Rio <inputFile> <outputFile>");
    System.exit(1);
    return;
  }
  String inputFile = args[0];
  String outputFile = args[1];
  try (FileOutputStream outStream = new FileOutputStream(outputFile);
      FileInputStream inStream = new FileInputStream(inputFile);)
  {
    createParser(getParserFormatForFileName(inputFile).orElse(RDFFormat.RDFXML)).setRDFHandler(
        createWriter(getWriterFormatForFileName(outputFile).orElse(RDFFormat.RDFXML),
            outStream)).parse(inStream, "file:" + inputFile);
  }
}

代码示例来源:origin: eclipse/rdf4j

public static void main(String[] args)
  throws IOException, RDFParseException, RDFHandlerException, UnsupportedRDFormatException
{
  if (args.length < 2) {
    System.out.println("Usage: java org.eclipse.rdf4j.rio.Rio <inputFile> <outputFile>");
    System.exit(1);
    return;
  }
  String inputFile = args[0];
  String outputFile = args[1];
  try (FileOutputStream outStream = new FileOutputStream(outputFile);
      FileInputStream inStream = new FileInputStream(inputFile);)
  {
    createParser(getParserFormatForFileName(inputFile).orElse(RDFFormat.RDFXML)).setRDFHandler(
        createWriter(getWriterFormatForFileName(outputFile).orElse(RDFFormat.RDFXML),
            outStream)).parse(inStream, "file:" + inputFile);
  }
}

代码示例来源:origin: org.eclipse.rdf4j/rdf4j-rio-api

public static void main(String[] args)
  throws IOException, RDFParseException, RDFHandlerException, UnsupportedRDFormatException
{
  if (args.length < 2) {
    System.out.println("Usage: java org.eclipse.rdf4j.rio.Rio <inputFile> <outputFile>");
    System.exit(1);
    return;
  }
  String inputFile = args[0];
  String outputFile = args[1];
  try (FileOutputStream outStream = new FileOutputStream(outputFile);
      FileInputStream inStream = new FileInputStream(inputFile);)
  {
    createParser(getParserFormatForFileName(inputFile).orElse(RDFFormat.RDFXML)).setRDFHandler(
        createWriter(getWriterFormatForFileName(outputFile).orElse(RDFFormat.RDFXML),
            outStream)).parse(inStream, "file:" + inputFile);
  }
}

代码示例来源:origin: org.eclipse.rdf4j/rdf4j-rio-api

/**
 * Writes the given single statement to the given {@link OutputStream} in the given format.
 * 
 * @param st
 *        The statement to be written.
 * @param output
 *        The {@link OutputStream} to write the statement to.
 * @param dataFormat
 *        The {@link RDFFormat} to use when writing the statement.
 * @param settings
 *        The {@link WriterConfig} containing setting for configuring the writer.
 * @throws RDFHandlerException
 *         Thrown if there is an error writing the statement.
 * @throws UnsupportedRDFormatException
 *         If no {@link RDFWriter} is available for the specified RDF format.
 */
public static void write(Statement st, OutputStream output, RDFFormat dataFormat, WriterConfig settings)
  throws RDFHandlerException
{
  final RDFWriter writer = Rio.createWriter(dataFormat, output);
  writer.setWriterConfig(settings);
  write(st, writer);
}

代码示例来源:origin: de.tudarmstadt.ukp.inception.app/inception-kb

@Override
public void exportData(KnowledgeBase kb, RDFFormat format, OutputStream os)
{
  if (kb.getType() != RepositoryType.LOCAL) {
    log.info("Not exporting non-local knowledge base: [{}]", kb.getName());
    return;
  }
  try (RepositoryConnection conn = getConnection(kb)) {
    RDFWriter rdfWriter = Rio.createWriter(format, os);
    conn.export(rdfWriter);
  }
}

代码示例来源:origin: joshsh/sesametools

private void translateRDFDocument(final InputStream in,
                      final OutputStream out,
                      final RDFFormat inFormat,
                      final RDFFormat outFormat,
                      final String baseURI)
      throws SailException, IOException, RDFHandlerException, RDFParseException {

    RDFParser p = Rio.createParser(inFormat);
    RDFWriter w = Rio.createWriter(outFormat, out);

    p.setRDFHandler(w);

    p.parse(in, baseURI);
  }
}

代码示例来源:origin: inception-project/inception

@Override
public void exportData(KnowledgeBase kb, RDFFormat format, OutputStream os)
{
  if (kb.getType() != RepositoryType.LOCAL) {
    log.info("Not exporting non-local knowledge base: [{}]", kb.getName());
    return;
  }
  try (RepositoryConnection conn = getConnection(kb)) {
    RDFWriter rdfWriter = Rio.createWriter(format, os);
    conn.export(rdfWriter);
  }
}

代码示例来源:origin: joshsh/sesametools

@Override
  public void execute(SesamizeArgs args) throws Exception {
      Long totalTriples = Long.valueOf(args.nonOptions.get(1));
      RDFFormat outputFormat = args.getRDFFormat(RDFFormat.RDFXML, "o", "outputFormat");

      OutputStream os = System.out;

      RandomValueFactory rvf = new RandomValueFactory(
          SimpleValueFactory.getInstance());

      RDFWriter writer = Rio.createWriter(outputFormat, os);
      writer.startRDF();
      for (long l = 0L; l < totalTriples; l++) {
        Statement st = rvf.randomStatement();
        writer.handleStatement(st);
      }
      writer.endRDF();

      os.close();
  }
}

代码示例来源:origin: joshsh/sesametools

private void dumpNativeStoreToRDFDocument(final File nativeStoreDirectory,
                       final File dumpFile,
                       final RDFFormat format,
                       final Resource... contexts)
      throws SailException, RepositoryException, IOException, RDFHandlerException {

    logger.info("dumping store at " + nativeStoreDirectory + " to file " + dumpFile);

    Sail sail = new NativeStore(nativeStoreDirectory);
    sail.initialize();

    try {
      Repository repo = new SailRepository(sail);

      try (RepositoryConnection rc = repo.getConnection()) {
        try (OutputStream out = new FileOutputStream(dumpFile)) {
          RDFHandler h = Rio.createWriter(format, out);
          rc.export(h, contexts);
        }
      }
    } finally {
      sail.shutDown();
    }
  }
}

代码示例来源:origin: jbarrasa/neosemantics

@Override
public void write(OutputStream outputStream) throws IOException, WebApplicationException {
  RDFWriter writer = Rio.createWriter(getFormat(acceptHeaderParam), outputStream);
  SimpleValueFactory valueFactory = SimpleValueFactory.getInstance();
  handleNamespaces(writer, gds);
  writer.startRDF();
  try (Transaction tx = gds.beginTx()) {
    Map<String, String> mappings = getMappingsFromDB(gds);
    Node node = (Node) gds.getNodeById(idParam);
    processNodeInLPG(writer, valueFactory, mappings, node, onlyMappedInfo!=null);
    if (excludeContextParam == null) {
      processRelsOnLPG(writer, valueFactory, mappings, node, onlyMappedInfo!=null);
    }
    writer.endRDF();
  }catch(NotFoundException e){
    writer.endRDF();
  }
}

代码示例来源:origin: streampipes/streampipes-ce

private static RDFWriter getRioWriter(OutputStream stream) throws RDFHandlerException {
 RDFWriter writer = Rio.createWriter(RDFFormat.JSONLD, stream);
 writer.handleNamespace("sp", "https://streampipes.org/vocabulary/v1/");
 writer.handleNamespace("ssn", "http://purl.oclc.org/NET/ssnx/ssn#");
 writer.handleNamespace("xsd", "http://www.w3.org/2001/XMLSchema#");
 writer.handleNamespace("empire", "urn:clarkparsia.com:empire:");
 writer.handleNamespace("spi", "urn:streampipes.org:spi:");
 writer.getWriterConfig().set(JSONLDSettings.JSONLD_MODE, JSONLDMode.COMPACT);
 writer.getWriterConfig().set(JSONLDSettings.OPTIMIZE, true);
 writer.getWriterConfig().set(BasicWriterSettings.PRETTY_PRINT, true);
 return writer;
}

代码示例来源:origin: org.streampipes/streampipes-commons

private static RDFWriter getRioWriter(OutputStream stream) throws RDFHandlerException {
 RDFWriter writer = Rio.createWriter(RDFFormat.JSONLD, stream);
 writer.handleNamespace("sp", "https://streampipes.org/vocabulary/v1/");
 writer.handleNamespace("ssn", "http://purl.oclc.org/NET/ssnx/ssn#");
 writer.handleNamespace("xsd", "http://www.w3.org/2001/XMLSchema#");
 writer.handleNamespace("empire", "urn:clarkparsia.com:empire:");
 writer.handleNamespace("spi", "urn:streampipes.org:spi:");
 writer.getWriterConfig().set(JSONLDSettings.JSONLD_MODE, JSONLDMode.COMPACT);
 writer.getWriterConfig().set(JSONLDSettings.OPTIMIZE, true);
 writer.getWriterConfig().set(BasicWriterSettings.PRETTY_PRINT, true);
 return writer;
}

相关文章