RowProcessor implementation to perform row processing tasks in parallel. The ConcurrentRowProcessor wraps another RowProcessor, and collects rows read from the input.
The actual row processing is performed in by wrapped RowProcessor in a separate thread.
AbstractParser, RowProcessor
| Access | Constructor and Description |
|---|---|
| public | ConcurrentRowProcessor(RowProcessor
a regular rowProcessor)RowProcessor implementation which will be executed in a separate thread.Creates a non-blocking |
| public | ConcurrentRowProcessor(RowProcessor
a regular rowProcessor, int RowProcessor implementation which will be executed in a separate thread.the limit of rows to be kept in memory before the input parsing process is blocked. limit)Creates a blocking |
| Modifier and Type | Method and Description |
|---|---|
| protected ParsingContext | copyContext(ParsingContext context)
Implements abstract com. |
| protected ParsingContext | wrapContext(ParsingContext context)
Implements abstract com. |
| ConcurrentRowProcessor | back to summary |
|---|---|
| public ConcurrentRowProcessor(RowProcessor rowProcessor) Creates a non-blocking
| |
| ConcurrentRowProcessor | back to summary |
|---|---|
| public ConcurrentRowProcessor(RowProcessor rowProcessor, int limit) Creates a blocking
| |
| copyContext | back to summary |
|---|---|
| protected ParsingContext copyContext(ParsingContext context) Implements abstract com.
| |
| wrapContext | back to summary |
|---|---|
| protected ParsingContext wrapContext(ParsingContext context) Implements abstract com.
| |