Class ConcurrentRowProcessor

All Implemented Interfaces:
Processor<ParsingContext>, RowProcessor

public class ConcurrentRowProcessor extends AbstractConcurrentProcessor<ParsingContext> implements RowProcessor
A 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.
See Also:
  • Constructor Details

    • ConcurrentRowProcessor

      public ConcurrentRowProcessor(RowProcessor rowProcessor)
      Creates a non-blocking ConcurrentRowProcessor, to perform processing of rows parsed from the input in a separate thread.
      Parameters:
      rowProcessor - a regular RowProcessor implementation which will be executed in a separate thread.
    • ConcurrentRowProcessor

      public ConcurrentRowProcessor(RowProcessor rowProcessor, int limit)
      Creates a blocking ConcurrentRowProcessor, to perform processing of rows parsed from the input in a separate thread.
      Parameters:
      rowProcessor - a regular RowProcessor implementation which will be executed in a separate thread.
      limit - the limit of rows to be kept in memory before the input parsing process is blocked.
  • Method Details