Package | Description |
---|---|
org.apache.giraph.comm.netty |
Package for netty implementations.
|
org.apache.giraph.comm.netty.handler |
Package for classes which handle requests and responses.
|
org.apache.giraph.master |
Package of all the master related things.
|
org.apache.giraph.worker |
Package of all the worker related things
|
Modifier and Type | Method and Description |
---|---|
void |
NettyClient.connectAllAddresses(Collection<? extends TaskInfo> tasks)
Connect to a collection of tasks servers
|
Constructor and Description |
---|
NettyClient(org.apache.hadoop.mapreduce.Mapper.Context context,
ImmutableClassesGiraphConfiguration conf,
TaskInfo myTaskInfo,
Thread.UncaughtExceptionHandler exceptionHandler)
Only constructor
|
NettyServer(ImmutableClassesGiraphConfiguration conf,
RequestServerHandler.Factory requestServerHandlerFactory,
TaskInfo myTaskInfo,
org.apache.hadoop.util.Progressable progressable,
SaslServerHandler.Factory saslServerHandlerFactory,
Thread.UncaughtExceptionHandler exceptionHandler)
Constructor for creating the server
|
NettyServer(ImmutableClassesGiraphConfiguration conf,
RequestServerHandler.Factory requestServerHandlerFactory,
TaskInfo myTaskInfo,
org.apache.hadoop.util.Progressable progressable,
Thread.UncaughtExceptionHandler exceptionHandler)
Constructor for creating the server
|
Modifier and Type | Method and Description |
---|---|
RequestServerHandler |
WorkerRequestServerHandler.Factory.newHandler(WorkerRequestReservedMap workerRequestReservedMap,
ImmutableClassesGiraphConfiguration conf,
TaskInfo myTaskInfo,
Thread.UncaughtExceptionHandler exceptionHandler) |
RequestServerHandler |
MasterRequestServerHandler.Factory.newHandler(WorkerRequestReservedMap workerRequestReservedMap,
ImmutableClassesGiraphConfiguration conf,
TaskInfo myTaskInfo,
Thread.UncaughtExceptionHandler exceptionHandler) |
RequestServerHandler |
RequestServerHandler.Factory.newHandler(WorkerRequestReservedMap workerRequestReservedMap,
ImmutableClassesGiraphConfiguration conf,
TaskInfo myTaskInfo,
Thread.UncaughtExceptionHandler exceptionHandler)
Create new
RequestServerHandler |
Constructor and Description |
---|
MasterRequestServerHandler(WorkerRequestReservedMap workerRequestReservedMap,
ImmutableClassesGiraphConfiguration conf,
TaskInfo myTaskInfo,
MasterGlobalCommHandler commHandler,
Thread.UncaughtExceptionHandler exceptionHandler,
FlowControl flowControl)
Constructor
|
RequestServerHandler(WorkerRequestReservedMap workerRequestReservedMap,
ImmutableClassesGiraphConfiguration conf,
TaskInfo myTaskInfo,
Thread.UncaughtExceptionHandler exceptionHandler)
Constructor
|
WorkerRequestServerHandler(ServerData<I,V,E> serverData,
WorkerRequestReservedMap workerRequestReservedMap,
ImmutableClassesGiraphConfiguration conf,
TaskInfo myTaskInfo,
Thread.UncaughtExceptionHandler exceptionHandler,
FlowControl flowControl)
Constructor with external server data
|
Modifier and Type | Class and Description |
---|---|
class |
MasterInfo
Information about the master that is sent to other workers.
|
Modifier and Type | Class and Description |
---|---|
class |
WorkerInfo
Information about a worker that is sent to the master and other workers.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.