Uses of Class
org.openrefine.runners.local.pll.Tuple2

Packages that use Tuple2

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

Uses of Tuple2 in org.openrefine.runners.local

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

Modifier and Type	Method	Description
protected static Tuple2<Long,Row>	LocalRunner.parseIndexedRow(String source)

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

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.
protected static <T> CloseableIterator<Tuple2<Long,T>>	LocalChangeData.wrapStreamWithProgressReporting(long startIdx, CloseableIterator<Tuple2<Long,T>> iterator, TaskSignalling taskSignalling)

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

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.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)
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.
protected static <T> CloseableIterator<Tuple2<Long,T>>	LocalChangeData.wrapStreamWithProgressReporting(long startIdx, CloseableIterator<Tuple2<Long,T>> iterator, TaskSignalling taskSignalling)

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

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

Modifier and Type	Field	Description
protected PLL<Tuple2<K,V>>	PairPLL.pll

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

Modifier and Type	Method	Description
static <U,V> Tuple2<U,V>	Tuple2.of(U key, V value)

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

Modifier and Type	Method	Description
protected CloseableIterator<Tuple2<Long,T>>	IndexedPLL.compute(Partition partition)
protected CloseableIterator<Tuple2<K,Tuple2<V,W>>>	OrderedJoinPLL.compute(Partition partition)
protected CloseableIterator<Tuple2<K,Tuple2<V,W>>>	OrderedJoinPLL.compute(Partition partition)
protected CloseableIterator<Tuple2<K,V>>	PairPLL.compute(Partition partition)
protected CloseableIterator<Tuple2<Long,Record>>	RecordPLL.compute(Partition partition)
<W> PairPLL<K,Tuple2<V,W>>	PairPLL.fullJoinOrdered(PairPLL<K,W> other, Comparator<K> comparator)	Assuming both PairPLLs are ordered by key, and each key appears at most once in each dataset, returns an ordered PairPLL with the full (outer) join of both PLLs.
protected static <K,V> List<Tuple2<K,V>>	PairPLL.gatherElementsBefore(K upperBound, int limit, CloseableIterator<Tuple2<K,V>> stream, Comparator<K> comparator)	Returns the last n elements whose key is strictly less than the supplied upper bound.
io.vavr.collection.Array<Tuple2<K,V>>	PairPLL.getByKeys(Set<K> keys)	Returns the list of elements whose keys match one of the supplied keys.
List<Tuple2<K,V>>	PairPLL.getRangeAfter(K from, int limit, Comparator<K> comparator)	Returns the list of elements starting at the given key and for up to the given number of elements.
List<Tuple2<K,V>>	PairPLL.getRangeBefore(K upperBound, int limit, Comparator<K> comparator)	Returns the list of elements ending at the given key (excluded) and for up to the given number of elements.
protected static CloseableIterator<Tuple2<Long,Record>>	RecordPLL.groupIntoRecords(CloseableIterator<IndexedRow> indexedRows, int keyCellIndex, boolean ignoreFirstRows, List<Row> additionalRows)
<W> PairPLL<K,Tuple2<V,W>>	PairPLL.innerJoinOrdered(PairPLL<K,W> other, Comparator<K> comparator)	Assuming both PairPLLs are ordered by key, and each key appears at most once in each dataset, returns an ordered PairPLL with the inner join of both PLLs.
CloseableIterator<Tuple2<K,V>>	PairPLL.iterate(Partition partition)
protected static <K,V,W> CloseableIterator<Tuple2<K,Tuple2<V,W>>>	OrderedJoinPLL.joinStreams(CloseableIterator<Tuple2<K,V>> firstIterator, CloseableIterator<Tuple2<K,W>> secondIterator, Comparator<K> comparator, OrderedJoinPLL.JoinType joinType)	Merges two key-ordered streams where each key is guaranteed to appear at most once in each stream.
protected static <K,V,W> CloseableIterator<Tuple2<K,Tuple2<V,W>>>	OrderedJoinPLL.joinStreams(CloseableIterator<Tuple2<K,V>> firstIterator, CloseableIterator<Tuple2<K,W>> secondIterator, Comparator<K> comparator, OrderedJoinPLL.JoinType joinType)	Merges two key-ordered streams where each key is guaranteed to appear at most once in each stream.
<W> PairPLL<K,Tuple2<V,W>>	PairPLL.leftJoinOrdered(PairPLL<K,W> other, Comparator<K> comparator)	Assuming both PairPLLs are ordered by key, and each key appears at most once in each dataset, returns an ordered PairPLL with the left join of both PLLs.
<W> PairPLL<K,Tuple2<V,W>>	PairPLL.rightJoinOrdered(PairPLL<K,W> other, Comparator<K> comparator)	Assuming both PairPLLs are ordered by key, and each key appears at most once in each dataset, returns an ordered PairPLL with the right join of both PLLs.
CloseableIterator<Tuple2<K,V>>	PairPLL.streamBetweenKeys(Optional<K> from, Optional<K> upTo, Comparator<K> comparator)	Iterates over the elements of this PLL between the given keys, where both boundaries are optional.
CloseableIterator<Tuple2<K,V>>	PairPLL.streamBetweenKeys(K from, K upTo, Comparator<K> comparator)	Iterates over the elements of this PLL from the given key (inclusive) and up to the other given key (exclusive).
CloseableIterator<Tuple2<K,V>>	PairPLL.streamFromKey(K from, Comparator<K> comparator)	Iterates over the elements of this PLL starting from a given key (inclusive).
CloseableIterator<Tuple2<K,V>>	PairPLL.streamUpToKey(K upTo, Comparator<K> comparator)	Iterates over the elements of this PLL up to the given key (exclusive).
PLL<Tuple2<K,V>>	PairPLL.toPLL()	Returns the underlying PLL, discarding any partitioner.

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

Modifier and Type	Method	Description
PairPLL<K,V>	PairPLL.filter(Predicate<? super Tuple2<K,V>> predicate)
protected static <K,V> List<Tuple2<K,V>>	PairPLL.gatherElementsBefore(K upperBound, int limit, CloseableIterator<Tuple2<K,V>> stream, Comparator<K> comparator)	Returns the last n elements whose key is strictly less than the supplied upper bound.
protected static <K,V,W> CloseableIterator<Tuple2<K,Tuple2<V,W>>>	OrderedJoinPLL.joinStreams(CloseableIterator<Tuple2<K,V>> firstIterator, CloseableIterator<Tuple2<K,W>> secondIterator, Comparator<K> comparator, OrderedJoinPLL.JoinType joinType)	Merges two key-ordered streams where each key is guaranteed to appear at most once in each stream.
<K,V> PairPLL<K,V>	PLL.mapToPair(Function<T,Tuple2<K,V>> mapFunction)	Deprecated. use PLL.mapToPair(Function, String) to also provide a description of the map function applied
<K,V> PairPLL<K,V>	PLL.mapToPair(Function<T,Tuple2<K,V>> mapFunction, String mapDescription)	Maps this collection to an indexed PLL.

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

Constructor	Description
PairPLL(PLL<Tuple2<K,V>> pll, Optional<Partitioner<K>> partitioner)
PairPLL(PLL<Tuple2<K,V>> pll, Optional<Partitioner<K>> partitioner, io.vavr.collection.Array<Long> partitionSizes)