org.apache.giraph.comm.requests

Enum RequestType

java.lang.Object

java.lang.Enum<RequestType>

org.apache.giraph.comm.requests.RequestType

All Implemented Interfaces:

Serializable, Comparable<RequestType>

public enum RequestType
extends Enum<RequestType>

Type of the request

Enum Constant Summary

Enum Constants

Enum Constant and Description
ADDRESSES_AND_PARTITIONS_REQUEST Send addresses and partitions assignments from master to workers
ASK_FOR_INPUT_SPLIT_REQUEST Send request for input split from worker to master
PARTITION_STATS_REQUEST Send partition stats from worker to master
REPLY_WITH_INPUT_SPLIT_REQUEST Send request with granted input split from master to workers
SASL_COMPLETE_REQUEST Used by servers to acknowledge SASL authentication completion with client, so client can modify its pipeline afterwards.
SASL_TOKEN_MESSAGE_REQUEST Exchange authentication information between clients and servers
SEND_AGGREGATORS_TO_MASTER_REQUEST Send aggregated values from worker owner to master
SEND_AGGREGATORS_TO_OWNER_REQUEST Send aggregators from master to worker owners
SEND_AGGREGATORS_TO_WORKER_REQUEST Send aggregators from worker owner to other workers
SEND_PARTITION_CURRENT_MESSAGES_REQUEST Sending a partition of messages for current superstep (used during partition exchange)
SEND_PARTITION_MUTATIONS_REQUEST Send a partition of mutations
SEND_RESUME_REQUEST Send request to resume sending messages (used in flow-control)
SEND_VERTEX_REQUEST Sending vertices request
SEND_WORKER_AGGREGATORS_REQUEST Send aggregated values from one worker's vertices
SEND_WORKER_EDGES_REQUEST Send a partition of edges
SEND_WORKER_MESSAGES_REQUEST Sending a partition of messages for next superstep
SEND_WORKER_ONE_MESSAGE_TO_MANY_REQUEST Sending one message to many ids in a single request
SEND_WORKER_TO_WORKER_MESSAGE_REQUEST Send message from worker to worker
SEND_WORKER_VERTICES_REQUEST Sending vertices request

Method Summary

Modifier and Type	Method and Description
Class<? extends WritableRequest>	getRequestClass() Get class of request which this type corresponds to
static RequestType	valueOf(String name) Returns the enum constant of this type with the specified name.
static RequestType[]	values() Returns an array containing the constants of this enum type, in the order they are declared.

Methods inherited from class java.lang.Enum

clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Enum Constant Detail

SASL_TOKEN_MESSAGE_REQUEST

public static final RequestType SASL_TOKEN_MESSAGE_REQUEST

Exchange authentication information between clients and servers

SASL_COMPLETE_REQUEST

public static final RequestType SASL_COMPLETE_REQUEST

Used by servers to acknowledge SASL authentication completion with client, so client can modify its pipeline afterwards.

SEND_VERTEX_REQUEST

public static final RequestType SEND_VERTEX_REQUEST

Sending vertices request

SEND_WORKER_VERTICES_REQUEST

public static final RequestType SEND_WORKER_VERTICES_REQUEST

Sending vertices request

SEND_WORKER_MESSAGES_REQUEST

public static final RequestType SEND_WORKER_MESSAGES_REQUEST

Sending a partition of messages for next superstep

SEND_WORKER_ONE_MESSAGE_TO_MANY_REQUEST

public static final RequestType SEND_WORKER_ONE_MESSAGE_TO_MANY_REQUEST

Sending one message to many ids in a single request

SEND_PARTITION_CURRENT_MESSAGES_REQUEST

public static final RequestType SEND_PARTITION_CURRENT_MESSAGES_REQUEST

Sending a partition of messages for current superstep (used during partition exchange)

SEND_WORKER_EDGES_REQUEST

public static final RequestType SEND_WORKER_EDGES_REQUEST

Send a partition of edges

SEND_PARTITION_MUTATIONS_REQUEST

public static final RequestType SEND_PARTITION_MUTATIONS_REQUEST

Send a partition of mutations

SEND_WORKER_AGGREGATORS_REQUEST

public static final RequestType SEND_WORKER_AGGREGATORS_REQUEST

Send aggregated values from one worker's vertices

SEND_AGGREGATORS_TO_MASTER_REQUEST

public static final RequestType SEND_AGGREGATORS_TO_MASTER_REQUEST

Send aggregated values from worker owner to master

SEND_AGGREGATORS_TO_OWNER_REQUEST

public static final RequestType SEND_AGGREGATORS_TO_OWNER_REQUEST

Send aggregators from master to worker owners

SEND_AGGREGATORS_TO_WORKER_REQUEST

public static final RequestType SEND_AGGREGATORS_TO_WORKER_REQUEST

Send aggregators from worker owner to other workers

SEND_WORKER_TO_WORKER_MESSAGE_REQUEST

public static final RequestType SEND_WORKER_TO_WORKER_MESSAGE_REQUEST

Send message from worker to worker

ASK_FOR_INPUT_SPLIT_REQUEST

public static final RequestType ASK_FOR_INPUT_SPLIT_REQUEST

Send request for input split from worker to master

REPLY_WITH_INPUT_SPLIT_REQUEST

public static final RequestType REPLY_WITH_INPUT_SPLIT_REQUEST

Send request with granted input split from master to workers

SEND_RESUME_REQUEST

public static final RequestType SEND_RESUME_REQUEST

Send request to resume sending messages (used in flow-control)

ADDRESSES_AND_PARTITIONS_REQUEST

public static final RequestType ADDRESSES_AND_PARTITIONS_REQUEST

Send addresses and partitions assignments from master to workers

PARTITION_STATS_REQUEST

public static final RequestType PARTITION_STATS_REQUEST

Send partition stats from worker to master

Method Detail

values

public static RequestType[] values()

Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:

for (RequestType c : RequestType.values())
    System.out.println(c);

Returns:

an array containing the constants of this enum type, in the order they are declared

valueOf

public static RequestType valueOf(String name)

Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)

Parameters:

name - the name of the enum constant to be returned.

Returns:

the enum constant with the specified name

Throws:

IllegalArgumentException - if this enum type has no constant with the specified name

NullPointerException - if the argument is null

getRequestClass

public Class<? extends WritableRequest> getRequestClass()

Get class of request which this type corresponds to

Returns:

Class of request which this type corresponds to