Uses of Class
org.openrefine.runners.local.pll.util.TaskSignalling

Packages that use TaskSignalling

Package	Description
org.openrefine.runners.local	Supplies a Runner which is designed for execution on a single machine, with parallelism.
org.openrefine.runners.local.pll
org.openrefine.runners.local.pll.util

Uses of TaskSignalling in org.openrefine.runners.local

Methods in org.openrefine.runners.local with parameters of type TaskSignalling

Modifier and Type	Method	Description
protected static <T> CloseableIterator<Tuple2<Long,T>>	LocalChangeData.wrapStreamWithProgressReporting(long startIdx, CloseableIterator<Tuple2<Long,T>> iterator, TaskSignalling taskSignalling)

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

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

Modifier and Type	Method	Description
<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.
protected void	PLL.writeOriginalPartition(Partition partition, File directory, Optional<TaskSignalling> taskSignalling, boolean flushRegularly)
protected void	PLL.writePartition(int partitionIndex, CloseableIterator<T> iterator, File partFile, Optional<TaskSignalling> taskSignalling, boolean flushRegularly)
protected void	PLL.writePlannedPartition(org.openrefine.runners.local.pll.PLL.PlannedPartition partition, File directory, io.vavr.collection.Iterator<T> choppedIterator, Optional<TaskSignalling> taskSignalling, boolean flushRegularly)

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

Constructors in org.openrefine.runners.local.pll.util with parameters of type TaskSignalling

Constructor	Description
ProgressingFutureWrapper(com.google.common.util.concurrent.ListenableFuture<T> future, TaskSignalling taskSignalling, boolean supportsProgress)