See: Description
Interface | Description |
---|---|
Computation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable> |
Interface for an application for computation.
|
GraphTaskManager.CheckerIfWorkerShouldFailAfterException |
Interface to check if worker should fail after a thread gets an exception
|
JobProgressTrackerClient |
Wrapper around JobProgressTracker which retries to connect and swallows
exceptions so app wouldn't crash if something goes wrong with progress
reports.
|
MapperObserver |
Mapper observer
It can implement ContextSettable if it needs to access job counters.
|
Vertex<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Class which holds vertex id, data and edges.
|
VertexChanges<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Structure to hold all the possible graph mutations that can occur during a
superstep.
|
VertexResolver<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Handles all the situations that can arise upon creation/removal of
vertices and edges.
|
VertexValueCombiner<V extends org.apache.hadoop.io.Writable> |
When vertex values with the same vertex id are loaded, this
class specifies how to combine their vertex values.
|
Class | Description |
---|---|
AbstractComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable> |
See
Computation for explanation of the interface. |
AddressesAndPartitionsWritable |
Helper class to write descriptions of master, workers and partition owners
|
BasicComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable> |
Computation in which both incoming and outgoing message types are the same.
|
ByteValueVertex<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Special version of vertex that holds the value in raw byte form to save
memory.
|
ComputeCallable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable> |
Compute as many vertex partitions as possible.
|
DefaultVertex<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Class which holds vertex id, data and edges.
|
DefaultVertexResolver<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Default implementation of how to resolve vertex creation/removal, messages
to nonexistent vertices, etc.
|
DefaultVertexValueCombiner<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
The default vertex value combining approach is to simply keep the original
value.
|
FinishedSuperstepStats |
Immutable graph stats after the completion of a superstep
|
GiraphTransferRegulator |
Utility class to manage data transfers from
a local worker reading InputSplits.
|
GlobalStats |
Aggregated stats by the master.
|
GraphMapper<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
This mapper that will execute the BSP graph tasks alloted to this worker.
|
GraphState |
Immutable global state of the graph.
|
GraphTaskManager<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
The Giraph-specific business logic for a single BSP
compute node in whatever underlying type of cluster
our Giraph job will run on.
|
GraphTaskManager.FailWithEveryExceptionOccurred |
Class to use by default, where each exception causes job failure
|
JobProgressTrackerClientNoOp |
Class to use for JobProgressTracker client when progress shouldn't be
tracked or something goes wrong
|
OnlyIdVertex<I extends org.apache.hadoop.io.WritableComparable> |
Vertex which only contains ID.
|
RetryableJobProgressTrackerClient |
Wrapper around JobProgressTracker which retries to connect and swallows
exceptions so app wouldn't crash if something goes wrong with progress
reports.
|
TaskInfo |
Abstract class for information about any task - worker or master.
|
VertexEdgeCount |
Simple immutable structure for storing a final vertex and edge count.
|
VertexMutations<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
Structure to hold all the possible graph mutations that can occur during a
superstep.
|
Enum | Description |
---|---|
GraphFunctions |
Each compute node running on the underlying cluster
is marked with this enum to indicate the worker or
master task(s) it must perform during job runs.
|
GraphType |
Enumeration for a user graph type (IVEMM)
|
Language |
Programming language that something is implemented in
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.