Package org.openrefine.operations.recon

Class ExtendDataOperation.DataExtensionProducer

java.lang.Object

org.openrefine.operations.recon.ExtendDataOperation.DataExtensionProducer

All Implemented Interfaces:

Serializable, RecordChangeDataProducer<ReconciledDataExtensionJob.RecordDataExtension>

Enclosing class:

ExtendDataOperation

public static class ExtendDataOperation.DataExtensionProducer
extends Object
implements RecordChangeDataProducer<ReconciledDataExtensionJob.RecordDataExtension>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
DataExtensionProducer(ReconciledDataExtensionJob job, int cellIndex, RowFilter rowFilter)

Method Summary

Modifier and Type	Method	Description
ReconciledDataExtensionJob.RecordDataExtension	call(Record record)	Compute the change data on a given record.
List<ReconciledDataExtensionJob.RecordDataExtension>	callRecordBatch(List<Record> records)	Compute the change data on a batch of consecutive records.
int	getBatchSize()	The size of batches this producer would like to be called on.

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

getMaxConcurrency

Constructor Detail

DataExtensionProducer

public DataExtensionProducer(ReconciledDataExtensionJob job,
                             int cellIndex,
                             RowFilter rowFilter)

Method Detail

call

public ReconciledDataExtensionJob.RecordDataExtension call(Record record)

Description copied from interface: RecordChangeDataProducer

Compute the change data on a given record.

Specified by:

call in interface RecordChangeDataProducer<ReconciledDataExtensionJob.RecordDataExtension>

callRecordBatch

public List<ReconciledDataExtensionJob.RecordDataExtension> callRecordBatch(List<Record> records)

Description copied from interface: RecordChangeDataProducer

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

Specified by:

callRecordBatch in interface RecordChangeDataProducer<ReconciledDataExtensionJob.RecordDataExtension>

Parameters:

records - the list of records to fetch change data on

Returns:

a list of the same size

getBatchSize

public int getBatchSize()

Description copied from interface: RecordChangeDataProducer

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<ReconciledDataExtensionJob.RecordDataExtension>