Package | Description |
---|---|
org.apache.giraph.reducers.impl |
Package of Giraph reducers.
|
org.apache.giraph.writable.tuple |
Writable tuple utilities
|
Modifier and Type | Method and Description |
---|---|
PairWritable<L,R> |
MaxPairReducer.createInitialValue() |
PairWritable<R1,R2> |
PairReduce.createInitialValue() |
PairWritable<L,R> |
MaxPairReducer.reduce(PairWritable<L,R> curValue,
PairWritable<L,R> valueToReduce) |
PairWritable<R1,R2> |
PairReduce.reduce(PairWritable<R1,R2> curValue,
org.apache.commons.lang3.tuple.Pair<S1,S2> valueToReduce) |
PairWritable<R1,R2> |
PairReduce.reduceMerge(PairWritable<R1,R2> curValue,
PairWritable<R1,R2> valueToReduce) |
Modifier and Type | Method and Description |
---|---|
PairWritable<L,R> |
MaxPairReducer.reduce(PairWritable<L,R> curValue,
PairWritable<L,R> valueToReduce) |
PairWritable<L,R> |
MaxPairReducer.reduce(PairWritable<L,R> curValue,
PairWritable<L,R> valueToReduce) |
PairWritable<R1,R2> |
PairReduce.reduce(PairWritable<R1,R2> curValue,
org.apache.commons.lang3.tuple.Pair<S1,S2> valueToReduce) |
PairWritable<R1,R2> |
PairReduce.reduceMerge(PairWritable<R1,R2> curValue,
PairWritable<R1,R2> valueToReduce) |
PairWritable<R1,R2> |
PairReduce.reduceMerge(PairWritable<R1,R2> curValue,
PairWritable<R1,R2> valueToReduce) |
Modifier and Type | Class and Description |
---|---|
class |
DoubleDoubleWritable
Double-double Pair Writable
|
class |
IntDoubleWritable
Int-Double Pair Writable
|
class |
IntIntWritable
Int-Int Pair Writable
|
class |
IntLongWritable
Int-Long Pair Writable
|
class |
LongDoubleWritable
Long-Double Pair Writable
|
class |
LongIntWritable
Long-Int Pair Writable
|
class |
LongLongWritable
Long-Long Pair Writable
|
Modifier and Type | Method and Description |
---|---|
static <L extends org.apache.hadoop.io.Writable,R extends org.apache.hadoop.io.Writable> |
PairWritable.of(L left,
R right)
Obtains an immutable pair of from two objects inferring
the generic types.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.