Package | Description |
---|---|
org.apache.giraph.comm.flow_control |
Package for flow-control policies.
|
org.apache.giraph.comm.netty.handler |
Package for classes which handle requests and responses.
|
Modifier and Type | Method and Description |
---|---|
AckSignalFlag |
StaticFlowControl.getAckSignalFlag(int response) |
AckSignalFlag |
CreditBasedFlowControl.getAckSignalFlag(int response)
Get the response flag from a response
|
AckSignalFlag |
NoOpFlowControl.getAckSignalFlag(int response) |
AckSignalFlag |
FlowControl.getAckSignalFlag(int response)
Decode the acknowledgement signal from the response after an open request
is completed
|
Modifier and Type | Method and Description |
---|---|
int |
StaticFlowControl.calculateResponse(AckSignalFlag alreadyDone,
int clientId) |
int |
CreditBasedFlowControl.calculateResponse(AckSignalFlag flag,
int taskId) |
int |
NoOpFlowControl.calculateResponse(AckSignalFlag alreadyDone,
int taskId) |
int |
FlowControl.calculateResponse(AckSignalFlag flag,
int taskId)
Calculate/Build the response to piggyback with acknowledgement
|
Modifier and Type | Method and Description |
---|---|
static AckSignalFlag |
AckSignalFlag.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static AckSignalFlag[] |
AckSignalFlag.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.