public final class RDFStreamProcessor extends Object
handlers
or provides the results as an iteration(List)
.Modifier and Type | Class and Description |
---|---|
static class |
RDFStreamProcessor.ProcessingCancelledException |
Modifier and Type | Method and Description |
---|---|
RDFStreamProcessor |
add(Iterable<RDFStream> theStreams) |
RDFStreamProcessor |
add(RDFStream theStream)
Adds a new stream to process.
|
void |
cancel(String theCause) |
static RDFStreamProcessor |
create() |
static RDFStreamProcessor |
create(CancellationPoint theCancellationPoint) |
RDFStreamProcessor |
executor(ExecutorService theExecutor)
Specifies the executor that will be used for processing.
|
Throwable |
getException(RDFStream theStream) |
RDFStreamProcessor |
handler(RDFNamespaceHandler theNamespaceHandler)
Specifies the namespace handler that will be used by this process.
|
RDFStreamProcessor |
handler(RDFStatementHandler.Factory theHandler)
Specifies the factory that will be used to create handlers.
|
static StatementIterator |
iteration(List<RDFStream> theStreams) |
static void |
main(String[] args) |
RDFStreamProcessor |
monitorOutput(OutputStream theStream)
Sets the output progress if progress should be reported or
null if progress should not be reported. |
void |
pause()
Pauses processing.
|
void |
process()
Waits for the processing of streams to finish.
|
Map<RDFStream,Exception> |
processSilently()
Waits for the processing of streams to finish and returns a mapping from the streams to exceptions.
|
void |
resume()
Resumes processing as soon as possible.
|
public static RDFStreamProcessor create()
public static StatementIterator iteration(List<RDFStream> theStreams)
public static RDFStreamProcessor create(CancellationPoint theCancellationPoint)
public RDFStreamProcessor handler(RDFStatementHandler.Factory theHandler)
public RDFStreamProcessor handler(RDFNamespaceHandler theNamespaceHandler)
public RDFStreamProcessor executor(ExecutorService theExecutor)
public RDFStreamProcessor monitorOutput(OutputStream theStream)
null
if progress should not be reported.
Passing null
value is preferred compared to passing an output stream that ignores its output so that
we will avoid keeping track of progress completely.public RDFStreamProcessor add(RDFStream theStream)
public RDFStreamProcessor add(Iterable<RDFStream> theStreams)
public void process() throws InvalidRDF, IOException
InvalidRDF
IOException
public Map<RDFStream,Exception> processSilently()
public void pause()
resume()
is called.public void resume()
public void cancel(String theCause)
public static void main(String[] args)
Copyright © 2010-2016 Stardog Union. All Rights Reserved.