Uses of Interface
org.openrefine.runners.local.pll.Partition

Packages that use Partition

Package	Description
org.openrefine.runners.local.pll

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

Classes in org.openrefine.runners.local.pll that implement Partition

Modifier and Type	Class	Description
protected static class	CroppedPLL.CroppedPartition
protected static class	DropPartitionsPLL.PartitionLink
protected static class	IndexedPLL.IndexedPartition
protected static class	InMemoryPLL.InMemoryPartition
protected static class	OrderedJoinPLL.JoinPartition
protected static class	RecordPLL.RecordPartition
protected static class	TextFilePLL.TextFilePartition
protected static class	UnionPLL.UnionPartition

Fields in org.openrefine.runners.local.pll declared as Partition

Modifier and Type	Field	Description
protected Partition	DropPartitionsPLL.PartitionLink.originalPartition
protected Partition	IndexedPLL.IndexedPartition.parent
protected Partition	OrderedJoinPLL.JoinPartition.parent
protected Partition	RecordPLL.RecordPartition.parent
protected Partition	UnionPLL.UnionPartition.parent

Fields in org.openrefine.runners.local.pll with type parameters of type Partition

Modifier and Type	Field	Description
protected io.vavr.collection.Array<Partition>	DropPartitionsPLL.partitions

Methods in org.openrefine.runners.local.pll that return Partition

Modifier and Type	Method	Description
Partition	CroppedPLL.CroppedPartition.getParent()
Partition	DropPartitionsPLL.PartitionLink.getParent()
Partition	IndexedPLL.IndexedPartition.getParent()
Partition	InMemoryPLL.InMemoryPartition.getParent()
Partition	OrderedJoinPLL.JoinPartition.getParent()
Partition	Partition.getParent()	Returns the partition of the parent PLL this is derived from (if any - otherwise null)
Partition	RecordPLL.RecordPartition.getParent()
Partition	TextFilePLL.TextFilePartition.getParent()
Partition	UnionPLL.UnionPartition.getParent()

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

Modifier and Type	Method	Description
io.vavr.collection.Array<? extends Partition>	CroppedPLL.getPartitions()
io.vavr.collection.Array<? extends Partition>	DropPartitionsPLL.getPartitions()
io.vavr.collection.Array<? extends Partition>	IndexedPLL.getPartitions()
io.vavr.collection.Array<? extends Partition>	InMemoryPLL.getPartitions()
io.vavr.collection.Array<? extends Partition>	MapPartitionsPLL.getPartitions()
io.vavr.collection.Array<? extends Partition>	OrderedJoinPLL.getPartitions()
io.vavr.collection.Array<? extends Partition>	PairPLL.getPartitions()
abstract io.vavr.collection.Array<? extends Partition>	PLL.getPartitions()
io.vavr.collection.Array<? extends Partition>	RecordPLL.getPartitions()
io.vavr.collection.Array<? extends Partition>	SinglePartitionPLL.getPartitions()
io.vavr.collection.Array<? extends Partition>	TextFilePLL.getPartitions()
io.vavr.collection.Array<? extends Partition>	UnionPLL.getPartitions()

Methods in org.openrefine.runners.local.pll with parameters of type Partition

Modifier and Type	Method	Description
protected CloseableIterator<T>	CroppedPLL.compute(Partition partition)
protected CloseableIterator<T>	DropPartitionsPLL.compute(Partition partition)
protected CloseableIterator<Tuple2<Long,T>>	IndexedPLL.compute(Partition partition)
CloseableIterator<T>	InMemoryPLL.compute(Partition partition)
CloseableIterator<T>	MapPartitionsPLL.compute(Partition partition)
protected CloseableIterator<Tuple2<K,Tuple2<V,W>>>	OrderedJoinPLL.compute(Partition partition)
protected CloseableIterator<Tuple2<K,V>>	PairPLL.compute(Partition partition)
protected abstract CloseableIterator<T>	PLL.compute(Partition partition)	Iterate over the elements of the given partition.
protected CloseableIterator<Tuple2<Long,Record>>	RecordPLL.compute(Partition partition)
protected CloseableIterator<T>	SinglePartitionPLL.compute(Partition partition)
protected CloseableIterator<String>	TextFilePLL.compute(Partition partition)
protected CloseableIterator<T>	UnionPLL.compute(Partition partition)
CloseableIterator<Tuple2<K,V>>	PairPLL.iterate(Partition partition)
CloseableIterator<T>	PLL.iterate(Partition partition)	Iterate over the elements of the given partition.
protected void	PLL.writeOriginalPartition(Partition partition, File directory, Optional<TaskSignalling> taskSignalling, boolean flushRegularly)

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

Modifier and Type	Method	Description
<U> io.vavr.collection.Array<U>	PLL.runOnPartitions(Function<Partition,U> partitionFunction, int maxConcurrency)	Runs a task in parallel on all partitions.
protected <U> io.vavr.collection.Array<U>	PLL.runOnPartitions(Function<Partition,U> partitionFunction, io.vavr.collection.Iterator<? extends Partition> partitions, int maxConcurrency)	Run a task in parallel on a selection of partitions.
protected <U> io.vavr.collection.Array<U>	PLL.runOnPartitions(Function<Partition,U> partitionFunction, io.vavr.collection.Iterator<? extends Partition> partitions, int maxConcurrency)	Run a task in parallel on a selection of 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.
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.
<U> io.vavr.collection.Array<U>	PLL.runOnPartitionsWithoutInterruption(Function<Partition,U> partitionFunction)	Same as PLL.runOnPartitions(Function, int) but wrapping any InterruptedException in an unchecked PLL.PLLExecutionError.
protected <U> io.vavr.collection.Array<U>	PLL.runOnPartitionsWithoutInterruption(Function<Partition,U> partitionFunction, io.vavr.collection.Iterator<? extends Partition> partitions)	Same as PLL.runOnPartitions(Function, Iterator, int) but wrapping any InterruptedException as an unchecked PLL.PLLExecutionError.
protected <U> io.vavr.collection.Array<U>	PLL.runOnPartitionsWithoutInterruption(Function<Partition,U> partitionFunction, io.vavr.collection.Iterator<? extends Partition> partitions)	Same as PLL.runOnPartitions(Function, Iterator, int) but wrapping any InterruptedException as an unchecked PLL.PLLExecutionError.

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

Constructor	Description
CroppedPartition(int index, Partition parent)
IndexedPartition(int partitionIndex, long offset, Partition parent)
JoinPartition(int index, Partition parent)
PartitionLink(int index, Partition originalPartition)
RecordPartition(int index, List<Row> additionalRows, Partition parent)
UnionPartition(int index, int parentIndex, Partition parent)