public final class RDFStreamProcessor extends Object
handlers
or provides the results as an iteration(List, CancelCheck)
.Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_MAX_HANDLER_COUNT |
static int |
DEFAULT_MAX_PARSER_COUNT |
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(CancelCheck check) |
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,
CancelCheck check) |
static void |
main(String[] args) |
RDFStreamProcessor |
maxHandlers(int count) |
RDFStreamProcessor |
maxParsers(int count) |
RDFStreamProcessor |
monitorOutput(OutputStream theStream)
Sets the output progress if progress should be reported or
null if progress should not be reported. |
RDFStreamProcessor |
monitorOutput(ProgressReporter reporter) |
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.
|
RDFStreamProcessor |
resizeHandlers(boolean value) |
void |
resume()
Resumes processing as soon as possible.
|
public static final int DEFAULT_MAX_PARSER_COUNT
public static final int DEFAULT_MAX_HANDLER_COUNT
public static RDFStreamProcessor create(CancelCheck check)
public static StatementIterator iteration(List<RDFStream> theStreams, CancelCheck check)
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 monitorOutput(ProgressReporter reporter)
public RDFStreamProcessor maxParsers(int count)
public RDFStreamProcessor maxHandlers(int count)
public RDFStreamProcessor resizeHandlers(boolean value)
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.