Uses of Class
org.openrefine.model.changes.IndexedData

Packages that use IndexedData

Package	Description
org.openrefine.model
org.openrefine.model.changes
org.openrefine.operations.cell
org.openrefine.operations.column
org.openrefine.operations.recon
org.openrefine.runners.local	Supplies a Runner which is designed for execution on a single machine, with parallelism.
org.openrefine.runners.local.logging
org.openrefine.runners.testing
org.openrefine.wikibase.operations

Uses of IndexedData in org.openrefine.model

Method parameters in org.openrefine.model with type arguments of type IndexedData

Modifier and Type	Method	Description
default <T> ChangeData<T>	Runner.changeDataFromIterable(CloseableIterable<IndexedData<T>> iterable, long itemCount)	Creates a ChangeData from an iterable.
<T> ChangeData<T>	Runner.changeDataFromList(List<IndexedData<T>> changeData)	Creates a ChangeData from an in-memory list of indexed data.

Uses of IndexedData in org.openrefine.model.changes

Methods in org.openrefine.model.changes that return IndexedData

Modifier and Type	Method	Description
IndexedData<T>	ChangeData.get(long rowId)	Returns the change data at a given row.
static <T> IndexedData<T>	IndexedData.read(String line, ChangeDataSerializer<T> serializer)

Methods in org.openrefine.model.changes that return types with arguments of type IndexedData

Modifier and Type	Method	Description
static <T> CloseableIterator<IndexedData<T>>	IndexedData.completeIterator(CloseableIterator<IndexedData<T>> originalIterator)	Completes an iterator over a set of indexed data, by appending an infinite stream of pending indexed data objects after the original stream ends.

Methods in org.openrefine.model.changes with parameters of type IndexedData

Modifier and Type	Method	Description
List<Row>	RecordChangeDataJoiner.call(Record record, IndexedData<T> indexedData)	Given a record and the pre-computed change data for this record, return the new rows in the record after the change.
List<Row>	RowChangeDataFlatJoiner.call(Row row, IndexedData<T> indexedData)	Given a row, its id and the pre-computed change data for this row, return the new row after the change.
Row	RowChangeDataJoiner.call(Row row, IndexedData<T> indexedData)	Given a row, its id and the pre-computed change data for this row, return the new row after the change.
List<Row>	RowInRecordChangeDataJoiner.call(Record record, IndexedData<List<Cell>> indexedData)

Method parameters in org.openrefine.model.changes with type arguments of type IndexedData

Modifier and Type	Method	Description
static <T> CloseableIterator<IndexedData<T>>	IndexedData.completeIterator(CloseableIterator<IndexedData<T>> originalIterator)	Completes an iterator over a set of indexed data, by appending an infinite stream of pending indexed data objects after the original stream ends.

Uses of IndexedData in org.openrefine.operations.cell

Methods in org.openrefine.operations.cell with parameters of type IndexedData

Modifier and Type	Method	Description
Row	TextTransformOperation.Joiner.call(Row row, IndexedData<Cell> indexedData)

Uses of IndexedData in org.openrefine.operations.column

Methods in org.openrefine.operations.column with parameters of type IndexedData

Modifier and Type	Method	Description
Row	ColumnAdditionOperation.Joiner.call(Row row, IndexedData<Cell> indexedData)

Uses of IndexedData in org.openrefine.operations.recon

Methods in org.openrefine.operations.recon with parameters of type IndexedData

Modifier and Type	Method	Description
List<Row>	ExtendDataOperation.DataExtensionJoiner.call(Record record, IndexedData<ReconciledDataExtensionJob.RecordDataExtension> indexedData)
Row	ReconOperation.Joiner.call(Row row, IndexedData<Cell> indexedData)

Uses of IndexedData in org.openrefine.runners.local

Methods in org.openrefine.runners.local that return IndexedData

Modifier and Type	Method	Description
IndexedData<T>	LocalChangeData.get(long rowId)

Methods in org.openrefine.runners.local that return types with arguments of type IndexedData

Modifier and Type	Method	Description
protected static <T> CloseableIterator<Tuple2<Long,IndexedData<T>>>	LocalGrid.applyRecordChangeDataMapper(RecordChangeDataProducer<T> recordMapper, List<Tuple2<Long,Record>> recordBatch)
protected static <T> CloseableIterator<Tuple2<Long,IndexedData<T>>>	LocalGrid.applyRecordChangeDataMapperWithIncompleteData(RecordChangeDataProducer<T> recordMapper, List<Tuple2<Long,Tuple2<Record,IndexedData<T>>>> recordBatch)
protected static <T> CloseableIterator<Tuple2<Long,IndexedData<T>>>	LocalGrid.applyRowChangeDataMapper(RowChangeDataProducer<T> rowMapper, List<IndexedRow> rowBatch)
protected static <T> CloseableIterator<Tuple2<Long,IndexedData<T>>>	LocalGrid.applyRowChangeDataMapperWithIncompleteData(RowChangeDataProducer<T> rowMapper, List<Tuple2<Long,Tuple2<IndexedRow,IndexedData<T>>>> rowBatch)
protected static <T> CloseableIterator<Tuple2<Long,IndexedData<T>>>	LocalRunner.fillWithIncompleteIndexedData(CloseableIterator<Tuple2<Long,IndexedData<T>>> originalIterator, long initialIndex, long upperBound)	Utility function used to pad a stream of elements read from an incomplete change data with "virtual", pending IndexedData elements to represent those which may be computed later.
PairPLL<Long,IndexedData<T>>	LocalChangeData.getPLL()
CloseableIterator<IndexedData<T>>	LocalChangeData.iterator()

