Modifier and Type | Method and Description |
---|---|
ObjectWritable |
GiraphMessageCombiner.createInitialMessage() |
ObjectWritable<<any>> |
MemoryAggregator.createInitialValue() |
ObjectWritable<<any>> |
MemoryAggregator.getAggregatedValue() |
Modifier and Type | Method and Description |
---|---|
void |
MemoryAggregator.aggregate(ObjectWritable<<any>> object) |
void |
GiraphMessageCombiner.combine(ObjectWritable vertexIndex,
ObjectWritable originalMessage,
ObjectWritable messageToCombine) |
void |
GiraphMessageCombiner.combine(ObjectWritable vertexIndex,
ObjectWritable originalMessage,
ObjectWritable messageToCombine) |
void |
GiraphMessageCombiner.combine(ObjectWritable vertexIndex,
ObjectWritable originalMessage,
ObjectWritable messageToCombine) |
void |
EmptyOutEdges.remove(ObjectWritable targetVertexId) |
void |
MemoryAggregator.setAggregatedValue(ObjectWritable<<any>> object) |
Modifier and Type | Method and Description |
---|---|
void |
GiraphComputation.compute(<any> vertex,
Iterable<ObjectWritable> messages) |
GiraphMessenger |
GiraphWorkerContext.getMessenger(GiraphVertex giraphVertex,
GiraphComputation giraphComputation,
Iterator<ObjectWritable> messages) |
Constructor and Description |
---|
GiraphMessenger(GiraphVertex giraphVertex,
GiraphComputation giraphComputation,
Iterator<ObjectWritable<M>> messages) |
Modifier and Type | Method and Description |
---|---|
void |
HadoopCombine.reduce(ObjectWritable key,
Iterable<ObjectWritable> values,
<any>.Context context) |
void |
HadoopReduce.reduce(ObjectWritable key,
Iterable<ObjectWritable> values,
<any>.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
HadoopCombine.reduce(ObjectWritable key,
Iterable<ObjectWritable> values,
<any>.Context context) |
void |
HadoopReduce.reduce(ObjectWritable key,
Iterable<ObjectWritable> values,
<any>.Context context) |
Modifier and Type | Method and Description |
---|---|
static <A> ObjectWritable<A> |
ObjectWritable.empty() |
static ObjectWritable<MapReduce.NullObject> |
ObjectWritable.getNullObjectWritable() |
Modifier and Type | Method and Description |
---|---|
int |
ObjectWritableComparator.compare(ObjectWritable objectWritable1,
ObjectWritable objectWritable2) |
int |
ObjectWritableComparator.compare(ObjectWritable objectWritable1,
ObjectWritable objectWritable2) |
int |
ObjectWritable.compareTo(ObjectWritable objectWritable) |
Modifier and Type | Method and Description |
---|---|
ObjectWritable<A> |
MemoryAccumulator.addAccumulator(ObjectWritable<A> a,
ObjectWritable<A> b) |
ObjectWritable<A> |
MemoryAccumulator.addInPlace(ObjectWritable<A> a,
ObjectWritable<A> b) |
ObjectWritable<A> |
MemoryAccumulator.zero(ObjectWritable<A> a) |
Modifier and Type | Method and Description |
---|---|
ObjectWritable<A> |
MemoryAccumulator.addAccumulator(ObjectWritable<A> a,
ObjectWritable<A> b) |
ObjectWritable<A> |
MemoryAccumulator.addAccumulator(ObjectWritable<A> a,
ObjectWritable<A> b) |
ObjectWritable<A> |
MemoryAccumulator.addInPlace(ObjectWritable<A> a,
ObjectWritable<A> b) |
ObjectWritable<A> |
MemoryAccumulator.addInPlace(ObjectWritable<A> a,
ObjectWritable<A> b) |
ObjectWritable<A> |
MemoryAccumulator.zero(ObjectWritable<A> a) |
Modifier and Type | Method and Description |
---|---|
<I extends InputShim> |
ObjectWritableSerializer.read(KryoShim<I,?> kryo,
I input,
Class<ObjectWritable<T>> clazz) |
Modifier and Type | Method and Description |
---|---|
<O extends OutputShim> |
ObjectWritableSerializer.write(KryoShim<?,O> kryo,
O output,
ObjectWritable<T> starGraph) |
Modifier and Type | Method and Description |
---|---|
<I extends InputShim> |
ObjectWritableSerializer.read(KryoShim<I,?> kryo,
I input,
Class<ObjectWritable<T>> clazz) |
Copyright © 2013–2018 Apache Software Foundation. All rights reserved.