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