Package org.openrefine.operations.recon

Class ReconOperation.ReconChangeDataProducer

java.lang.Object

org.openrefine.model.changes.RowInRecordChangeDataProducer<Cell>

org.openrefine.operations.recon.ReconOperation.ReconChangeDataProducer

All Implemented Interfaces:

Serializable, RecordChangeDataProducer<List<Cell>>, RowChangeDataProducer<Cell>

Enclosing class:

ReconOperation

protected static class ReconOperation.ReconChangeDataProducer
extends RowInRecordChangeDataProducer<Cell>

See Also:

Serialized Form

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	ReconChangeDataProducer(String columnName, int columnIndex, ReconConfig reconConfig, long historyEntryId, ColumnModel columnModel)

Method Summary

Modifier and Type	Method	Description
Cell	call(Record record, long rowId, Row row)	Maps a row, in the context of a record.
List<Cell>	callRowBatch(List<IndexedRow> rows)	Compute the change data on a batch of consecutive rows.
int	getBatchSize()	The size of batches this producer would like to be called on.

Methods inherited from class org.openrefine.model.changes.RowInRecordChangeDataProducer

call, call, getMaxConcurrency

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.openrefine.model.changes.RecordChangeDataProducer

callRecordBatch

Constructor Detail

ReconChangeDataProducer

protected ReconChangeDataProducer(String columnName,
                                  int columnIndex,
                                  ReconConfig reconConfig,
                                  long historyEntryId,
                                  ColumnModel columnModel)

Method Detail

call

public Cell call(Record record,
                 long rowId,
                 Row row)

Description copied from class: RowInRecordChangeDataProducer

Maps a row, in the context of a record.

Specified by:

call in class RowInRecordChangeDataProducer<Cell>

Parameters:

record - the record enclosing the row to map

rowId - the global index of the row in the entire grid

row - the row itself

callRowBatch

public List<Cell> callRowBatch(List<IndexedRow> rows)

Description copied from interface: RowChangeDataProducer

Compute the change data on a batch of consecutive rows. This defaults to individual calls if the method is not overridden.

Parameters:

rows - the list of rows to fetch change data on

Returns:

a list of the same size

getBatchSize

public int getBatchSize()

Description copied from class: RowInRecordChangeDataProducer

The size of batches this producer would like to be called on. Smaller batches can be submitted (for instance at the end of a partition). Defaults to 1.

Specified by:

getBatchSize in interface RecordChangeDataProducer<List<Cell>>

Specified by:

getBatchSize in interface RowChangeDataProducer<Cell>

Overrides:

getBatchSize in class RowInRecordChangeDataProducer<Cell>