Uses of Class
com.cloudera.crunch.Pair

Packages that use Pair

com.cloudera.crunch
com.cloudera.crunch.fn
com.cloudera.crunch.impl.mem
com.cloudera.crunch.impl.mem.collect
com.cloudera.crunch.impl.mr.collect
com.cloudera.crunch.io.hbase
com.cloudera.crunch.io.seq
com.cloudera.crunch.lib
com.cloudera.crunch.type
com.cloudera.crunch.type.avro
com.cloudera.crunch.type.writable
com.cloudera.crunch.util

Uses of Pair in com.cloudera.crunch

Methods in com.cloudera.crunch that return Pair

static <T,U> Pair<T,U>

Pair.of(T first, U second)

Methods in com.cloudera.crunch that return types with arguments of type Pair

<U> PTable<K,Pair<Collection<V>,Collection<U>>>	PTable.cogroup(PTable<K,U> other) Co-group operation with the given table on common keys.
<U> PTable<K,Pair<V,U>>	PTable.join(PTable<K,U> other) Perform an inner join on this table and the one passed in as an argument on their common keys.
static <K,V1,V2> CombineFn<K,Pair<V1,V2>>	CombineFn.pairAggregator(CombineFn.AggregatorFactory<V1> a1, CombineFn.AggregatorFactory<V2> a2)
Iterable<Pair<V1,V2>>	CombineFn.PairAggregator.results()

Methods in com.cloudera.crunch with parameters of type Pair

int	Pair.compareTo(Pair<K,V> o)
void	CombineFn.AggregatorCombineFn.process(Pair<K,Iterable<V>> input, Emitter<Pair<K,V>> emitter)
void	CombineFn.PairAggregator.update(Pair<V1,V2> value)

Method parameters in com.cloudera.crunch with type arguments of type Pair

<K,V> PTable<K,V>	PCollection.parallelDo(DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type) Similar to the other parallelDo instance, but returns a PTable instance instead of a PCollection.
<K,V> PTable<K,V>	PCollection.parallelDo(String name, DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type) Similar to the other parallelDo instance, but returns a PTable instance instead of a PCollection.
void	CombineFn.AggregatorCombineFn.process(Pair<K,Iterable<V>> input, Emitter<Pair<K,V>> emitter)

Uses of Pair in com.cloudera.crunch.fn

Methods in com.cloudera.crunch.fn that return Pair

Pair<S,T>

PairMapFn.map(Pair<K,V> input)

Methods in com.cloudera.crunch.fn with parameters of type Pair

Pair<S,T>	PairMapFn.map(Pair<K,V> input)
void	MapKeysFn.process(Pair<K1,V> input, Emitter<Pair<K2,V>> emitter)
void	MapValuesFn.process(Pair<K,V1> input, Emitter<Pair<K,V2>> emitter)

Method parameters in com.cloudera.crunch.fn with type arguments of type Pair

void	MapKeysFn.process(Pair<K1,V> input, Emitter<Pair<K2,V>> emitter)
void	MapValuesFn.process(Pair<K,V1> input, Emitter<Pair<K,V2>> emitter)

Uses of Pair in com.cloudera.crunch.impl.mem

Method parameters in com.cloudera.crunch.impl.mem with type arguments of type Pair

static <S,T> PTable<S,T>	MemPipeline.tableOf(Iterable<Pair<S,T>> pairs)
static <S,T> PTable<S,T>	MemPipeline.typedTableOf(PTableType<S,T> ptype, Iterable<Pair<S,T>> pairs)

Uses of Pair in com.cloudera.crunch.impl.mem.collect

Methods in com.cloudera.crunch.impl.mem.collect that return types with arguments of type Pair

<U> PTable<K,Pair<Collection<V>,Collection<U>>>	MemTable.cogroup(PTable<K,U> other)
<U> PTable<K,Pair<V,U>>	MemTable.join(PTable<K,U> other)

Method parameters in com.cloudera.crunch.impl.mem.collect with type arguments of type Pair

<K,V> PTable<K,V>	MemCollection.parallelDo(DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type)
<K,V> PTable<K,V>	MemCollection.parallelDo(String name, DoFn<S,Pair<K,V>> doFn, PTableType<K,V> type)

Constructor parameters in com.cloudera.crunch.impl.mem.collect with type arguments of type Pair

