Package org.openrefine.operations.column

Class ColumnAdditionByFetchingURLsOperation.URLFetchingChangeProducer

java.lang.Object

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

org.openrefine.operations.column.ColumnAdditionByFetchingURLsOperation.URLFetchingChangeProducer

All Implemented Interfaces:

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

Enclosing class:

ColumnAdditionByFetchingURLsOperation

protected static class ColumnAdditionByFetchingURLsOperation.URLFetchingChangeProducer
extends RowInRecordChangeDataProducer<Cell>

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected boolean	_cacheResponses
protected int	_delay
protected RowInRecordChangeDataProducer<Cell>	_evaluatingChangeDataProducer
protected List<ColumnAdditionByFetchingURLsOperation.HttpHeader>	_httpHeaders
protected OnError	_onError

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	URLFetchingChangeProducer(OnError onError, List<ColumnAdditionByFetchingURLsOperation.HttpHeader> httpHeaders, boolean cacheResponses, int delay, RowInRecordChangeDataProducer<Cell> evaluatingChangeDataProducer)

Method Summary

Modifier and Type	Method	Description
Cell	call(Record record, long rowId, Row row)	Maps a row, in the context of a record.
protected com.google.common.cache.LoadingCache<String,Serializable>	getCache()
protected HttpClient	getHttpClient()
protected org.apache.hc.core5.http.Header[]	getHttpHeaders()

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

call, call, getBatchSize, 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

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

callRowBatch

Field Detail

_onError

protected final OnError _onError

_httpHeaders

protected final List<ColumnAdditionByFetchingURLsOperation.HttpHeader> _httpHeaders

_cacheResponses

protected final boolean _cacheResponses

_delay

protected final int _delay

_evaluatingChangeDataProducer

protected final RowInRecordChangeDataProducer<Cell> _evaluatingChangeDataProducer

Constructor Detail

URLFetchingChangeProducer

protected URLFetchingChangeProducer(OnError onError,
                                    List<ColumnAdditionByFetchingURLsOperation.HttpHeader> httpHeaders,
                                    boolean cacheResponses,
                                    int delay,
                                    RowInRecordChangeDataProducer<Cell> evaluatingChangeDataProducer)

Method Detail

getHttpClient

protected HttpClient getHttpClient()

getHttpHeaders

protected org.apache.hc.core5.http.Header[] getHttpHeaders()

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

getCache

protected com.google.common.cache.LoadingCache<String,Serializable> getCache()