Package | Description |
---|---|
org.apache.giraph.benchmark |
Package of benchmarks for performance testing and optimization
|
org.apache.giraph.block_app.framework.api |
Interfaces representing full API to the underlying graph processing system.
|
org.apache.giraph.block_app.framework.api.giraph |
Giraph implementation of graph processing system API used by
Blocks Framework.
|
org.apache.giraph.examples |
Package of Giraph examples.
|
org.apache.giraph.examples.scc |
Classes for Strongly Connected Components computation.
|
org.apache.giraph.graph |
Package of all the graph related objects, built on the
org.apache.bsp package.
|
org.apache.giraph.jython |
Jython integration.
|
org.apache.giraph.worker |
Package of all the worker related things
|
Modifier and Type | Class and Description |
---|---|
static class |
AggregatorsBenchmark.AggregatorsBenchmarkComputation
Vertex class for AggregatorsBenchmark
|
static class |
AggregatorsBenchmark.AggregatorsBenchmarkWorkerContext
WorkerContext class for AggregatorsBenchmark
|
class |
PageRankComputation
Implementation of PageRank in which vertex ids are ints, page rank values
are floats, and graph is unweighted.
|
static class |
RandomMessageBenchmark.RandomMessageBenchmarkWorkerContext
WorkerContext forRandomMessageBenchmark. |
static class |
RandomMessageBenchmark.RandomMessageComputation
Actual message computation (messaging in this case)
|
static class |
ReducersBenchmark.ReducersBenchmarkComputation
Vertex class for ReducersBenchmark
|
static class |
ReducersBenchmark.ReducersBenchmarkWorkerContext
WorkerContext class for ReducersBenchmark
|
class |
ShortestPathsComputation
Shortest paths algorithm.
|
class |
WeightedPageRankComputation
Implementation of Page Rank algorithm on a weighted graph.
|
Modifier and Type | Interface and Description |
---|---|
interface |
BlockWorkerApi<I extends org.apache.hadoop.io.WritableComparable>
Block computation API available for worker methods.
|
interface |
BlockWorkerContextApi<I extends org.apache.hadoop.io.WritableComparable>
Block computation API available for worker context methods.
|
interface |
BlockWorkerContextReceiveApi<I extends org.apache.hadoop.io.WritableComparable>
Block computation API available for worker context receive methods.
|
interface |
BlockWorkerContextSendApi<I extends org.apache.hadoop.io.WritableComparable,WM extends org.apache.hadoop.io.Writable>
Block computation API available for worker send methods.
|
interface |
BlockWorkerReceiveApi<I extends org.apache.hadoop.io.WritableComparable>
Block computation API available for worker receive methods.
|
interface |
BlockWorkerSendApi<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>
Block computation API available for worker send methods.
|
Modifier and Type | Class and Description |
---|---|
class |
BlockComputation
Computation that executes receiver and sender blocks passed
into BlockWorkerPieces.
|
class |
BlockWorkerContext
WorkerContext that executes receiver and sender blocks passed
into BlockWorkerPieces.
|
Modifier and Type | Class and Description |
---|---|
class |
AggregatorsTestComputation
Computation which uses aggrergators.
|
class |
BrachaTouegDeadlockComputation
This code demonstrates the Bracha Toueg deadlock detection algorithm.
|
class |
ConnectedComponentsComputation
Implementation of the HCC algorithm that identifies connected components and
assigns each vertex its "component identifier" (the smallest vertex id
in the component)
The idea behind the algorithm is very simple: propagate the smallest
vertex id along the edges to all vertices of a connected component.
|
class |
IdentityComputation<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>
User applications can subclass IdentityComputation, which
simply prints the results that have been read for testing IO related
jobs under any inputformat
|
class |
MaxComputation
Simple algorithm that computes the max value in the graph.
|
class |
PageRankWithKryoSimpleWritable
Copy of SimplePageRank, modified to test vertex/edge and
message values that derives from KryoSimpleWritable.
|
static class |
PageRankWithKryoSimpleWritable.PageRankWithKryoWorkerContext
Worker context used with
PageRankWithKryoSimpleWritable . |
class |
RandomWalkComputation<E extends org.apache.hadoop.io.Writable>
Base class for executing a random walk on a graph
|
class |
RandomWalkWithRestartComputation
Executes "RandomWalkWithRestart", a random walk on the graph which is biased
towards a source vertex.
|
class |
RandomWalkWorkerContext
Worker context for random walks.
|
static class |
SimpleCheckpoint.SimpleCheckpointComputation
Actual computation.
|
static class |
SimpleCheckpoint.SimpleCheckpointVertexWorkerContext
Worker context associated with
SimpleCheckpoint . |
class |
SimpleCombinerComputation
Test whether messages can go through a combiner.
|
class |
SimpleFailComputation
Vertex to allow unit testing of failure detection
|
class |
SimpleInDegreeCountComputation
Simple function to return the out degree for each vertex.
|
class |
SimpleLongDoubleDoubleDoubleIdentityComputation
A simple use of the Identity Vertex for taking care of Long, Double,
Double, Double type Inputformat Good for use with
io.LongDoubleDoubleAdjacencyListVertexInputFormat
|
class |
SimpleMasterComputeComputation
Demonstrates a computation with a centralized part implemented via a
MasterCompute.
|
static class |
SimpleMasterComputeComputation.SimpleMasterComputeWorkerContext
Worker context used with
SimpleMasterComputeComputation . |
class |
SimpleMsgComputation
Test whether messages can be sent and received by vertices.
|
class |
SimpleMutateGraphComputation
Vertex to allow unit testing of graph mutations.
|
static class |
SimpleMutateGraphComputation.SimpleMutateGraphVertexWorkerContext
Worker context used with
SimpleMutateGraphComputation . |
class |
SimpleOutDegreeCountComputation
Simple function to return the out degree for each vertex.
|
class |
SimplePageRankComputation
Demonstrates the basic Pregel PageRank implementation.
|
static class |
SimplePageRankComputation.SimplePageRankWorkerContext
Worker context used with
SimplePageRankComputation . |
class |
SimpleShortestPathsComputation
Demonstrates the basic Pregel shortest paths implementation.
|
class |
SimpleSuperstepComputation
Just a simple Vertex compute implementation that executes 3 supersteps, then
finishes.
|
class |
SimpleTriangleClosingComputation
Demonstrates triangle closing in simple,
unweighted graphs for Giraph.
|
static class |
SimpleVertexWithWorkerContext.EmitterWorkerContext
Example worker context to emit data as part of a superstep.
|
static class |
SimpleVertexWithWorkerContext.SimpleComputation
Actual vetex implementation
|
class |
TestComputationStateComputation
Vertex to test the local variables in Computation, and pre/postSuperstep
methods
|
static class |
TestComputationStateComputation.TestComputationStateWorkerContext
WorkerContext for TestComputationState
|
static class |
VerifyMessage.VerifyMessageComputation
Send and verify messages.
|
static class |
VerifyMessage.VerifyMessageComputation.VerifyMessageVertexWorkerContext
Worker context used with
VerifyMessage.VerifyMessageComputation . |
Modifier and Type | Class and Description |
---|---|
class |
SccComputation
Finds strongly connected components of the graph.
|
Modifier and Type | Interface and Description |
---|---|
interface |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
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. |
class |
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.
|
Modifier and Type | Class and Description |
---|---|
class |
JythonGiraphComputation<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>
The
Computation class for using
Jython with Giraph. |
Modifier and Type | Class and Description |
---|---|
class |
DefaultWorkerContext
A dummy implementation of
WorkerContext . |
class |
WorkerContext
WorkerContext allows for the execution of user code
on a per-worker basis.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.