Name | Description | Type | Package | Framework |
AbstractListPerVertexStore | Abstract Implementation of SimpleMessageStore where multiple messages are stored per vertex as a list | Class | org.apache.giraph.comm.messages | Giraph |
AddressRequestIdGenerator | Generate different request ids based on the address of the well known port on the workers. | Class | org.apache.giraph.comm.netty.handler | Giraph |
AggregatorUtils | Class | org.apache.giraph.comm.aggregators | Giraph | |
AllAggregatorServerData | Accepts aggregators and their values from previous superstep from master and workers which own aggregators. | Class | org.apache.giraph.comm.aggregators | Giraph |
AsyncMessageStoreWrapper | This class decouples message receiving and processing into separate threads thus reducing contention. | Class | org.apache.giraph.comm.messages.queue | Giraph |
AuthorizeServerHandler | Authorize or deny client requests based on existence and completeness of client's SASL authentication. | Class | org.apache.giraph.comm.netty.handler | Giraph |
ByteArrayMessagesPerVertexStore | stored per vertex as byte backed datastructures. | Class | org.apache.giraph.comm.messages | Giraph |
ByteArrayRequest | Class | org.apache.giraph.comm.requests | Giraph | |
ByteArrayWithSenderTaskIdRequest | Class | org.apache.giraph.comm.requests | Giraph | |
ByteCounter | Interface | org.apache.giraph.comm.netty | Giraph | |
ByteCounterDelegate | Delegate Object to help keep track of the bytes processed and provide some metrics when desired as part of the Netty Channel stack. | Class | org.apache.giraph.comm.netty | Giraph |
ChannelRotater | Maintains multiple channels and rotates between them. | Class | org.apache.giraph.comm.netty | Giraph |
ClientRequestId | Simple immutable object to use for tracking requests uniquely. | Class | org.apache.giraph.comm.netty.handler | Giraph |
CountingCache | Cache which counts the number of flushes per task id (destination worker id), so we know how many requests were sent to the worker | Class | org.apache.giraph.comm.aggregators | Giraph |
CountingOutputStream | Wrapper for output stream which keeps the place in the beginning for the count of objects which were written to it | Class | org.apache.giraph.comm.aggregators | Giraph |
DiskBackedMessageStore | Message store which separates data by partitions, and submits them to underlying message store. | Class | org.apache.giraph.comm.messages.out_of_core | Giraph |
DiskBackedMessageStoreFactory | Message store factory which persist the messages on the disk. | Class | org.apache.giraph.comm.messages.out_of_core | Giraph |
GlobalCommType | Type tag distinguishing different global communication messages. | Class | org.apache.giraph.comm | Giraph |
GlobalCommValueOutputStream | reduced values in the form of pair (name, type, value) There are two modes: | Class | org.apache.giraph.comm.aggregators | Giraph |
IdByteArrayMessageStore | Special message store to be used when IDs are primitive and no combiner is Data is backed by primitive maps in order to decrease number of objects and | Class | org.apache.giraph.comm.messages.primitives | Giraph |
IdOneMessagePerVertexStore | Special message store to be used when IDs are primitive and message doesn't need to be, and message combiner is used. | Class | org.apache.giraph.comm.messages.primitives | Giraph |
InboundByteCounter | Keep track of the bytes received and provide some metrics when desired as part of the Netty Channel stack. | Class | org.apache.giraph.comm.netty | Giraph |
InMemoryMessageStoreFactory | Message store factory which produces message stores which hold all messages in memory. | Class | org.apache.giraph.comm.messages | Giraph |
IntByteArrayMessageStore | Special message store to be used when ids are IntWritable and no combiner Uses fastutil primitive maps in order to decrease number of objects and | Class | org.apache.giraph.comm.messages.primitives | Giraph |
IntFloatMessageStore | Special message store to be used when ids are IntWritable and messages are FloatWritable and messageCombiner is used. | Class | org.apache.giraph.comm.messages.primitives | Giraph |
LongAbstractListMessageStore | Special message store to be used when ids are LongWritable and no combiner Uses fastutil primitive maps in order to decrease number of objects and | Class | org.apache.giraph.comm.messages.primitives.long_id | Giraph |
LongAbstractMessageStore | Special message store to be used when ids are LongWritable and no combiner Uses fastutil primitive maps in order to decrease number of objects and | Class | org.apache.giraph.comm.messages.primitives.long_id | Giraph |
LongByteArrayMessageStore | Special message store to be used when ids are LongWritable and no combiner Uses fastutil primitive maps in order to decrease number of objects and | Class | org.apache.giraph.comm.messages.primitives.long_id | Giraph |
LongDoubleMessageStore | Special message store to be used when ids are LongWritable and messages are DoubleWritable and messageCombiner is used. | Class | org.apache.giraph.comm.messages.primitives | Giraph |
LongPointerListMessageStore | This stores messages in ExtendedByteArrayOutputBuffer | Class | org.apache.giraph.comm.messages.primitives.long_id | Giraph |
MasterClient | Interface | org.apache.giraph.comm | Giraph | |
MasterRequest | Interface | org.apache.giraph.comm.requests | Giraph | |
MasterRequestServerHandler | Class | org.apache.giraph.comm.netty.handler | Giraph | |
MasterRequestServerHandler .Factory | Class | org.apache.giraph.comm.netty.handler.MasterRequestServerHandler | Giraph | |
MasterServer | Interface | org.apache.giraph.comm | Giraph | |
MessageEncodeAndStoreType | enum MessageEncodeAndStoreTypeThere are two types of message-stores currently | Class | org.apache.giraph.comm.messages | Giraph |
MessagesIterable | Class | org.apache.giraph.comm.messages | Giraph | |
MessageStore | Interface | org.apache.giraph.comm.messages | Giraph | |
MessageStoreFactory | Interface | org.apache.giraph.comm.messages | Giraph | |
NettyClient | Netty client for sending requests. | Class | org.apache.giraph.comm.netty | Giraph |
NettyMasterClient | Class | org.apache.giraph.comm.netty | Giraph | |
NettyMasterServer | Class | org.apache.giraph.comm.netty | Giraph | |
NettyServer | Class | org.apache.giraph.comm.netty | Giraph | |
NettyWorkerAggregatorRequestProcessor | Class | org.apache.giraph.comm.netty | Giraph | |
NettyWorkerClient | Takes users facing APIs in WorkerClient and implements them using the available WritableRequest objects. | Class | org.apache.giraph.comm.netty | Giraph |
NettyWorkerClientRequestProcessor | Aggregate requests and sends them to the thread-safe NettyClient. | Class | org.apache.giraph.comm.netty | Giraph |
NettyWorkerServer | Netty worker server that implement WorkerServer and contains the actual ServerData. | Class | org.apache.giraph.comm.netty | Giraph |
OneMessagePerVertexStore | message per vertex. | Class | org.apache.giraph.comm.messages | Giraph |
OutboundByteCounter | Keep track of the bytes sent and provide some metrics when desired as part of the Netty Channel stack. | Class | org.apache.giraph.comm.netty | Giraph |
OwnerAggregatorServerData | Class for holding aggregators which current worker owns, and aggregating partial aggregator values from workers. | Class | org.apache.giraph.comm.aggregators | Giraph |
PartitionDiskBackedMessageStore | Message storage with in-memory map of messages and with support for flushing all the messages to the disk. | Class | org.apache.giraph.comm.messages.out_of_core | Giraph |
PartitionMessage | Small wrapper that holds a reference to vertex message and knows partition id. | Class | org.apache.giraph.comm.messages.queue | Giraph |
PointerListMessagesIterable | Class | org.apache.giraph.comm.messages | Giraph | |
PointerListPerVertexStore | stored as a list of long pointers to extended data output objects Used when there is no combiner provided. | Class | org.apache.giraph.comm.messages | Giraph |
RequestDecoder | Decodes encoded requests from the client. | Class | org.apache.giraph.comm.netty.handler | Giraph |
RequestEncoder | Requests have a request type and an encoded request. | Class | org.apache.giraph.comm.netty.handler | Giraph |
RequestInfo | Class | org.apache.giraph.comm.netty.handler | Giraph | |
RequestServerHandler | Generic handler of requests. | Class | org.apache.giraph.comm.netty.handler | Giraph |
RequestServerHandler .Factory | Interface | org.apache.giraph.comm.netty.handler.RequestServerHandler | Giraph | |
RequestType | Class | org.apache.giraph.comm.requests | Giraph | |
ResponseClientHandler | Generic handler of responses. | Class | org.apache.giraph.comm.netty.handler | Giraph |
ResponseEncoder | How a server should respond to a client. | Class | org.apache.giraph.comm.netty.handler | Giraph |
SaslClientHandler | Class | org.apache.giraph.comm.netty.handler | Giraph | |
SaslCompleteRequest | Reply from server to client after SASL authentication completes. | Class | org.apache.giraph.comm.requests | Giraph |
SaslNettyClient | Class | org.apache.giraph.comm.netty | Giraph | |
SaslNettyServer | Encapsulates SASL server logic for Giraph BSP worker servers. | Class | org.apache.giraph.comm.netty | Giraph |
SaslNettyServer .SaslDigestCallbackHandler | Class | org.apache.giraph.comm.netty.SaslNettyServer | Giraph | |
SaslServerHandler | Generate SASL response tokens to client SASL tokens, allowing clients to authenticate themselves with this server. | Class | org.apache.giraph.comm.netty.handler | Giraph |
SaslServerHandler .Factory | Class | org.apache.giraph.comm.netty.handler.SaslServerHandler | Giraph | |
SaslTokenMessageRequest | Send and receive SASL tokens. | Class | org.apache.giraph.comm.requests | Giraph |
SendAggregatorsToOwnerRequest | Class | org.apache.giraph.comm.requests | Giraph | |
SendAggregatorsToWorkerRequest | Class | org.apache.giraph.comm.requests | Giraph | |
SendDataCache | An abstract structure for caching data by partitions to be sent to workers in bulk. | Class | org.apache.giraph.comm | Giraph |
SendEdgeCache | Aggregates the edges to be sent to workers so they can be sent in bulk. | Class | org.apache.giraph.comm | Giraph |
SendGlobalCommCache | Takes and serializes global communication values and keeps them grouped by owner partition id, to be sent in bulk. | Class | org.apache.giraph.comm.aggregators | Giraph |
SendMessageCache | Aggregates the messages to be sent to workers so they can be sent in bulk. | Class | org.apache.giraph.comm | Giraph |
SendMutationsCache | Class | org.apache.giraph.comm | Giraph | |
SendOneMessageToManyCache | Class | org.apache.giraph.comm | Giraph | |
SendPartitionCache | Caches partition vertices prior to sending. | Class | org.apache.giraph.comm | Giraph |
SendPartitionCurrentMessagesRequest | Send a collection of vertex messages for a partition. | Class | org.apache.giraph.comm.requests | Giraph |
SendPartitionMutationsRequest | Send a collection of vertex mutations for a partition. | Class | org.apache.giraph.comm.requests | Giraph |
SendReducedToMasterRequest | Request to send final aggregated values from worker which owns aggregators to the master | Class | org.apache.giraph.comm.requests | Giraph |
SendVertexIdDataCache | An abstract structure for caching data indexed by vertex id, to be sent to workers in bulk. | Class | org.apache.giraph.comm | Giraph |
SendVertexRequest | Send a collection of vertices for a partition. | Class | org.apache.giraph.comm.requests | Giraph |
SendWorkerAggregatorsRequest | Request to send partial aggregated values for current superstep (values which were computed by one worker's vertices) | Class | org.apache.giraph.comm.requests | Giraph |
SendWorkerDataRequest | Class | org.apache.giraph.comm.requests | Giraph | |
SendWorkerEdgesRequest | Send a collection of edges for a partition. | Class | org.apache.giraph.comm.requests | Giraph |
SendWorkerMessagesRequest | Send a collection of vertex messages for a partition. | Class | org.apache.giraph.comm.requests | Giraph |
SendWorkerOneMessageToManyRequest | Send a collection of ByteArrayOneMessageToManyIds messages to a worker. | Class | org.apache.giraph.comm.requests | Giraph |
SendWorkerToWorkerMessageRequest | Class | org.apache.giraph.comm.requests | Giraph | |
SendWorkerVerticesRequest | Class | org.apache.giraph.comm.requests | Giraph | |
SequentialFileMessageStore | Used for writing and reading collection of messages to the disk. | Class | org.apache.giraph.comm.messages.out_of_core | Giraph |
ServerData | Class | org.apache.giraph.comm | Giraph | |
SimpleMessageStore | Abstract class for MessageStore which allows any kind of object to hold messages for one vertex. | Class | org.apache.giraph.comm.messages | Giraph |
WorkerAggregatorRequestProcessor | Interface | org.apache.giraph.comm.aggregators | Giraph | |
WorkerClient | Interface | org.apache.giraph.comm | Giraph | |
WorkerClientRequestProcessor | Interface | org.apache.giraph.comm | Giraph | |
WorkerRequest | Interface | org.apache.giraph.comm.requests | Giraph | |
WorkerRequestReservedMap | Class | org.apache.giraph.comm.netty.handler | Giraph | |
WorkerRequestServerHandler | Class | org.apache.giraph.comm.netty.handler | Giraph | |
WorkerRequestServerHandler .Factory | Class | org.apache.giraph.comm.netty.handler.WorkerRequestServerHandler | Giraph | |
WorkerServer | Interface for message communication server. | Interface | org.apache.giraph.comm | Giraph |
WritableRequest | Class | org.apache.giraph.comm.requests | Giraph | |