| Package | Description | 
|---|---|
| org.apache.giraph.comm | Package of communication related objects, IPC service. | 
| org.apache.giraph.comm.aggregators | Package for classes which are used to handle aggregators. | 
| org.apache.giraph.comm.netty | Package for netty implementations. | 
| Modifier and Type | Method and Description | 
|---|---|
| static GlobalCommType | GlobalCommType. valueOf(String name)Returns the enum constant of this type with the specified name. | 
| static GlobalCommType[] | GlobalCommType. values()Returns an array containing the constants of this enum type, in
the order they are declared. | 
| Modifier and Type | Method and Description | 
|---|---|
| void | MasterClient. sendToOwner(String name,
           GlobalCommType type,
           org.apache.hadoop.io.Writable value)Sends aggregator to its owner | 
| Modifier and Type | Method and Description | 
|---|---|
| int | SendGlobalCommCache. addValue(Integer taskId,
        String name,
        GlobalCommType type,
        org.apache.hadoop.io.Writable value)Add global communication value to the cache | 
| int | GlobalCommValueOutputStream. addValue(String name,
        GlobalCommType type,
        org.apache.hadoop.io.Writable value)Write global communication object to the stream
 and increment internal counter | 
| void | AllAggregatorServerData. receiveValueFromMaster(String name,
                      GlobalCommType type,
                      org.apache.hadoop.io.Writable value)Received value through global communication from master. | 
| Modifier and Type | Method and Description | 
|---|---|
| void | NettyMasterClient. sendToOwner(String name,
           GlobalCommType sendType,
           org.apache.hadoop.io.Writable object) | 
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.