本文整理了Java中org.apache.jena.atlas.io.IO.openFile()
方法的一些代码示例,展示了IO.openFile()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。IO.openFile()
方法的具体详情如下:
包路径:org.apache.jena.atlas.io.IO
类名称: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") ;
}
}
}
内容来源于网络,如有侵权,请联系作者删除!