Modifier and Type | Method and Description |
---|---|
void |
HadoopReduce.reduce(ObjectWritable key,
Iterable<ObjectWritable> values,
<any>.Context context) |
void |
HadoopCombine.reduce(ObjectWritable key,
Iterable<ObjectWritable> values,
<any>.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
HadoopReduce.reduce(ObjectWritable key,
Iterable<ObjectWritable> values,
<any>.Context context) |
void |
HadoopCombine.reduce(ObjectWritable key,
Iterable<ObjectWritable> values,
<any>.Context context) |
Modifier and Type | Method and Description |
---|---|
ObjectWritable |
GiraphMessageCombiner.createInitialMessage() |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
void |
GiraphComputeVertex.compute(Iterable<ObjectWritable> messages) |
GiraphMessenger |
GiraphWorkerContext.getMessenger(GiraphComputeVertex giraphComputeVertex,
Iterator<ObjectWritable> messages) |
Constructor and Description |
---|
GiraphMessenger(GiraphComputeVertex giraphComputeVertex,
Iterator<ObjectWritable<M>> messages) |
Modifier and Type | Method and Description |
---|---|
static ObjectWritable |
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) |
Copyright © 2013–2015 Apache Software Foundation. All rights reserved.