MemTable(Iterable<Pair<K,V>> collect)

MemTable(Iterable<Pair<K,V>> collect, PTableType<K,V> ptype, String name)

Uses of Pair in com.cloudera.crunch.impl.mr.collect

Methods in com.cloudera.crunch.impl.mr.collect that return types with arguments of type Pair

<U> PTable<K,Pair<Collection<V>,Collection<U>>>	PTableBase.cogroup(PTable<K,U> other)
PType<Pair<K,V>>	UnionTable.getPType()
PType<Pair<K,Iterable<V>>>	PGroupedTableImpl.getPType()
PType<Pair<K,V>>	InputTable.getPType()
PType<Pair<K,V>>	DoTableImpl.getPType()
<U> PTable<K,Pair<V,U>>	PTableBase.join(PTable<K,U> other)

Method parameters in com.cloudera.crunch.impl.mr.collect with type arguments of type Pair

<K,V> PTable<K,V>	PCollectionImpl.parallelDo(DoFn<S,Pair<K,V>> fn, PTableType<K,V> type)
<K,V> PTable<K,V>	PCollectionImpl.parallelDo(String name, DoFn<S,Pair<K,V>> fn, PTableType<K,V> type)

Uses of Pair in com.cloudera.crunch.io.hbase

Methods in com.cloudera.crunch.io.hbase that return types with arguments of type Pair

PType<Pair<org.apache.hadoop.hbase.io.ImmutableBytesWritable,org.apache.hadoop.hbase.client.Result>>

HBaseSourceTarget.getType()

Uses of Pair in com.cloudera.crunch.io.seq

Methods in com.cloudera.crunch.io.seq that return types with arguments of type Pair

PType<Pair<K,V>>	SeqFileTableSourceTarget.getType()
Iterable<Pair<K,V>>	SeqFileTableSourceTarget.read(org.apache.hadoop.conf.Configuration conf)
Iterator<Pair<K,V>>	SeqFileTableReaderFactory.read(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path)

Uses of Pair in com.cloudera.crunch.lib

Methods in com.cloudera.crunch.lib that return types with arguments of type Pair

static <K,U,V> PTable<K,Pair<Collection<U>,Collection<V>>>	Cogroup.cogroup(PTable<K,U> left, PTable<K,V> right) Co-groups the two PTable arguments.
static <K,U,V> PTable<K,Pair<U,V>>	Join.innerJoin(PTable<K,U> left, PTable<K,V> right)
static <K,U,V> PTable<K,Pair<U,V>>	Join.join(PTable<K,U> left, PTable<K,V> right)
static <K,U,V> PTable<K,Pair<U,V>>	Join.leftJoin(PTable<K,U> left, PTable<K,V> right)
static <U,V> PCollection<Pair<U,V>>	Sort.sortPairs(PCollection<Pair<U,V>> collection, Sort.ColumnOrder... columnOrders) Sorts the PCollection of Pairs using the specified column ordering.

Methods in com.cloudera.crunch.lib with parameters of type Pair

int	Aggregate.PairValueComparator.compare(Pair<K,V> left, Pair<K,V> right)
int	Aggregate.PairValueComparator.compare(Pair<K,V> left, Pair<K,V> right)
void	Aggregate.TopKCombineFn.process(Pair<Boolean,Iterable<Pair<K,V>>> input, Emitter<Pair<Boolean,Pair<K,V>>> emitter)
void	Aggregate.TopKFn.process(Pair<K,V> input, Emitter<Pair<Boolean,Pair<K,V>>> emitter)

Method parameters in com.cloudera.crunch.lib with type arguments of type Pair

