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.