Package org.openrefine.wikibase.operations

Class PerformWikibaseEditsOperation.RowEditingResultsProducer

java.lang.Object

org.openrefine.wikibase.operations.PerformWikibaseEditsOperation.RowEditingResultsProducer

All Implemented Interfaces:

Serializable, RowChangeDataProducer<PerformWikibaseEditsOperation.RowEditingResults>

Enclosing class:

PerformWikibaseEditsOperation

protected static class PerformWikibaseEditsOperation.RowEditingResultsProducer
extends Object
implements RowChangeDataProducer<PerformWikibaseEditsOperation.RowEditingResults>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected int	batchSize
protected ColumnModel	columnModel
protected org.wikidata.wdtk.wikibaseapi.ApiConnection	connection
protected org.wikidata.wdtk.wikibaseapi.WikibaseDataEditor	editor
protected org.wikidata.wdtk.wikibaseapi.WikibaseDataFetcher	fetcher
protected NewEntityLibrary	library
protected int	maxEditsPerMinute
protected int	maxLag
protected WikibaseSchema	schema
protected String	summary
protected List<String>	tags

Method Summary

Modifier and Type	Method	Description
PerformWikibaseEditsOperation.RowEditingResults	call(long rowId, Row row)	Compute the change data on a given row.
List<PerformWikibaseEditsOperation.RowEditingResults>	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.
int	getMaxConcurrency()	The maximum number of concurrent calls to this change data producer.

Methods inherited from class java.lang.Object

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

Field Detail

connection

protected final org.wikidata.wdtk.wikibaseapi.ApiConnection connection

schema

protected final WikibaseSchema schema

columnModel

protected final ColumnModel columnModel

summary

protected final String summary

batchSize

protected final int batchSize

maxLag

protected final int maxLag

maxEditsPerMinute

protected final int maxEditsPerMinute

tags

protected final List<String> tags

library

protected final NewEntityLibrary library

fetcher

protected final org.wikidata.wdtk.wikibaseapi.WikibaseDataFetcher fetcher

editor

protected final org.wikidata.wdtk.wikibaseapi.WikibaseDataEditor editor

Method Detail

call

public PerformWikibaseEditsOperation.RowEditingResults call(long rowId,
                                                            Row row)

Description copied from interface: RowChangeDataProducer

Compute the change data on a given row.

Specified by:

call in interface RowChangeDataProducer<PerformWikibaseEditsOperation.RowEditingResults>

callRowBatch

public List<PerformWikibaseEditsOperation.RowEditingResults> 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.

Specified by:

callRowBatch in interface RowChangeDataProducer<PerformWikibaseEditsOperation.RowEditingResults>

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 interface: RowChangeDataProducer

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 RowChangeDataProducer<PerformWikibaseEditsOperation.RowEditingResults>

getMaxConcurrency

public int getMaxConcurrency()

Description copied from interface: RowChangeDataProducer

The maximum number of concurrent calls to this change data producer. If 0, there is no limit to the concurrency.

Specified by:

getMaxConcurrency in interface RowChangeDataProducer<PerformWikibaseEditsOperation.RowEditingResults>