void	Aggregate.TopKFn.cleanup(Emitter<Pair<Boolean,Pair<K,V>>> emitter)
void	Aggregate.TopKFn.cleanup(Emitter<Pair<Boolean,Pair<K,V>>> emitter)
void	Aggregate.TopKCombineFn.process(Pair<Boolean,Iterable<Pair<K,V>>> input, Emitter<Pair<Boolean,Pair<K,V>>> emitter)
void	Aggregate.TopKCombineFn.process(Pair<Boolean,Iterable<Pair<K,V>>> input, Emitter<Pair<Boolean,Pair<K,V>>> emitter)
void	Aggregate.TopKCombineFn.process(Pair<Boolean,Iterable<Pair<K,V>>> input, Emitter<Pair<Boolean,Pair<K,V>>> emitter)
void	Aggregate.TopKFn.process(Pair<K,V> input, Emitter<Pair<Boolean,Pair<K,V>>> emitter)
void	Aggregate.TopKFn.process(Pair<K,V> input, Emitter<Pair<Boolean,Pair<K,V>>> emitter)
static <U,V> PCollection<Pair<U,V>>	Sort.sortPairs(PCollection<Pair<U,V>> collection, Sort.ColumnOrder... columnOrders) Sorts the PCollection of Pairs using the specified column ordering.

Uses of Pair in com.cloudera.crunch.type

Fields in com.cloudera.crunch.type with type parameters of type Pair

static TupleFactory<Pair>

TupleFactory.PAIR

Methods in com.cloudera.crunch.type that return Pair

Pair<K,Iterable<V>>

PGroupedTableType.PairIterableMapFn.map(Pair<Object,Iterable<Object>> input)

Methods in com.cloudera.crunch.type that return types with arguments of type Pair

SourceTarget<Pair<K,Iterable<V>>>	PGroupedTableType.getDefaultFileSource(org.apache.hadoop.fs.Path path)
<V1,V2> PType<Pair<V1,V2>>	PTypeFamily.pairs(PType<V1> p1, PType<V2> p2)

Methods in com.cloudera.crunch.type with parameters of type Pair

Pair<K,Iterable<V>>

PGroupedTableType.PairIterableMapFn.map(Pair<Object,Iterable<Object>> input)

Uses of Pair in com.cloudera.crunch.type.avro

Methods in com.cloudera.crunch.type.avro that return Pair

Pair<K,V>	AvroPairConverter.convertInput(org.apache.avro.mapred.AvroKey<K> key, org.apache.avro.mapred.AvroValue<V> value)
Pair<K,Iterable<V>>	AvroPairConverter.convertIterableInput(org.apache.avro.mapred.AvroKey<K> key, Iterable<org.apache.avro.mapred.AvroValue<V>> iter)

Methods in com.cloudera.crunch.type.avro that return types with arguments of type Pair

Class<Pair<K,Iterable<V>>>	AvroGroupedTableType.getTypeClass()
<V1,V2> PType<Pair<V1,V2>>	AvroTypeFamily.pairs(PType<V1> p1, PType<V2> p2)
static <V1,V2> AvroType<Pair<V1,V2>>	Avros.pairs(PType<V1> p1, PType<V2> p2)

Methods in com.cloudera.crunch.type.avro with parameters of type Pair

org.apache.avro.mapred.AvroKey<K>	AvroPairConverter.outputKey(Pair<K,V> value)
org.apache.avro.mapred.AvroValue<V>	AvroPairConverter.outputValue(Pair<K,V> value)

Constructor parameters in com.cloudera.crunch.type.avro with type arguments of type Pair

AvroTableType(AvroType<K> keyType, AvroType<V> valueType, Class<Pair<K,V>> pairClass)

Uses of Pair in com.cloudera.crunch.type.writable

Methods in com.cloudera.crunch.type.writable that return Pair

Pair<K,V>	WritablePairConverter.convertInput(K key, V value)
Pair<K,Iterable<V>>	WritablePairConverter.convertIterableInput(K key, Iterable<V> value)

Methods in com.cloudera.crunch.type.writable that return types with arguments of type Pair

Class<Pair<K,Iterable<V>>>	WritableGroupedTableType.getTypeClass()
<V1,V2> PType<Pair<V1,V2>>	WritableTypeFamily.pairs(PType<V1> p1, PType<V2> p2)
static <V1,V2> WritableType<Pair<V1,V2>,TupleWritable>	Writables.pairs(PType<V1> p1, PType<V2> p2)

Methods in com.cloudera.crunch.type.writable with parameters of type Pair

K	WritablePairConverter.outputKey(Pair<K,V> value)
V	WritablePairConverter.outputValue(Pair<K,V> value)

Uses of Pair in com.cloudera.crunch.util

Methods in com.cloudera.crunch.util that return types with arguments of type Pair

Iterator<Pair<S,T>>

Tuples.PairIterable.iterator()