Uses of Interface
org.openrefine.model.changes.ChangeData
-
Packages that use ChangeData Package Description org.openrefine.model org.openrefine.model.changes org.openrefine.runners.local Supplies aRunner
which is designed for execution on a single machine, with parallelism.org.openrefine.runners.local.logging org.openrefine.runners.testing -
-
Uses of ChangeData in org.openrefine.model
Methods in org.openrefine.model that return ChangeData Modifier and Type Method Description default <T> ChangeData<T>
Runner. changeDataFromIterable(CloseableIterable<IndexedData<T>> iterable, long itemCount)
Creates aChangeData
from an iterable.<T> ChangeData<T>
Runner. changeDataFromList(List<IndexedData<T>> changeData)
Creates aChangeData
from an in-memory list of indexed data.<T> ChangeData<T>
Runner. emptyChangeData()
Creates an empty change data object of a given type, marked as incomplete.<T> ChangeData<T>
Runner. loadChangeData(File path, ChangeDataSerializer<T> serializer)
Loads aChangeData
serialized at a given location.<T> ChangeData<T>
Grid. mapRecords(RecordFilter filter, RecordChangeDataProducer<T> recordMapper, Optional<ChangeData<T>> incompleteChangeData)
Extract change data by applying a function to each filtered record.<T> ChangeData<T>
Grid. mapRows(RowFilter filter, RowChangeDataProducer<T> rowMapper, Optional<ChangeData<T>> incompleteChangeData)
Extract change data by applying a function to each filtered row.Methods in org.openrefine.model with parameters of type ChangeData Modifier and Type Method Description <T> Grid
Grid. join(ChangeData<T> changeData, RecordChangeDataJoiner<T> recordJoiner, ColumnModel newColumnModel)
Joins pre-computed change data with the current grid data, record by record.<T> Grid
Grid. join(ChangeData<T> changeData, RowChangeDataFlatJoiner<T> rowJoiner, ColumnModel newColumnModel)
Joins pre-computed change data with the current grid data, with a joiner function that can return multiple rows for a given original row.<T> Grid
Grid. join(ChangeData<T> changeData, RowChangeDataJoiner<T> rowJoiner, ColumnModel newColumnModel)
Joins pre-computed change data with the current grid data, row by row.Method parameters in org.openrefine.model with type arguments of type ChangeData Modifier and Type Method Description <T> ChangeData<T>
Grid. mapRecords(RecordFilter filter, RecordChangeDataProducer<T> recordMapper, Optional<ChangeData<T>> incompleteChangeData)
Extract change data by applying a function to each filtered record.<T> ChangeData<T>
Grid. mapRows(RowFilter filter, RowChangeDataProducer<T> rowMapper, Optional<ChangeData<T>> incompleteChangeData)
Extract change data by applying a function to each filtered row. -
Uses of ChangeData in org.openrefine.model.changes
Methods in org.openrefine.model.changes that return ChangeData Modifier and Type Method Description <T> ChangeData<T>
ChangeContext. getChangeData(String dataId, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess)
Retrieves aChangeData
from the underlyingChangeDataStore
.<T> ChangeData<T>
ChangeContextImpl. getChangeData(String dataId, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess)
<T> ChangeData<T>
ChangeDataStore. retrieve(ChangeDataId changeDataId, ChangeDataSerializer<T> serializer)
Loads back aChangeData
that has been persisted before.<T> ChangeData<T>
FileChangeDataStore. retrieve(ChangeDataId changeDataId, ChangeDataSerializer<T> serializer)
<T> ChangeData<T>
LazyChangeDataStore. retrieve(ChangeDataId changeDataId, ChangeDataSerializer<T> serializer)
<T> ChangeData<T>
ChangeDataStore. retrieveOrCompute(ChangeDataId changeDataId, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess, String description)
Retrieves a change data if it exists already, and if it does not (or is incomplete), start a process to finish computing it.<T> ChangeData<T>
FileChangeDataStore. retrieveOrCompute(ChangeDataId changeDataId, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess, String description)
<T> ChangeData<T>
LazyChangeDataStore. retrieveOrCompute(ChangeDataId changeDataId, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess, String description)
Methods in org.openrefine.model.changes with parameters of type ChangeData Modifier and Type Method Description <T> void
ChangeDataStore. store(ChangeData<T> data, ChangeDataId changeDataId, ChangeDataSerializer<T> serializer, Optional<ProgressReporter> progressReporter)
Stores aChangeData
, which might imply explicitly computing all its values (if the store persists its changes).<T> void
FileChangeDataStore. store(ChangeData<T> data, ChangeDataId changeDataId, ChangeDataSerializer<T> serializer, Optional<ProgressReporter> progressReporter)
<T> void
LazyChangeDataStore. store(ChangeData<T> data, ChangeDataId changeDataId, ChangeDataSerializer<T> serializer, Optional<ProgressReporter> progressReporter)
<T> ProgressingFuture<Void>
ChangeDataStore. storeAsync(ChangeData<T> data, ChangeDataId changeDataId, ChangeDataSerializer<T> serializer)
Asynchronously stores aChangeData
, which might imply explicitly computing all its values (if the store persists its changes).<T> ProgressingFuture<Void>
FileChangeDataStore. storeAsync(ChangeData<T> data, ChangeDataId changeDataId, ChangeDataSerializer<T> serializer)
<T> ProgressingFuture<Void>
LazyChangeDataStore. storeAsync(ChangeData<T> data, ChangeDataId changeDataId, ChangeDataSerializer<T> serializer)
Method parameters in org.openrefine.model.changes with type arguments of type ChangeData Modifier and Type Method Description <T> ChangeData<T>
ChangeContext. getChangeData(String dataId, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess)
Retrieves aChangeData
from the underlyingChangeDataStore
.<T> ChangeData<T>
ChangeContext. getChangeData(String dataId, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess)
Retrieves aChangeData
from the underlyingChangeDataStore
.<T> ChangeData<T>
ChangeContextImpl. getChangeData(String dataId, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess)
<T> ChangeData<T>
ChangeContextImpl. getChangeData(String dataId, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess)
<T> ChangeData<T>
ChangeDataStore. retrieveOrCompute(ChangeDataId changeDataId, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess, String description)
Retrieves a change data if it exists already, and if it does not (or is incomplete), start a process to finish computing it.<T> ChangeData<T>
ChangeDataStore. retrieveOrCompute(ChangeDataId changeDataId, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess, String description)
Retrieves a change data if it exists already, and if it does not (or is incomplete), start a process to finish computing it.<T> ChangeData<T>
FileChangeDataStore. retrieveOrCompute(ChangeDataId changeDataId, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess, String description)
<T> ChangeData<T>
FileChangeDataStore. retrieveOrCompute(ChangeDataId changeDataId, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess, String description)
<T> ChangeData<T>
LazyChangeDataStore. retrieveOrCompute(ChangeDataId changeDataId, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess, String description)
<T> ChangeData<T>
LazyChangeDataStore. retrieveOrCompute(ChangeDataId changeDataId, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess, String description)
Constructor parameters in org.openrefine.model.changes with type arguments of type ChangeData Constructor Description ChangeDataStoringProcess(String description, Optional<ChangeData<T>> storedChangeData, ChangeDataId changeDataId, ChangeDataStore changeDataStore, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess, File temporaryDirToDelete)
ChangeDataStoringProcess(String description, Optional<ChangeData<T>> storedChangeData, ChangeDataId changeDataId, ChangeDataStore changeDataStore, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess, File temporaryDirToDelete)
ChangeDataStoringProcess(String description, Optional<ChangeData<T>> storedChangeData, ChangeDataId changeDataId, ChangeDataStore changeDataStore, ChangeDataSerializer<T> serializer, Function<Optional<ChangeData<T>>,ChangeData<T>> completionProcess, File temporaryDirToDelete)
-
Uses of ChangeData in org.openrefine.runners.local
Classes in org.openrefine.runners.local that implement ChangeData Modifier and Type Class Description class
LocalChangeData<T>
Methods in org.openrefine.runners.local that return ChangeData Modifier and Type Method Description <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)
<T> ChangeData<T>
LocalRunner. emptyChangeData()
<T> ChangeData<T>
LocalRunner. loadChangeData(File path, ChangeDataSerializer<T> serializer)
<T> ChangeData<T>
LocalGrid. mapRecords(RecordFilter filter, RecordChangeDataProducer<T> recordMapper, Optional<ChangeData<T>> incompleteChangeData)
<T> ChangeData<T>
LocalGrid. mapRows(RowFilter filter, RowChangeDataProducer<T> rowMapper, Optional<ChangeData<T>> incompleteChangeData)
Methods in org.openrefine.runners.local with parameters of type ChangeData Modifier and Type Method Description <T> Grid
LocalGrid. join(ChangeData<T> changeData, RecordChangeDataJoiner<T> recordJoiner, ColumnModel newColumnModel)
<T> Grid
LocalGrid. join(ChangeData<T> changeData, RowChangeDataFlatJoiner<T> rowJoiner, ColumnModel newColumnModel)
<T> Grid
LocalGrid. join(ChangeData<T> changeData, RowChangeDataJoiner<T> rowJoiner, ColumnModel newColumnModel)
Method parameters in org.openrefine.runners.local with type arguments of type ChangeData Modifier and Type Method Description <T> ChangeData<T>
LocalGrid. mapRecords(RecordFilter filter, RecordChangeDataProducer<T> recordMapper, Optional<ChangeData<T>> incompleteChangeData)
<T> ChangeData<T>
LocalGrid. mapRows(RowFilter filter, RowChangeDataProducer<T> rowMapper, Optional<ChangeData<T>> incompleteChangeData)
-
Uses of ChangeData in org.openrefine.runners.local.logging
Classes in org.openrefine.runners.local.logging that implement ChangeData Modifier and Type Class Description class
LoggedChangeData<T>
Fields in org.openrefine.runners.local.logging declared as ChangeData Modifier and Type Field Description protected ChangeData<T>
LoggedChangeData. changeData
Methods in org.openrefine.runners.local.logging that return ChangeData 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)
<T> ChangeData<T>
LoggedRunner. emptyChangeData()
<T> ChangeData<T>
LoggedRunner. loadChangeData(File path, ChangeDataSerializer<T> serializer)
<T> ChangeData<T>
LoggedGrid. mapRecords(RecordFilter filter, RecordChangeDataProducer<T> recordMapper, Optional<ChangeData<T>> incompleteChangeData)
<T> ChangeData<T>
LoggedGrid. mapRows(RowFilter filter, RowChangeDataProducer<T> rowMapper, Optional<ChangeData<T>> incompleteChangeData)
protected <T> ChangeData<T>
LoggedGrid. wrap(ChangeData<T> change)
protected <T> ChangeData<T>
LoggedRunner. wrap(ChangeData<T> changeData)
Methods in org.openrefine.runners.local.logging with parameters of type ChangeData Modifier and Type Method Description <T> Grid
LoggedGrid. join(ChangeData<T> changeData, RecordChangeDataJoiner<T> recordJoiner, ColumnModel newColumnModel)
<T> Grid
LoggedGrid. join(ChangeData<T> changeData, RowChangeDataFlatJoiner<T> rowJoiner, ColumnModel newColumnModel)
<T> Grid
LoggedGrid. join(ChangeData<T> changeData, RowChangeDataJoiner<T> rowJoiner, ColumnModel newColumnModel)
protected <T> ChangeData<T>
LoggedGrid. wrap(ChangeData<T> change)
protected <T> ChangeData<T>
LoggedRunner. wrap(ChangeData<T> changeData)
Method parameters in org.openrefine.runners.local.logging with type arguments of type ChangeData Modifier and Type Method Description <T> ChangeData<T>
LoggedGrid. mapRecords(RecordFilter filter, RecordChangeDataProducer<T> recordMapper, Optional<ChangeData<T>> incompleteChangeData)
<T> ChangeData<T>
LoggedGrid. mapRows(RowFilter filter, RowChangeDataProducer<T> rowMapper, Optional<ChangeData<T>> incompleteChangeData)
Constructors in org.openrefine.runners.local.logging with parameters of type ChangeData Constructor Description LoggedChangeData(LoggedRunner runner, ChangeData<T> changeData)
-
Uses of ChangeData in org.openrefine.runners.testing
Classes in org.openrefine.runners.testing that implement ChangeData Modifier and Type Class Description class
TestingChangeData<T>
Fields in org.openrefine.runners.testing declared as ChangeData Modifier and Type Field Description protected ChangeData<String>
RunnerTestBase. simpleChangeData
Methods in org.openrefine.runners.testing that return ChangeData Modifier and Type Method Description <T> ChangeData<T>
TestingRunner. changeDataFromList(List<IndexedData<T>> changeData)
protected <T extends Serializable>
ChangeData<T>RunnerTestBase. createChangeData(IndexedData<T>... data)
<T> ChangeData<T>
TestingRunner. emptyChangeData()
<T> ChangeData<T>
TestingRunner. loadChangeData(File path, ChangeDataSerializer<T> serializer)
<T> ChangeData<T>
TestingGrid. mapRecords(RecordFilter filter, RecordChangeDataProducer<T> recordMapper, Optional<ChangeData<T>> incompleteChangeData)
<T> ChangeData<T>
TestingGrid. mapRows(RowFilter filter, RowChangeDataProducer<T> rowMapper, Optional<ChangeData<T>> incompleteChangeData)
Methods in org.openrefine.runners.testing with parameters of type ChangeData Modifier and Type Method Description <T> Grid
TestingGrid. join(ChangeData<T> changeData, RecordChangeDataJoiner<T> recordJoiner, ColumnModel newColumnModel)
<T> Grid
TestingGrid. join(ChangeData<T> changeData, RowChangeDataFlatJoiner<T> rowJoiner, ColumnModel newColumnModel)
<T> Grid
TestingGrid. join(ChangeData<T> changeData, RowChangeDataJoiner<T> rowJoiner, ColumnModel newColumnModel)
Method parameters in org.openrefine.runners.testing with type arguments of type ChangeData Modifier and Type Method Description <T> ChangeData<T>
TestingGrid. mapRecords(RecordFilter filter, RecordChangeDataProducer<T> recordMapper, Optional<ChangeData<T>> incompleteChangeData)
<T> ChangeData<T>
TestingGrid. mapRows(RowFilter filter, RowChangeDataProducer<T> rowMapper, Optional<ChangeData<T>> incompleteChangeData)
-