Method parameters in org.openrefine.runners.local with type arguments of type IndexedData

Modifier and Type	Method	Description
protected static <T> CloseableIterator<Tuple2<Long,IndexedData<T>>>	LocalGrid.applyRecordChangeDataMapperWithIncompleteData(RecordChangeDataProducer<T> recordMapper, List<Tuple2<Long,Tuple2<Record,IndexedData<T>>>> recordBatch)
protected static <T> CloseableIterator<Tuple2<Long,IndexedData<T>>>	LocalGrid.applyRowChangeDataMapperWithIncompleteData(RowChangeDataProducer<T> rowMapper, List<Tuple2<Long,Tuple2<IndexedRow,IndexedData<T>>>> rowBatch)
<T> ChangeData<T>	LocalRunner.changeDataFromIterable(CloseableIterable<IndexedData<T>> iterable, long itemCount)
protected <T> ChangeData<T>	LocalRunner.changeDataFromIterable(CloseableIterable<IndexedData<T>> iterable, long itemCount, boolean isComplete)
<T> ChangeData<T>	LocalRunner.changeDataFromList(List<IndexedData<T>> changeData)
protected static <T> CloseableIterator<Tuple2<Long,IndexedData<T>>>	LocalRunner.fillWithIncompleteIndexedData(CloseableIterator<Tuple2<Long,IndexedData<T>>> originalIterator, long initialIndex, long upperBound)	Utility function used to pad a stream of elements read from an incomplete change data with "virtual", pending IndexedData elements to represent those which may be computed later.

Constructor parameters in org.openrefine.runners.local with type arguments of type IndexedData

Constructor	Description
LocalChangeData(LocalRunner runner, PairPLL<Long,IndexedData<T>> grid, io.vavr.collection.Array<Long> parentPartitionSizes, Callable<Boolean> complete, int maxConcurrency)	Constructs a change data.

Uses of IndexedData in org.openrefine.runners.local.logging

Methods in org.openrefine.runners.local.logging that return IndexedData

Modifier and Type	Method	Description
IndexedData<T>	LoggedChangeData.get(long rowId)

Methods in org.openrefine.runners.local.logging that return types with arguments of type IndexedData

Modifier and Type	Method	Description
CloseableIterator<IndexedData<T>>	LoggedChangeData.iterator()

Method parameters in org.openrefine.runners.local.logging with type arguments of type IndexedData

Modifier and Type	Method	Description
<T> ChangeData<T>	LoggedRunner.changeDataFromIterable(CloseableIterable<IndexedData<T>> iterable, long itemCount)
<T> ChangeData<T>	LoggedRunner.changeDataFromList(List<IndexedData<T>> changeData)

Uses of IndexedData in org.openrefine.runners.testing

Fields in org.openrefine.runners.testing with type parameters of type IndexedData

Modifier and Type	Field	Description
protected Map<Long,IndexedData<T>>	TestingChangeData.data

Methods in org.openrefine.runners.testing that return IndexedData

Modifier and Type	Method	Description
IndexedData<T>	TestingChangeData.get(long rowId)

Methods in org.openrefine.runners.testing that return types with arguments of type IndexedData

Modifier and Type	Method	Description
CloseableIterator<IndexedData<T>>	TestingChangeData.iterator()

Methods in org.openrefine.runners.testing with parameters of type IndexedData

Modifier and Type	Method	Description
protected <T extends Serializable> ChangeData<T>	RunnerTestBase.createChangeData(IndexedData<T>... data)

Method parameters in org.openrefine.runners.testing with type arguments of type IndexedData

Modifier and Type	Method	Description
<T> ChangeData<T>	TestingRunner.changeDataFromList(List<IndexedData<T>> changeData)

Constructor parameters in org.openrefine.runners.testing with type arguments of type IndexedData

Constructor	Description
TestingChangeData(Map<Long,IndexedData<T>> data, boolean isComplete)

Uses of IndexedData in org.openrefine.wikibase.operations

Methods in org.openrefine.wikibase.operations with parameters of type IndexedData

Modifier and Type	Method	Description
Row	PerformWikibaseEditsOperation.NewReconRowJoiner.call(Row row, IndexedData<PerformWikibaseEditsOperation.RowEditingResults> indexedData)