Processors that collect the values parsed from each column in a row and store values of columns in batches.
Use implementations of this interface implementation in favor of ColumnReader when processing large inputs to avoid running out of memory.
During the execution of the process, the batchProcessed(int) method will be invoked after a given number of rows has been processed.
The user can access the lists with values parsed for all columns using the methods getColumnValuesAsList(),
getColumnValuesAsMapOfIndexes() and getColumnValuesAsMapOfNames().
After batchProcessed(int) is invoked, all values will be discarded and the next batch of column values will be accumulated.
This process will repeat until there's no more rows in the input.
AbstractBatchedColumnProcessor, AbstractBatchedObjectColumnProcessor, Processor
| Modifier and Type | Method and Description |
|---|---|
| public void | batchProcessed(int
the number of rows processed in the current batch. This corresponds to the number of elements of each list of each column. rowsInThisBatch)Callback to the user, where the lists with values parsed for all columns can be accessed using the methods |
| public int | Returns: the number of batches already processedReturns the number of batches already processed |
| public int | Returns: the number of rows per batchReturns the number of rows processed in each batch |
| batchProcessed | back to summary |
|---|---|
| public void batchProcessed(int rowsInThisBatch) Callback to the user, where the lists with values parsed for all columns can be accessed using the methods
| |
| getBatchesProcessed | back to summary |
|---|---|
| public int getBatchesProcessed() Returns the number of batches already processed
| |
| getRowsPerBatch | back to summary |
|---|---|
| public int getRowsPerBatch() Returns the number of rows processed in each batch
| |