Search Java Classes and Packages
#Org.apache.giraph.comm Classes and Interfaces - 103 results found.
| 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 | |