Uses of Interface org.openrefine.process.ProgressingFuture (OpenRefine 4.0-SNAPSHOT API)

Packages that use ProgressingFuture
Package	Description
org.openrefine.model
org.openrefine.model.changes
org.openrefine.process
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.local.pll
org.openrefine.runners.local.pll.util
org.openrefine.runners.testing

Uses of ProgressingFuture in org.openrefine.model

Methods in org.openrefine.model that return ProgressingFuture
Modifier and Type	Method	Description
`ProgressingFuture<Boolean>`	Grid.`cacheAsync()`	Attempt to cache this grid in memory, in an async way.
`ProgressingFuture<Void>`	Grid.`saveToFileAsync(File file)`	Saves the grid to a specified directory, in an asynchronous fashion.

Uses of ProgressingFuture in org.openrefine.model.changes

Methods in org.openrefine.model.changes that return ProgressingFuture
Modifier and Type	Method	Description
`protected ProgressingFuture<Void>`	FileChangeDataStore.ChangeDataStoringProcess.`getFuture()`
`ProgressingFuture<Void>`	ChangeData.`saveToFileAsync(File file, ChangeDataSerializer<T> serializer)`	Saves the change data to a specified directory, following OpenRefine's format for change data, in an asynchronous way.
`<T> ProgressingFuture<Void>`	ChangeDataStore.`storeAsync(ChangeData<T> data, ChangeDataId changeDataId, ChangeDataSerializer<T> serializer)`	Asynchronously stores a `ChangeData`, 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)`

Uses of ProgressingFuture in org.openrefine.process

Classes in org.openrefine.process that implement ProgressingFuture
Modifier and Type	Class	Description
`class`	`CompletedFuture<T>`	An implementation of `ProgressingFuture` which is already supplied with its final value.
`class`	`FailingFuture<T>`

Fields in org.openrefine.process declared as ProgressingFuture
Modifier and Type	Field	Description
`protected ProgressingFuture<Void>`	Process.`_future`

Methods in org.openrefine.process that return ProgressingFuture
Modifier and Type	Method	Description
`static <T> ProgressingFuture<T>`	ProgressingFutures.`exception(Exception e)`	A precomputed future in an error state, defined by the supplied exception.
`static <T> ProgressingFuture<T>`	ProgressingFutures.`fromListenableFuture(com.google.common.util.concurrent.ListenableFuture<T> future, Executor executor)`	Wraps a listenable future into a progressing future which does not support reporting progress or pausing.
`protected abstract ProgressingFuture<Void>`	Process.`getFuture()`
`static <T> ProgressingFuture<T>`	ProgressingFutures.`immediate(T value)`	A future whose result is already computed.
`static <T,U> ProgressingFuture<U>`	ProgressingFutures.`transform(ProgressingFuture<T> future, com.google.common.base.Function<T,U> function, com.google.common.util.concurrent.ListeningExecutorService executor)`	Chaining a future with a transformation.

Methods in org.openrefine.process with parameters of type ProgressingFuture
Modifier and Type	Method	Description
`static <T,U> ProgressingFuture<U>`	ProgressingFutures.`transform(ProgressingFuture<T> future, com.google.common.base.Function<T,U> function, com.google.common.util.concurrent.ListeningExecutorService executor)`	Chaining a future with a transformation.

Uses of ProgressingFuture in org.openrefine.runners.local

Methods in org.openrefine.runners.local that return ProgressingFuture
Modifier and Type	Method	Description
`ProgressingFuture<Boolean>`	LocalGrid.`cacheAsync()`
`ProgressingFuture<Void>`	LocalChangeData.`saveToFileAsync(File file, ChangeDataSerializer<T> serializer)`
`ProgressingFuture<Void>`	LocalGrid.`saveToFileAsync(File file)`

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

Methods in org.openrefine.runners.local.logging that return ProgressingFuture
Modifier and Type	Method	Description
`ProgressingFuture<Boolean>`	LoggedGrid.`cacheAsync()`
`ProgressingFuture<Void>`	LoggedChangeData.`saveToFileAsync(File file, ChangeDataSerializer<T> serializer)`
`ProgressingFuture<Void>`	LoggedGrid.`saveToFileAsync(File file)`

Uses of ProgressingFuture in org.openrefine.runners.local.pll

Methods in org.openrefine.runners.local.pll that return ProgressingFuture
Modifier and Type	Method	Description
`ProgressingFuture<Void>`	InMemoryPLL.`cacheAsync()`
`ProgressingFuture<Void>`	PairPLL.`cacheAsync()`	Prevent double caching from this PairPLL wrapper and the underlying PLL by defering the caching to the child.
`ProgressingFuture<Void>`	PLL.`cacheAsync()`	Loads the contents of all partitions in memory.
`protected ProgressingFuture<io.vavr.collection.Array<io.vavr.collection.Array<T>>>`	PLL.`collectPartitionsAsync()`	Retrieves the contents of all partitions.
`<U> ProgressingFuture<io.vavr.collection.Array<U>>`	PLL.`runOnPartitionsAsync(BiFunction<Partition,TaskSignalling,U> partitionFunction, int maxConcurrency)`	Runs a task in parallel on all partitions, asynchronously.
`protected <U> ProgressingFuture<io.vavr.collection.Array<U>>`	PLL.`runOnPartitionsAsync(BiFunction<Partition,TaskSignalling,U> partitionFunction, io.vavr.collection.Iterator<? extends Partition> partitions, int maxConcurrency)`	Run a task in parallel on a selection of partitions, asynchronously.
`ProgressingFuture<Void>`	PLL.`saveAsTextFileAsync(String path, int maxConcurrency, boolean repartition, boolean flushRegularly)`	Write the PLL to a directory, writing one file per partition, in an asynchronous way.

Uses of ProgressingFuture in org.openrefine.runners.local.pll.util

Classes in org.openrefine.runners.local.pll.util that implement ProgressingFuture
Modifier and Type	Class	Description
`class`	`ProgressingFutureWrapper<T>`	A future which supports pausing and progress reporting, assuming the underlying future was built on a task that relies on the supplied `TaskSignalling` object to periodically check for pause and report progress.

Uses of ProgressingFuture in org.openrefine.runners.testing

Methods in org.openrefine.runners.testing that return ProgressingFuture
Modifier and Type	Method	Description
`ProgressingFuture<Boolean>`	TestingGrid.`cacheAsync()`
`ProgressingFuture<Void>`	TestingChangeData.`saveToFileAsync(File file, ChangeDataSerializer<T> serializer)`
`ProgressingFuture<Void>`	TestingGrid.`saveToFileAsync(File file)`