Package | Description |
---|---|
org.apache.giraph.comm.requests |
Package for requests.
|
org.apache.giraph.io |
Input/Output related things.
|
org.apache.giraph.master.input |
Input related master classes
|
org.apache.giraph.worker |
Package of all the worker related things
|
Constructor and Description |
---|
AskForInputSplitRequest(InputType splitType,
int workerTaskId,
boolean isFirstSplit)
Constructor
|
ReplyWithInputSplitRequest(InputType splitType,
byte[] serializedInputSplit)
Constructor
|
Modifier and Type | Method and Description |
---|---|
static InputType |
InputType.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static InputType[] |
InputType.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
void |
MasterInputSplitsHandler.addSplits(InputType splitsType,
List<org.apache.hadoop.mapreduce.InputSplit> inputSplits,
GiraphInputFormat inputFormat)
Add splits
|
static org.apache.hadoop.mapreduce.Counter |
MasterInputSplitsHandler.getSplitFractionDoneTimestampCounter(InputType inputType,
double fraction,
org.apache.hadoop.mapreduce.Mapper.Context context)
Get counter
|
void |
MasterInputSplitsHandler.sendSplitTo(InputType splitType,
int workerTaskId,
boolean isFirstSplit)
Called after we receive a split request from some worker, should send
split back to it if available, or send it information that there is no
more available
|
Modifier and Type | Method and Description |
---|---|
InputType |
MappingInputSplitsCallable.getInputType() |
InputType |
VertexInputSplitsCallable.getInputType() |
abstract InputType |
InputSplitsCallable.getInputType()
Get input type
|
InputType |
EdgeInputSplitsCallable.getInputType() |
Modifier and Type | Method and Description |
---|---|
void |
WorkerInputSplitsHandler.receivedInputSplit(InputType splitType,
byte[] serializedInputSplit)
Called when an input split has been received from master, adding it to
the map
|
byte[] |
WorkerInputSplitsHandler.reserveInputSplit(InputType splitType,
boolean isFirstSplit)
Try to reserve an InputSplit for loading.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.