| Class | Description |
|---|---|
| ByteUtils |
Utility methods
|
| RRClient |
RequestID response client
|
| RRServer |
RRServer class is used by Job Master
It works in request/response messaging
Workers and the client always send a request message, and
JobMaster sends a single response message to each request message
However, sometimes job master may send messages to workers that are not response messages
For example, the driver in Job Master may send messages to workers
The messages that are initiated from Job Master are one-way messages
They don't have response messages
Message Format:
RequestID (32 bytes), message type length, message type data, senderID (4 bytes), message data
message type is the class name of the protocol buffer for that message
RequestID is generated in request senders (workers or the client),
and the same requestID is used in the response message.
|
| TwoChannelTest |
In this test we will use two channels to communicate
|