| 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 | 
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 | 
|---|---|
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.