Class ConcurrentRowProcessor

    • Constructor Detail

      • 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.