Package org.apache.giraph.worker

Class WorkerAggregatorDelegator<I extends org.apache.hadoop.io.WritableComparable,​V extends org.apache.hadoop.io.Writable,​E extends org.apache.hadoop.io.Writable>

  • All Implemented Interfaces:
    org.apache.giraph.aggregators.AggregatorUsage, org.apache.giraph.conf.GiraphConfigurationSettable<I,​V,​E>, org.apache.giraph.conf.ImmutableClassesGiraphConfigurable<I,​V,​E>, org.apache.giraph.worker.WorkerAggregatorUsage, org.apache.giraph.worker.WorkerBroadcastUsage, org.apache.giraph.worker.WorkerGlobalCommUsage, org.apache.giraph.worker.WorkerReduceUsage
    Direct Known Subclasses:
    AbstractComputation, org.apache.giraph.io.EdgeReader, org.apache.giraph.io.VertexReader, WorkerContext
    public abstract class WorkerAggregatorDelegator<I extends org.apache.hadoop.io.WritableComparable,​V extends org.apache.hadoop.io.Writable,​E extends org.apache.hadoop.io.Writable>
extends org.apache.giraph.conf.DefaultImmutableClassesGiraphConfigurable<I,​V,​E>
implements org.apache.giraph.worker.WorkerAggregatorUsage, org.apache.giraph.worker.WorkerGlobalCommUsage

    • Constructor Detail

      • WorkerAggregatorDelegator

        public WorkerAggregatorDelegator()

    • Method Detail

      • setAggregatorManager

        public void setAggregatorManager​(AggregatorManager aggregatorManager)

      • reduce

        public void reduce​(String name,
                   Object value)
        Specified by:
        reduce in interface org.apache.giraph.worker.WorkerReduceUsage

      • reduceMerge

        public void reduceMerge​(String name,
                        org.apache.hadoop.io.Writable value)
        Specified by:
        reduceMerge in interface org.apache.giraph.worker.WorkerReduceUsage

      • getBroadcast

        public final <B extends org.apache.hadoop.io.Writable> B getBroadcast​(String name)
        Specified by:
        getBroadcast in interface org.apache.giraph.worker.WorkerBroadcastUsage

      • aggregate

        public <A extends org.apache.hadoop.io.Writable> void aggregate​(String name,
                                                                A value)
        Specified by:
        aggregate in interface org.apache.giraph.worker.WorkerAggregatorUsage

      • getAggregatedValue

        public <A extends org.apache.hadoop.io.Writable> A getAggregatedValue​(String name)
        Specified by:
        getAggregatedValue in interface org.apache.giraph.aggregators.AggregatorUsage