java.lang.Object
- com.complexible.common.rdf.rio.RDFStreamProcessor

```
public final class RDFStreamProcessor
extends java.lang.Object
```
Stream processor that handles concurrent production of statements from multiple streams and passes the statements to handlers or provides the results as an iteration(List, CancelCheck).

Since:

0.1

Author:

Michael Grove, Evren Sirin, Fernando Hernandez

Field Summary

Fields
Modifier and Type Field Description

static int DEFAULT_MAX_HANDLER_COUNT

static int DEFAULT_MAX_PARSER_COUNT

Method Summary

All Methods Static Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`RDFStreamProcessor`	`add(RDFStream theStream)`	Adds a new stream to process.
`RDFStreamProcessor`	`add(java.lang.Iterable<RDFStream> theStreams)`
`void`	`cancel(java.lang.String theCause)`
`static RDFStreamProcessor`	`create(CancelCheck check)`
`RDFStreamProcessor`	`executor(java.util.concurrent.ExecutorService theExecutor)`	Specifies the executor that will be used for processing.
`java.lang.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(java.util.List<RDFStream> theStreams, CancelCheck check)`
`static void`	`main(java.lang.String[] args)`
`RDFStreamProcessor`	`maxHandlers(int count)`
`RDFStreamProcessor`	`maxParsers(int count)`
`RDFStreamProcessor`	`monitorOutput(ProgressReporter reporter)`
`RDFStreamProcessor`	`monitorOutput(java.io.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.
`java.util.Map<RDFStream,java.lang.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.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - DEFAULT_MAX_PARSER_COUNT
```
public static final int DEFAULT_MAX_PARSER_COUNT
```
  - DEFAULT_MAX_HANDLER_COUNT
```
public static final int DEFAULT_MAX_HANDLER_COUNT
```
- Method Detail
  - create
```
public static RDFStreamProcessor create(CancelCheck check)
```
  - iteration
```
public static StatementIterator iteration(java.util.List<RDFStream> theStreams,
                                          CancelCheck check)
```
  - handler
```
public RDFStreamProcessor handler(RDFStatementHandler.Factory theHandler)
```
    Specifies the factory that will be used to create handlers. Multiple handlers may be created depending on the number of streams processed, number of available processors, etc.
  - handler
```
public RDFStreamProcessor handler(RDFNamespaceHandler theNamespaceHandler)
```
    Specifies the namespace handler that will be used by this process. A single namespace handler is used for all the streams processed.
  - executor
```
public RDFStreamProcessor executor(java.util.concurrent.ExecutorService theExecutor)
```
    Specifies the executor that will be used for processing.
  - monitorOutput
```
public RDFStreamProcessor monitorOutput(java.io.OutputStream theStream)
```
    Sets the output progress if progress should be reported or 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.
  - monitorOutput
```
public RDFStreamProcessor monitorOutput(ProgressReporter reporter)
```
  - maxParsers
```
public RDFStreamProcessor maxParsers(int count)
```
  - maxHandlers
```
public RDFStreamProcessor maxHandlers(int count)
```
  - resizeHandlers
```
public RDFStreamProcessor resizeHandlers(boolean value)
```
  - add
```
public RDFStreamProcessor add(RDFStream theStream)
```
    Adds a new stream to process. Processing might start immediately
  - add
```
public RDFStreamProcessor add(java.lang.Iterable<RDFStream> theStreams)
```
  - getException
```
public java.lang.Throwable getException(RDFStream theStream)
```
  - process
```
public void process()
             throws InvalidRDF,
                    java.io.IOException
```
    Waits for the processing of streams to finish. No more streams may be added to the processor after this function is called. An exception is thrown at the very end if there was an error processing any one of the streams.
    
    Throws:
    
    InvalidRDF
    
    java.io.IOException
  - processSilently
```
public java.util.Map<RDFStream,java.lang.Exception> processSilently()
```
    Waits for the processing of streams to finish and returns a mapping from the streams to exceptions. The map will be empty if there were no exceptions during processing. No more streams may be added to the processor after this function is called.
  - pause
```
public void pause()
```
    Pauses processing. All parsing and processing tasks will block until resume() is called.
  - resume
```
public void resume()
```
    Resumes processing as soon as possible.
  - cancel
```
public void cancel(java.lang.String theCause)
```
  - main
```
public static void main(java.lang.String[] args)
```

Modifier and Type	Field	Description
`static int`	`DEFAULT_MAX_HANDLER_COUNT`
`static int`	`DEFAULT_MAX_PARSER_COUNT`

Class RDFStreamProcessor

Field Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

DEFAULT_MAX_PARSER_COUNT

DEFAULT_MAX_HANDLER_COUNT

Method Detail

create

iteration

handler

handler

executor

monitorOutput

monitorOutput

maxParsers

maxHandlers

resizeHandlers

add

add

getException

process

processSilently

pause

resume

cancel

main