org.apache.jena.atlas.io.IO.openFile()方法的使用及代码示例

x33g5p2x  于2022-01-21 转载在 其他  
字(6.6k)|赞(0)|评价(0)|浏览(120)

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

IO.openFile介绍

[英]Open an input stream to a file. If the filename is null or "-", return System.in If the filename ends in .gz, wrap in GZIPInputStream
[中]打开文件的输入流。如果文件名为null或“-”,则返回System。如果文件名以结尾,则为。gz,用GZIPInputStream包装

代码示例

代码示例来源:origin: org.seaborne.rdf-delta/rdf-delta-client

private InputStream openChangesSrc(String x) {
  // May change to cope with remote source
  return IO.openFile(x) ;
}

代码示例来源:origin: apache/jena

private static Reader openFileReader(String filename, Charset charset)
{
  InputStream in = openFile(filename) ;
  return new InputStreamReader(in, charset) ;
}

代码示例来源:origin: org.apache.clerezza.ext/org.apache.jena.jena-arq

private static Reader openFileReader(String filename, Charset charset)
{
  InputStream in = openFile(filename) ;
  return new InputStreamReader(in, charset) ;
}

代码示例来源:origin: org.apache.jena/jena-base

private static Reader openFileReader(String filename, Charset charset)
{
  InputStream in = openFile(filename) ;
  return new InputStreamReader(in, charset) ;
}

代码示例来源:origin: apache/jena

/**
 * Decode the contents of the input stream and send to the {@link StreamRDF}.
 * @param filename
 */
public static TProtocol protocol(String filename) {
  InputStream in = IO.openFile(filename) ;
  TProtocol protocol = protocol(in) ;
  return protocol ;
}

代码示例来源:origin: org.apache.clerezza.ext/org.apache.jena.jena-arq

public static LangRDFXML create(String xmlBase, String filename, ErrorHandler errorHandler, StreamRDF sink)
{
  return create(IO.openFile(filename), xmlBase, filename, errorHandler, sink) ;
}

代码示例来源:origin: apache/jena

public static CSVParser create(String filename) {
  InputStream input = IO.openFile(filename) ;
  return create(input) ;
}

代码示例来源:origin: apache/jena

public static void main(String... args) {
    if ( args.length == 0 ) {
      args = new String[] {"-"} ;
    }
    
    if ( args.length != 1 ) {
      System.err.println("Usage: "+Lib.classShortName(dumpthrift.class)+" FILE") ;
      System.exit(2) ;
    }
    
    // Leave a general loop ...
    for ( String fn : args ) {
      InputStream in = IO.openFile(fn) ; 
      BinRDF.dump(System.out, in) ;
    }
  }
}

代码示例来源:origin: org.apache.jena/jena-cmds

public static void main(String... args) {
    if ( args.length == 0 ) {
      args = new String[] {"-"} ;
    }
    
    if ( args.length != 1 ) {
      System.err.println("Usage: "+Lib.classShortName(dumpthrift.class)+" FILE") ;
      System.exit(2) ;
    }
    
    // Leave a general loop ...
    for ( String fn : args ) {
      InputStream in = IO.openFile(fn) ; 
      BinRDF.dump(System.out, in) ;
    }
  }
}

代码示例来源:origin: org.apache.clerezza.ext/org.apache.jena.jena-arq

/** Create an UpdateRequest by reading it from a file */
public static UpdateRequest read(UsingList usingList, String fileName, String baseURI, Syntax syntax)
{ 
  InputStream in = null ;
  if ( fileName.equals("-") )
    in = System.in ;
  else
  {
    in = IO.openFile(fileName) ;
    if ( in == null )
      throw new UpdateException("File could not be opened: "+fileName) ;
  }
  return read(usingList, in, baseURI, syntax) ;
}

代码示例来源:origin: org.apache.clerezza.ext/org.apache.jena.jena-arq

/** Parse update operations into a GraphStore by reading it from a file */
public static void parseExecute(UsingList usingList, DatasetGraph dataset, String fileName, Binding inputBinding, String baseURI, Syntax syntax)
{ 
  InputStream in = null ;
  if ( fileName.equals("-") )
    in = System.in ;
  else
  {
    in = IO.openFile(fileName) ;
    if ( in == null )
      throw new UpdateException("File could not be opened: "+fileName) ;
  }
  parseExecute(usingList, dataset, in, inputBinding, baseURI, syntax) ;
}

代码示例来源:origin: apache/jena

/**
 * Decode the contents of the file and send to the {@link StreamRDF}.
 * A filename ending {@code .gz} will have a gzip decompressor added.
 * A filename of "-" is {@code System.in}.
 * @param filename The file.
 * @param dest Sink
 */
public static void fileToStream(String filename, StreamRDF dest) {
  InputStream in = IO.openFile(filename) ;
  TProtocol protocol = TRDF.protocol(in) ;
  protocolToStream(protocol, dest) ;
}

代码示例来源:origin: apache/jena

/**
 * Load a result set from file or URL into a result set (memory backed).
 * 
 * @param filenameOrURI
 * @param format
 * @return ResultSet
 */
public static ResultSet load(String filenameOrURI, ResultsFormat format) {
  if (format == null)
    format = ResultsFormat.guessSyntax(filenameOrURI);
  InputStream in = IO.openFile(filenameOrURI) ;
  return load(in, format) ;
}

代码示例来源:origin: org.apache.jena/jena-csv

protected static PropertyTable fillPropertyTable(PropertyTable table, String csvFilePath ){
  InputStream input = IO.openFile(csvFilePath) ;
  CSVParser iterator = CSVParser.create(input) ;
  return fillPropertyTable(table, iterator, csvFilePath);
}

代码示例来源:origin: apache/jena

/** Parse update operations into a GraphStore by reading it from a file */
@SuppressWarnings("resource")
public static void parseExecute(UsingList usingList, DatasetGraph dataset, String fileName, Binding inputBinding, String baseURI, Syntax syntax)
{ 
  InputStream in = null ;
  if ( fileName.equals("-") )
    in = System.in ;
  else {
    in = IO.openFile(fileName) ;
    if ( in == null )
      throw new UpdateException("File could not be opened: "+fileName) ;
  }
  parseExecute(usingList, dataset, in, inputBinding, baseURI, syntax) ;
  if ( in != System.in )
    IO.close(in) ;
}

代码示例来源:origin: apache/jena

@Test public void resultSet_10() {
    try (InputStream in = IO.openFile(DIR+"/results-1.srj")) {
      ResultSet rs = ResultSetFactory.fromJSON(in) ;
      test(ResultSetFactory.copyResults(rs)) ;
    } catch (IOException ex) { IO.exception(ex) ; }
  }
}

代码示例来源:origin: apache/jena

@Test
public void load_dataset_02() {
  DatasetGraphTDB dsg = fresh() ;
  InputStream in = IO.openFile(DIR + "data-1.nq") ;
  TDBLoader.load(dsg, in, false) ;
  assertTrue(dsg.getDefaultGraph().isEmpty()) ;
  assertEquals(1, dsg.getGraph(g).size()) ;
}

代码示例来源:origin: org.apache.jena/jena-tdb

@Test
public void load_dataset_02() {
  DatasetGraphTDB dsg = fresh() ;
  InputStream in = IO.openFile(DIR + "data-1.nq") ;
  TDBLoader.load(dsg, in, false) ;
  assertTrue(dsg.getDefaultGraph().isEmpty()) ;
  assertEquals(1, dsg.getGraph(g).size()) ;
}

代码示例来源:origin: apache/jena

@Test(expected=RiotException.class)
  public void trix_bad() {
    ErrorHandler err = ErrorHandlerFactory.getDefaultErrorHandler() ;
    try {
      ErrorHandlerFactory.setDefaultErrorHandler(ErrorHandlerFactory.errorHandlerSimple()) ;
      InputStream in = IO.openFile(fInput) ;
      StreamRDF sink = StreamRDFLib.sinkNull() ;
      RDFParser.source(in).lang(Lang.TRIX).parse(sink);
    } finally {
      ErrorHandlerFactory.setDefaultErrorHandler(err) ;
    }
  }
}

代码示例来源:origin: apache/jena

@Test
public void trix_direct() {
  ReaderRIOT r = new ReaderTriX(RiotLib.dftProfile(), ErrorHandlerFactory.errorHandlerNoWarnings);
  InputStream in = IO.openFile(fInput) ;
  DatasetGraph dsg = DatasetGraphFactory.create() ;
  //StreamRDF stream = StreamRDFLib.writer(System.out) ;
  StreamRDF stream = StreamRDFLib.dataset(dsg) ;
  stream.start();
  r.read(in, null, null, stream, null) ;
  stream.finish();
  if ( fExpected != null ) {
    DatasetGraph dsg2 = RDFDataMgr.loadDatasetGraph(fExpected) ;
    boolean b = IsoMatcher.isomorphic(dsg, dsg2) ;
    if ( ! b ) {
      Assert.fail("Not isomorphic") ;
    }
  }
}

相关文章