A B C D E F G H I L M N O P R S T V W

A

ACK - Static variable in class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage

Bracha-Toueg ACK message.

addParent(long) - Method in class org.apache.giraph.examples.scc.SccVertexValue

Adds a vertex id to the list of parent vertices.

addParent(Long) - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

add a parent id into the list of parents kept at the vertex side

aggregate(PageRankWithKryoSimpleWritable.VertexValue) - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.DoubleMaxWrapperAggregator

aggregate(PageRankWithKryoSimpleWritable.VertexValue) - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.DoubleMinWrapperAggregator

AggregatorsTestComputation - Class in org.apache.giraph.examples

Computation which uses aggrergators.

AggregatorsTestComputation() - Constructor for class org.apache.giraph.examples.AggregatorsTestComputation

AggregatorsTestComputation.AggregatorsTestMasterCompute - Class in org.apache.giraph.examples

Master compute which uses aggregators.

AggregatorsTestComputation.SimpleEdgeInputFormat - Class in org.apache.giraph.examples

Simple VertexInputFormat

AggregatorsTestComputation.SimpleEdgeReader - Class in org.apache.giraph.examples

Simple Edge Reader

AggregatorsTestComputation.SimpleVertexInputFormat - Class in org.apache.giraph.examples

Simple VertexInputFormat

AggregatorsTestComputation.SimpleVertexReader - Class in org.apache.giraph.examples

Simple VertexReader

AggregatorsTestMasterCompute() - Constructor for class org.apache.giraph.examples.AggregatorsTestComputation.AggregatorsTestMasterCompute

Algorithm - Annotation Type in org.apache.giraph.examples

This annotation should be used to annotate built-in algorithms.

B

BRACHA_TOUEG_DL_INITIATOR_ID - Static variable in class org.apache.giraph.examples.BrachaTouegDeadlockComputation

The deadlock detection initiator id

BrachaTouegDeadlockComputation - Class in org.apache.giraph.examples

This code demonstrates the Bracha Toueg deadlock detection algorithm.

BrachaTouegDeadlockComputation() - Constructor for class org.apache.giraph.examples.BrachaTouegDeadlockComputation

BrachaTouegDeadlockInputFormat - Class in org.apache.giraph.examples.io.formats

VertexInputFormat for the Bracha Toueg Deadlock Detection algorithm specified in JSON format.

BrachaTouegDeadlockInputFormat() - Constructor for class org.apache.giraph.examples.io.formats.BrachaTouegDeadlockInputFormat

BrachaTouegDeadlockMessage - Class in org.apache.giraph.examples.utils

Data sent via a message that includes the source vertex id.

BrachaTouegDeadlockMessage() - Constructor for class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage

Default empty constructor.

BrachaTouegDeadlockMessage(long, long) - Constructor for class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage

BrachaTouegDeadlockVertexValue - Class in org.apache.giraph.examples.utils

Vertex value used for the Bracha-Toueg Dealock algorithm

BrachaTouegDeadlockVertexValue() - Constructor for class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

Default constructor

BrachaTouegDeadlockVertexValue(HashMap<Long, ArrayList<Long>>) - Constructor for class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

Parametrized constructor

C

checkInputSpecs(Configuration) - Method in class org.apache.giraph.examples.AggregatorsTestComputation.SimpleEdgeInputFormat

clearParents() - Method in class org.apache.giraph.examples.scc.SccVertexValue

Clear parents list.

close() - Method in class org.apache.giraph.examples.GeneratedEdgeReader

close() - Method in class org.apache.giraph.examples.GeneratedVertexReader

close() - Method in class org.apache.giraph.examples.SimpleAggregatorWriter

compareTo(SimpleTriangleClosingComputation.Pair) - Method in class org.apache.giraph.examples.SimpleTriangleClosingComputation.Pair

Comparator to quickly sort by values

compute() - Method in class org.apache.giraph.examples.AggregatorsTestComputation.AggregatorsTestMasterCompute

compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.AggregatorsTestComputation

compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation

compute() - Method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterCompute

compute(Vertex<LongWritable, BrachaTouegDeadlockVertexValue, LongWritable>, Iterable<BrachaTouegDeadlockMessage>) - Method in class org.apache.giraph.examples.BrachaTouegDeadlockComputation

compute(Vertex<IntWritable, IntWritable, NullWritable>, Iterable<IntWritable>) - Method in class org.apache.giraph.examples.ConnectedComponentsComputation

Propagates the smallest vertex id to all neighbors.

compute(Vertex<I, V, E>, Iterable<M>) - Method in class org.apache.giraph.examples.IdentityComputation

compute(Vertex<IntWritable, IntWritable, NullWritable>, Iterable<IntWritable>) - Method in class org.apache.giraph.examples.MaxComputation

compute(Vertex<LongWritable, PageRankWithKryoSimpleWritable.VertexValue, PageRankWithKryoSimpleWritable.EdgeValue>, Iterable<PageRankWithKryoSimpleWritable.MessageValue>) - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable

compute(Vertex<LongWritable, DoubleWritable, E>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.RandomWalkComputation

compute() - Method in class org.apache.giraph.examples.RandomWalkVertexMasterCompute

compute(Vertex<LongWritable, SccVertexValue, NullWritable>, Iterable<LongWritable>) - Method in class org.apache.giraph.examples.scc.SccComputation

compute() - Method in class org.apache.giraph.examples.scc.SccPhaseMasterCompute

compute(Vertex<LongWritable, IntWritable, FloatWritable>, Iterable<FloatWritable>) - Method in class org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointComputation

compute(Vertex<LongWritable, IntWritable, FloatWritable>, Iterable<IntWritable>) - Method in class org.apache.giraph.examples.SimpleCombinerComputation

compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimpleFailComputation

compute(Vertex<LongWritable, LongWritable, DoubleWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimpleInDegreeCountComputation

compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimpleMasterComputeComputation

compute() - Method in class org.apache.giraph.examples.SimpleMasterComputeComputation.SimpleMasterCompute

compute(Vertex<LongWritable, IntWritable, FloatWritable>, Iterable<IntWritable>) - Method in class org.apache.giraph.examples.SimpleMsgComputation

compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimpleMutateGraphComputation

compute(Vertex<LongWritable, LongWritable, DoubleWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimpleOutDegreeCountComputation

compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimplePageRankComputation

compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimpleShortestPathsComputation

compute(Vertex<LongWritable, IntWritable, FloatWritable>, Iterable<IntWritable>) - Method in class org.apache.giraph.examples.SimpleSuperstepComputation

compute(Vertex<IntWritable, SimpleTriangleClosingComputation.IntArrayListWritable, NullWritable>, Iterable<IntWritable>) - Method in class org.apache.giraph.examples.SimpleTriangleClosingComputation

compute(Vertex<LongWritable, IntWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.SimpleVertexWithWorkerContext.SimpleComputation

compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.examples.TestComputationStateComputation

compute(Vertex<LongWritable, IntWritable, FloatWritable>, Iterable<VerifyMessage.VerifiableMessage>) - Method in class org.apache.giraph.examples.VerifyMessage.VerifyMessageComputation

ConnectedComponentsComputation - Class in org.apache.giraph.examples

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.

ConnectedComponentsComputation() - Constructor for class org.apache.giraph.examples.ConnectedComponentsComputation

CONVERGED - Static variable in class org.apache.giraph.examples.scc.SccPhaseMasterCompute

Flags whether a vertex converged in the Backward Traversal phase

createBlock(GiraphConfiguration) - Method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory

createEdgeReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.AggregatorsTestComputation.SimpleEdgeInputFormat

createInitialValue() - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.DoubleMaxWrapperAggregator

createInitialValue() - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.DoubleMinWrapperAggregator

createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.AggregatorsTestComputation.SimpleVertexInputFormat

createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.io.formats.BrachaTouegDeadlockInputFormat

createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.LongDoubleDoubleTextInputFormat

createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.LongDoubleFloatTextInputFormat

createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.LongDoubleNullTextInputFormat

createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.NormalizingLongDoubleDoubleTextInputFormat

createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoVertexInputFormat

createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.scc.SccLongLongNullTextInputFormat

createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankVertexInputFormat

createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.SimpleSuperstepComputation.SimpleSuperstepVertexInputFormat

createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankVertexOutputFormat

createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.examples.SimpleSuperstepComputation.SimpleSuperstepVertexOutputFormat

createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.examples.SimpleTextVertexOutputFormat

createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.examples.VertexWithDoubleValueDoubleEdgeTextOutputFormat

createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.examples.VertexWithDoubleValueNullEdgeTextOutputFormat

CTRL_IN_EDGE - Static variable in class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage

Bracha-Toueg control incoming-edge message

D

deactivate() - Method in class org.apache.giraph.examples.scc.SccVertexValue

Remove this vertex from the computation.

DEFAULT_READER_EDGES - Static variable in class org.apache.giraph.examples.GeneratedEdgeReader

Default edges produced by this reader

DONE - Static variable in class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage

Bracha-Toueg DONE message.

DoubleMaxWrapperAggregator() - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.DoubleMaxWrapperAggregator

DoubleMinWrapperAggregator() - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.DoubleMinWrapperAggregator

E

EdgeValue() - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.EdgeValue

Constructor

EdgeValue(Float) - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.EdgeValue

Constructor

emit(String) - Method in class org.apache.giraph.examples.SimpleVertexWithWorkerContext.EmitterWorkerContext

Write this string to the output stream.

EmitterWorkerContext() - Constructor for class org.apache.giraph.examples.SimpleVertexWithWorkerContext.EmitterWorkerContext

ENABLE_FAULT - Static variable in class org.apache.giraph.examples.SimpleCheckpoint

Should fault?

equals(Object) - Method in class org.apache.giraph.examples.SimpleTriangleClosingComputation.Pair

F

FAULT_FILE - Static variable in class org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointVertexWorkerContext

Filename to indicate whether a fault was found

FAULTING_SUPERSTEP - Static variable in class org.apache.giraph.examples.SimpleCheckpoint

Which superstep to cause the worker to fail

FAULTING_VERTEX_ID - Static variable in class org.apache.giraph.examples.SimpleCheckpoint

Vertex id to fault on

G

GeneratedEdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.examples

Used by GeneratedEdgeInputFormat to read some generated data

GeneratedEdgeReader() - Constructor for class org.apache.giraph.examples.GeneratedEdgeReader

Default constructor for reflection.

GeneratedVertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.examples

Used by GeneratedVertexInputFormat to read some generated data

GeneratedVertexReader() - Constructor for class org.apache.giraph.examples.GeneratedVertexReader

Default constructor for reflection.

get() - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.EdgeValue

Get edge value

get() - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.MessageValue

Get message value

get() - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.VertexValue

Get vertex value

get() - Method in class org.apache.giraph.examples.scc.SccVertexValue

Returns the vertex value.

getConf() - Method in class org.apache.giraph.examples.LongDoubleDoubleTextInputFormat

getConf() - Method in class org.apache.giraph.examples.LongDoubleFloatTextInputFormat

getConf() - Method in class org.apache.giraph.examples.LongDoubleNullTextInputFormat

getConf() - Method in class org.apache.giraph.examples.NormalizingLongDoubleDoubleTextInputFormat

getConf() - Method in class org.apache.giraph.examples.SimpleCheckpoint

getConf() - Method in class org.apache.giraph.examples.SimpleVertexWithWorkerContext

getCurrentEdge() - Method in class org.apache.giraph.examples.AggregatorsTestComputation.SimpleEdgeReader

getCurrentSourceId() - Method in class org.apache.giraph.examples.AggregatorsTestComputation.SimpleEdgeReader

getCurrentVertex() - Method in class org.apache.giraph.examples.AggregatorsTestComputation.SimpleVertexReader

getCurrentVertex() - Method in class org.apache.giraph.examples.LongDoubleDoubleTextInputFormat.LongDoubleDoubleDoubleVertexReader

getCurrentVertex() - Method in class org.apache.giraph.examples.LongDoubleFloatTextInputFormat.LongDoubleFloatVertexReader

getCurrentVertex() - Method in class org.apache.giraph.examples.LongDoubleNullTextInputFormat.LongDoubleNullDoubleVertexReader

getCurrentVertex() - Method in class org.apache.giraph.examples.NormalizingLongDoubleDoubleTextInputFormat.NormalizingLongDoubleDoubleDoubleVertexReader

getCurrentVertex() - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoVertexReader

getCurrentVertex() - Method in class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankVertexReader

getCurrentVertex() - Method in class org.apache.giraph.examples.SimpleSuperstepComputation.SimpleSuperstepVertexReader

getDanglingProbability() - Method in class org.apache.giraph.examples.RandomWalkComputation

Returns the cumulative probability from dangling vertices.

getEdgeCount() - Method in class org.apache.giraph.examples.SimpleMutateGraphComputation.SimpleMutateGraphVertexWorkerContext

getEdges(String[]) - Method in class org.apache.giraph.examples.scc.SccLongLongNullTextInputFormat.LongLongNullVertexReader

getEdgeValueClass(GiraphConfiguration) - Method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory

getEnableFault() - Method in class org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointVertexWorkerContext

getFilename() - Static method in class org.apache.giraph.examples.SimpleAggregatorWriter

getFinalMax() - Static method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoWorkerContext

getFinalMax() - Static method in class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankWorkerContext

getFinalMin() - Static method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoWorkerContext

getFinalMin() - Static method in class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankWorkerContext

getFinalSum() - Static method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterWorkerContext

getFinalSum() - Static method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoWorkerContext

getFinalSum() - Static method in class org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointVertexWorkerContext

getFinalSum() - Static method in class org.apache.giraph.examples.SimpleMasterComputeComputation.SimpleMasterComputeWorkerContext

getFinalSum() - Static method in class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankWorkerContext

getFinalSum() - Static method in class org.apache.giraph.examples.VerifyMessage.VerifyMessageComputation

getId(String[]) - Method in class org.apache.giraph.examples.scc.SccLongLongNullTextInputFormat.LongLongNullVertexReader

getIdWithInHoldAck() - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

getIdWithInHoldDone() - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

getKey() - Method in class org.apache.giraph.examples.SimpleTriangleClosingComputation.Pair

key getter

getMaxSupersteps() - Method in class org.apache.giraph.examples.RandomWalkWorkerContext

getNumOfRequests(LongWritable) - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

This function retrieves the number of pending requests for the specified tag.

getOrigEdgeCount() - Method in class org.apache.giraph.examples.SimpleMutateGraphComputation.SimpleMutateGraphVertexWorkerContext

getParents() - Method in class org.apache.giraph.examples.scc.SccVertexValue

Returns the list of parent vertices, i.e., vertices that are at the other end of incoming edges.

getParents() - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

getPhase(IntWritable) - Static method in class org.apache.giraph.examples.scc.SccPhaseMasterCompute

Helper function to convert from internal aggregated value to a Phases enumerator.

getPreviousCumulativeProbability() - Method in class org.apache.giraph.examples.RandomWalkComputation

Returns the cumulative probability from dangling vertices.

getProgress() - Method in class org.apache.giraph.examples.GeneratedEdgeReader

getProgress() - Method in class org.apache.giraph.examples.GeneratedVertexReader

getSenderId() - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage

getSplits(JobContext, int) - Method in class org.apache.giraph.examples.AggregatorsTestComputation.SimpleEdgeInputFormat

getSupersteps() - Method in class org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointVertexWorkerContext

getTeleportationProbability() - Method in class org.apache.giraph.examples.RandomWalkWorkerContext

getType() - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage

getValue(String[]) - Method in class org.apache.giraph.examples.scc.SccLongLongNullTextInputFormat.LongLongNullVertexReader

getValue() - Method in class org.apache.giraph.examples.SimpleTriangleClosingComputation.Pair

value getter

getVertexCount() - Method in class org.apache.giraph.examples.SimpleMutateGraphComputation.SimpleMutateGraphVertexWorkerContext

getVertexIDClass(GiraphConfiguration) - Method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory

getVertexValueClass(GiraphConfiguration) - Method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory

getWorkerContextValueClass(GiraphConfiguration) - Method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory

GRANT - Static variable in class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage

Bracha-Toueg GRANT message.

H

hashCode() - Method in class org.apache.giraph.examples.SimpleTriangleClosingComputation.Pair

hasPendingRequests() - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

I

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> - Class in org.apache.giraph.examples

User applications can subclass IdentityComputation, which simply prints the results that have been read for testing IO related jobs under any inputformat

IdentityComputation() - Constructor for class org.apache.giraph.examples.IdentityComputation

increaseEdgesRemoved() - Method in class org.apache.giraph.examples.SimpleMutateGraphComputation.SimpleMutateGraphVertexWorkerContext

Increase the number of edges removed by one.

initialize() - Method in class org.apache.giraph.examples.AggregatorsTestComputation.AggregatorsTestMasterCompute

initialize() - Method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterCompute

initialize(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.GeneratedEdgeReader

initialize(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.examples.GeneratedVertexReader

initialize() - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoMasterCompute

initialize() - Method in class org.apache.giraph.examples.RandomWalkVertexMasterCompute

initialize() - Method in class org.apache.giraph.examples.scc.SccPhaseMasterCompute

initialize(Mapper.Context, long) - Method in class org.apache.giraph.examples.SimpleAggregatorWriter

initialize() - Method in class org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointVertexMasterCompute

initialize() - Method in class org.apache.giraph.examples.SimpleMasterComputeComputation.SimpleMasterCompute

initialize() - Method in class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankMasterCompute

initialize() - Method in class org.apache.giraph.examples.VerifyMessage.VerifyMessageMasterCompute

initialProbability() - Method in class org.apache.giraph.examples.RandomWalkComputation

Compute an initial probability value for the vertex.

inputSplit - Variable in class org.apache.giraph.examples.GeneratedEdgeReader

The input split from initialize().

inputSplit - Variable in class org.apache.giraph.examples.GeneratedVertexReader

The input split from initialize().

IntArrayListWritable() - Constructor for class org.apache.giraph.examples.SimpleTriangleClosingComputation.IntArrayListWritable

Default constructor for reflection

INVALID_ID - Static variable in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

Invalid ID

isActive() - Method in class org.apache.giraph.examples.scc.SccVertexValue

Indicates whether the vertex was removed in a Trimming phase.

isFree() - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

isNotified() - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

isSource(long) - Method in class org.apache.giraph.examples.RandomWalkWorkerContext

Checks if a vertex is a source.

isWaitingForMessage(Long) - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

L

LongDoubleDoubleDoubleVertexReader() - Constructor for class org.apache.giraph.examples.LongDoubleDoubleTextInputFormat.LongDoubleDoubleDoubleVertexReader

LongDoubleDoubleTextInputFormat - Class in org.apache.giraph.examples

Simple text-based VertexInputFormat for unweighted graphs with long ids.

LongDoubleDoubleTextInputFormat() - Constructor for class org.apache.giraph.examples.LongDoubleDoubleTextInputFormat

LongDoubleDoubleTextInputFormat.LongDoubleDoubleDoubleVertexReader - Class in org.apache.giraph.examples

Vertex reader associated with LongDoubleDoubleTextInputFormat.

LongDoubleFloatTextInputFormat - Class in org.apache.giraph.examples

Simple text-based VertexInputFormat for weighted graphs with long ids.

LongDoubleFloatTextInputFormat() - Constructor for class org.apache.giraph.examples.LongDoubleFloatTextInputFormat

LongDoubleFloatTextInputFormat.LongDoubleFloatVertexReader - Class in org.apache.giraph.examples

Vertex reader associated with LongDoubleDoubleTextInputFormat.

LongDoubleFloatVertexReader() - Constructor for class org.apache.giraph.examples.LongDoubleFloatTextInputFormat.LongDoubleFloatVertexReader

LongDoubleNullDoubleVertexReader() - Constructor for class org.apache.giraph.examples.LongDoubleNullTextInputFormat.LongDoubleNullDoubleVertexReader

LongDoubleNullTextInputFormat - Class in org.apache.giraph.examples

Input format for unweighted graphs with long ids.

LongDoubleNullTextInputFormat() - Constructor for class org.apache.giraph.examples.LongDoubleNullTextInputFormat

LongDoubleNullTextInputFormat.LongDoubleNullDoubleVertexReader - Class in org.apache.giraph.examples

Vertex reader associated with LongDoubleNullTextInputFormat.

LongLongNullVertexReader() - Constructor for class org.apache.giraph.examples.scc.SccLongLongNullTextInputFormat.LongLongNullVertexReader

M

main(String[]) - Static method in class org.apache.giraph.examples.SimpleCheckpoint

Executable from the command line.

main(String[]) - Static method in class org.apache.giraph.examples.SimpleVertexWithWorkerContext

Executable from the command line.

MAX_SUPERSTEPS - Static variable in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable

Number of supersteps for this test

MAX_SUPERSTEPS - Static variable in class org.apache.giraph.examples.SimplePageRankComputation

Number of supersteps for this test

MaxComputation - Class in org.apache.giraph.examples

Simple algorithm that computes the max value in the graph.

MaxComputation() - Constructor for class org.apache.giraph.examples.MaxComputation

MessageValue() - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.MessageValue

Constructor

MessageValue(Double) - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.MessageValue

Constructor

N

NEW_MAXIMUM - Static variable in class org.apache.giraph.examples.scc.SccPhaseMasterCompute

Flags whether a new maximum was found in the Forward Traversal phase

nextEdge() - Method in class org.apache.giraph.examples.AggregatorsTestComputation.SimpleEdgeReader

nextVertex() - Method in class org.apache.giraph.examples.AggregatorsTestComputation.SimpleVertexReader

nextVertex() - Method in class org.apache.giraph.examples.LongDoubleDoubleTextInputFormat.LongDoubleDoubleDoubleVertexReader

nextVertex() - Method in class org.apache.giraph.examples.LongDoubleFloatTextInputFormat.LongDoubleFloatVertexReader

nextVertex() - Method in class org.apache.giraph.examples.LongDoubleNullTextInputFormat.LongDoubleNullDoubleVertexReader

nextVertex() - Method in class org.apache.giraph.examples.NormalizingLongDoubleDoubleTextInputFormat.NormalizingLongDoubleDoubleDoubleVertexReader

nextVertex() - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoVertexReader

nextVertex() - Method in class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankVertexReader

nextVertex() - Method in class org.apache.giraph.examples.SimpleSuperstepComputation.SimpleSuperstepVertexReader

NormalizingLongDoubleDoubleDoubleVertexReader() - Constructor for class org.apache.giraph.examples.NormalizingLongDoubleDoubleTextInputFormat.NormalizingLongDoubleDoubleDoubleVertexReader

NormalizingLongDoubleDoubleTextInputFormat - Class in org.apache.giraph.examples

Simple text-based VertexInputFormat for unweighted graphs with long ids.

NormalizingLongDoubleDoubleTextInputFormat() - Constructor for class org.apache.giraph.examples.NormalizingLongDoubleDoubleTextInputFormat

NormalizingLongDoubleDoubleTextInputFormat.NormalizingLongDoubleDoubleDoubleVertexReader - Class in org.apache.giraph.examples

Vertex reader associated with LongDoubleDoubleTextInputFormat.

NOTIFY - Static variable in class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage

Bracha-Toueg NOTICE message.

NUM_COMPUTE_THREADS - Static variable in class org.apache.giraph.examples.TestComputationStateComputation

How many compute threads to use in the test

NUM_PARTITIONS - Static variable in class org.apache.giraph.examples.TestComputationStateComputation

How many partitions to have

NUM_VERTICES - Static variable in class org.apache.giraph.examples.TestComputationStateComputation

How many vertices to create for the test

numSources() - Method in class org.apache.giraph.examples.RandomWalkWorkerContext

O

org.apache.giraph.examples - package org.apache.giraph.examples

Package of Giraph examples.

org.apache.giraph.examples.block_app - package org.apache.giraph.examples.block_app

Package of Giraph examples for Block Applications.

org.apache.giraph.examples.io.formats - package org.apache.giraph.examples.io.formats

IO classes for Giraph examples.

org.apache.giraph.examples.scc - package org.apache.giraph.examples.scc

Classes for Strongly Connected Components computation.

org.apache.giraph.examples.utils - package org.apache.giraph.examples.utils

Utils for Giraph examples.

OUTPUTDIR - Static variable in class org.apache.giraph.examples.SimpleVertexWithWorkerContext

Directory name of where to write.

P

PageRankComputation - Class in org.apache.giraph.examples

The PageRank algorithm, with uniform transition probabilities on the edges http://en.wikipedia.org/wiki/PageRank

PageRankComputation() - Constructor for class org.apache.giraph.examples.PageRankComputation

PageRankWithKryoMasterCompute() - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoMasterCompute

PageRankWithKryoSimpleWritable - Class in org.apache.giraph.examples

Copy of SimplePageRank, modified to test vertex/edge and message values that derives from KryoSimpleWritable.

PageRankWithKryoSimpleWritable() - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable

PageRankWithKryoSimpleWritable.DoubleMaxWrapperAggregator - Class in org.apache.giraph.examples

Aggregator for getting max double value

PageRankWithKryoSimpleWritable.DoubleMinWrapperAggregator - Class in org.apache.giraph.examples

Aggregator for getting min double value.

PageRankWithKryoSimpleWritable.EdgeValue - Class in org.apache.giraph.examples

Creating a custom edge value class to force kryo to register with a new ID.

PageRankWithKryoSimpleWritable.MessageValue - Class in org.apache.giraph.examples

Creating a custom message value class to force kryo to register with a new ID.

PageRankWithKryoSimpleWritable.PageRankWithKryoMasterCompute - Class in org.apache.giraph.examples

Master compute associated with PageRankWithKryoSimpleWritable.

PageRankWithKryoSimpleWritable.PageRankWithKryoVertexInputFormat - Class in org.apache.giraph.examples

VertexInputFormat that supports PageRankWithKryoSimpleWritable

PageRankWithKryoSimpleWritable.PageRankWithKryoVertexReader - Class in org.apache.giraph.examples

Simple VertexReader that supports PageRankWithKryoSimpleWritable

PageRankWithKryoSimpleWritable.PageRankWithKryoWorkerContext - Class in org.apache.giraph.examples

Worker context used with PageRankWithKryoSimpleWritable.

PageRankWithKryoSimpleWritable.VertexValue - Class in org.apache.giraph.examples

Creating a custom vertex value class to force kryo to register with a new ID.

PageRankWithKryoVertexInputFormat() - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoVertexInputFormat

PageRankWithKryoVertexReader() - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoVertexReader

PageRankWithKryoWorkerContext() - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoWorkerContext

Pair(IntWritable, Integer) - Constructor for class org.apache.giraph.examples.SimpleTriangleClosingComputation.Pair

Constructor

PHASE - Static variable in class org.apache.giraph.examples.scc.SccPhaseMasterCompute

Aggregator that stores the current phase

postApplication() - Method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterWorkerContext

postApplication() - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoWorkerContext

postApplication() - Method in class org.apache.giraph.examples.RandomWalkWorkerContext

postApplication() - Method in class org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointVertexWorkerContext

postApplication() - Method in class org.apache.giraph.examples.SimpleMasterComputeComputation.SimpleMasterComputeWorkerContext

postApplication() - Method in class org.apache.giraph.examples.SimpleMutateGraphComputation.SimpleMutateGraphVertexWorkerContext

postApplication() - Method in class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankWorkerContext

postApplication() - Method in class org.apache.giraph.examples.SimpleVertexWithWorkerContext.EmitterWorkerContext

postApplication() - Method in class org.apache.giraph.examples.VerifyMessage.VerifyMessageComputation.VerifyMessageVertexWorkerContext

postSuperstep() - Method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterWorkerContext

postSuperstep() - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoWorkerContext

postSuperstep() - Method in class org.apache.giraph.examples.RandomWalkWorkerContext

postSuperstep() - Method in class org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointVertexWorkerContext

postSuperstep() - Method in class org.apache.giraph.examples.SimpleMasterComputeComputation.SimpleMasterComputeWorkerContext

postSuperstep() - Method in class org.apache.giraph.examples.SimpleMutateGraphComputation.SimpleMutateGraphVertexWorkerContext

postSuperstep() - Method in class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankWorkerContext

postSuperstep() - Method in class org.apache.giraph.examples.SimpleVertexWithWorkerContext.EmitterWorkerContext

postSuperstep() - Method in class org.apache.giraph.examples.TestComputationStateComputation

postSuperstep() - Method in class org.apache.giraph.examples.TestComputationStateComputation.TestComputationStateWorkerContext

postSuperstep() - Method in class org.apache.giraph.examples.VerifyMessage.VerifyMessageComputation.VerifyMessageVertexWorkerContext

preApplication() - Method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterWorkerContext

preApplication() - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoWorkerContext

preApplication() - Method in class org.apache.giraph.examples.RandomWalkWorkerContext

preApplication() - Method in class org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointVertexWorkerContext

preApplication() - Method in class org.apache.giraph.examples.SimpleMasterComputeComputation.SimpleMasterComputeWorkerContext

preApplication() - Method in class org.apache.giraph.examples.SimpleMutateGraphComputation.SimpleMutateGraphVertexWorkerContext

preApplication() - Method in class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankWorkerContext

preApplication() - Method in class org.apache.giraph.examples.SimpleVertexWithWorkerContext.EmitterWorkerContext

preApplication() - Method in class org.apache.giraph.examples.VerifyMessage.VerifyMessageComputation.VerifyMessageVertexWorkerContext

preprocessLine(Text) - Method in class org.apache.giraph.examples.scc.SccLongLongNullTextInputFormat.LongLongNullVertexReader

preSuperstep() - Method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterWorkerContext

preSuperstep() - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.PageRankWithKryoWorkerContext

preSuperstep() - Method in class org.apache.giraph.examples.RandomWalkWorkerContext

preSuperstep() - Method in class org.apache.giraph.examples.scc.SccComputation

preSuperstep() - Method in class org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointVertexWorkerContext

preSuperstep() - Method in class org.apache.giraph.examples.SimpleMasterComputeComputation.SimpleMasterComputeWorkerContext

preSuperstep() - Method in class org.apache.giraph.examples.SimpleMutateGraphComputation.SimpleMutateGraphVertexWorkerContext

preSuperstep() - Method in class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankWorkerContext

preSuperstep() - Method in class org.apache.giraph.examples.SimpleVertexWithWorkerContext.EmitterWorkerContext

preSuperstep() - Method in class org.apache.giraph.examples.TestComputationStateComputation

preSuperstep() - Method in class org.apache.giraph.examples.TestComputationStateComputation.TestComputationStateWorkerContext

preSuperstep() - Method in class org.apache.giraph.examples.VerifyMessage.VerifyMessageComputation.VerifyMessageVertexWorkerContext

R

RandomWalkComputation<E extends org.apache.hadoop.io.Writable> - Class in org.apache.giraph.examples

Base class for executing a random walk on a graph

RandomWalkComputation() - Constructor for class org.apache.giraph.examples.RandomWalkComputation

RandomWalkVertexMasterCompute - Class in org.apache.giraph.examples

Master compute associated with RandomWalkComputation.

RandomWalkVertexMasterCompute() - Constructor for class org.apache.giraph.examples.RandomWalkVertexMasterCompute

RandomWalkWithRestartComputation - Class in org.apache.giraph.examples

Executes "RandomWalkWithRestart", a random walk on the graph which is biased towards a source vertex.

RandomWalkWithRestartComputation() - Constructor for class org.apache.giraph.examples.RandomWalkWithRestartComputation

RandomWalkWorkerContext - Class in org.apache.giraph.examples

Worker context for random walks.

RandomWalkWorkerContext() - Constructor for class org.apache.giraph.examples.RandomWalkWorkerContext

READER_VERTICES - Static variable in class org.apache.giraph.examples.GeneratedVertexReader

Vertices produced by this reader

readFields(DataInput) - Method in class org.apache.giraph.examples.scc.SccVertexValue

readFields(DataInput) - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage

readFields(DataInput) - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

readFields(DataInput) - Method in class org.apache.giraph.examples.VerifyMessage.VerifiableMessage

receivedMessage(Long, Long) - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

Each time a message is received, it has to be removed from the queue that keeps track of the waited messages.

recompute(Vertex<LongWritable, DoubleWritable, NullWritable>, Iterable<DoubleWritable>, double) - Method in class org.apache.giraph.examples.PageRankComputation

recompute(Vertex<LongWritable, DoubleWritable, E>, Iterable<DoubleWritable>, double) - Method in class org.apache.giraph.examples.RandomWalkComputation

Perform a single step of a random walk computation.

recompute(Vertex<LongWritable, DoubleWritable, DoubleWritable>, Iterable<DoubleWritable>, double) - Method in class org.apache.giraph.examples.RandomWalkWithRestartComputation

recordsRead - Variable in class org.apache.giraph.examples.GeneratedEdgeReader

Records read so far

recordsRead - Variable in class org.apache.giraph.examples.GeneratedVertexReader

Records read so far

removeRequest(LongWritable, LongWritable) - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

remove the expected request from the edge on which the message arrived

REVERSE_ID_ORDER - Static variable in class org.apache.giraph.examples.GeneratedVertexReader

Reverse the order of the vertices?

reverseIdOrder - Variable in class org.apache.giraph.examples.GeneratedVertexReader

Reverse the id order?

run(String[]) - Method in class org.apache.giraph.examples.SimpleCheckpoint

run(String[]) - Method in class org.apache.giraph.examples.SimpleVertexWithWorkerContext

S

SccComputation - Class in org.apache.giraph.examples.scc

Finds strongly connected components of the graph.

SccComputation() - Constructor for class org.apache.giraph.examples.scc.SccComputation

SccLongLongNullTextInputFormat - Class in org.apache.giraph.examples.scc

Simple text-based VertexInputFormat for unweighted graphs with long ids.

SccLongLongNullTextInputFormat() - Constructor for class org.apache.giraph.examples.scc.SccLongLongNullTextInputFormat

SccLongLongNullTextInputFormat.LongLongNullVertexReader - Class in org.apache.giraph.examples.scc

Vertex reader associated with SccLongLongNullTextInputFormat.

SccPhaseMasterCompute - Class in org.apache.giraph.examples.scc

This master compute keeps track of what phase is being currently executed by the Strongly Connected Components computation.

SccPhaseMasterCompute() - Constructor for class org.apache.giraph.examples.scc.SccPhaseMasterCompute

SccPhaseMasterCompute.Phases - Enum in org.apache.giraph.examples.scc

Enumerates the possible phases of the algorithm.

SccVertexValue - Class in org.apache.giraph.examples.scc

Vertex value for the Strongly Connected Components algorithm.

SccVertexValue() - Constructor for class org.apache.giraph.examples.scc.SccVertexValue

Public constructor required for serialization.

SccVertexValue(long) - Constructor for class org.apache.giraph.examples.scc.SccVertexValue

Constructor

set(Float) - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.EdgeValue

Set edge value

set(Double) - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.MessageValue

Set message value

set(Double) - Method in class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.VertexValue

Set vertex value.

set(long) - Method in class org.apache.giraph.examples.scc.SccVertexValue

Sets the vertex value.

setClass() - Method in class org.apache.giraph.examples.SimpleTriangleClosingComputation.IntArrayListWritable

Set storage type for this ArrayListWritable

setConf(ImmutableClassesGiraphConfiguration<LongWritable, DoubleWritable, DoubleWritable>) - Method in class org.apache.giraph.examples.LongDoubleDoubleTextInputFormat

setConf(ImmutableClassesGiraphConfiguration<LongWritable, DoubleWritable, FloatWritable>) - Method in class org.apache.giraph.examples.LongDoubleFloatTextInputFormat

setConf(ImmutableClassesGiraphConfiguration<LongWritable, DoubleWritable, NullWritable>) - Method in class org.apache.giraph.examples.LongDoubleNullTextInputFormat

setConf(ImmutableClassesGiraphConfiguration<LongWritable, DoubleWritable, DoubleWritable>) - Method in class org.apache.giraph.examples.NormalizingLongDoubleDoubleTextInputFormat

setConf(Configuration) - Method in class org.apache.giraph.examples.SimpleCheckpoint

setConf(Configuration) - Method in class org.apache.giraph.examples.SimpleVertexWithWorkerContext

setFinalSum(double) - Static method in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterWorkerContext

setFinalSum(double) - Static method in class org.apache.giraph.examples.SimpleMasterComputeComputation.SimpleMasterComputeWorkerContext

setFree() - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

the vertex is free from deadlocks

setIdWithInHoldAck(Long) - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

setIdWithInHoldDone(Long) - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

setNotified() - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

the vertex got a notification

SimpleAggregatorWriter - Class in org.apache.giraph.examples

This is a simple example for an aggregator writer.

SimpleAggregatorWriter() - Constructor for class org.apache.giraph.examples.SimpleAggregatorWriter

SimpleCheckpoint - Class in org.apache.giraph.examples

An example that simply uses its id, value, and edges to compute new data every iteration to verify that checkpoint restarting works.

SimpleCheckpoint() - Constructor for class org.apache.giraph.examples.SimpleCheckpoint

SimpleCheckpoint.SimpleCheckpointComputation - Class in org.apache.giraph.examples

Actual computation.

SimpleCheckpoint.SimpleCheckpointVertexMasterCompute - Class in org.apache.giraph.examples

Master compute associated with SimpleCheckpoint.

SimpleCheckpoint.SimpleCheckpointVertexWorkerContext - Class in org.apache.giraph.examples

Worker context associated with SimpleCheckpoint.

SimpleCheckpointComputation() - Constructor for class org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointComputation

SimpleCheckpointVertexMasterCompute() - Constructor for class org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointVertexMasterCompute

SimpleCheckpointVertexWorkerContext() - Constructor for class org.apache.giraph.examples.SimpleCheckpoint.SimpleCheckpointVertexWorkerContext

SimpleCombinerComputation - Class in org.apache.giraph.examples

Test whether messages can go through a combiner.

SimpleCombinerComputation() - Constructor for class org.apache.giraph.examples.SimpleCombinerComputation

SimpleComputation() - Constructor for class org.apache.giraph.examples.SimpleVertexWithWorkerContext.SimpleComputation

SimpleEdgeInputFormat() - Constructor for class org.apache.giraph.examples.AggregatorsTestComputation.SimpleEdgeInputFormat

SimpleEdgeReader() - Constructor for class org.apache.giraph.examples.AggregatorsTestComputation.SimpleEdgeReader

SimpleFailComputation - Class in org.apache.giraph.examples

Vertex to allow unit testing of failure detection

SimpleFailComputation() - Constructor for class org.apache.giraph.examples.SimpleFailComputation

SimpleInDegreeCountComputation - Class in org.apache.giraph.examples

Simple function to return the out degree for each vertex.

SimpleInDegreeCountComputation() - Constructor for class org.apache.giraph.examples.SimpleInDegreeCountComputation

SimpleLongDoubleDoubleDoubleIdentityComputation - Class in org.apache.giraph.examples

A simple use of the Identity Vertex for taking care of Long, Double, Double, Double type Inputformat Good for use with io.LongDoubleDoubleAdjacencyListVertexInputFormat

SimpleLongDoubleDoubleDoubleIdentityComputation() - Constructor for class org.apache.giraph.examples.SimpleLongDoubleDoubleDoubleIdentityComputation

SimpleMasterCompute() - Constructor for class org.apache.giraph.examples.SimpleMasterComputeComputation.SimpleMasterCompute

SimpleMasterComputeComputation - Class in org.apache.giraph.examples

Demonstrates a computation with a centralized part implemented via a MasterCompute.

SimpleMasterComputeComputation() - Constructor for class org.apache.giraph.examples.SimpleMasterComputeComputation

SimpleMasterComputeComputation.SimpleMasterCompute - Class in org.apache.giraph.examples

MasterCompute used with SimpleMasterComputeComputation.

SimpleMasterComputeComputation.SimpleMasterComputeWorkerContext - Class in org.apache.giraph.examples

Worker context used with SimpleMasterComputeComputation.

SimpleMasterComputeWorkerContext() - Constructor for class org.apache.giraph.examples.SimpleMasterComputeComputation.SimpleMasterComputeWorkerContext

SimpleMigrationMasterBlockFactory - Class in org.apache.giraph.examples.block_app

Demonstrates using migration library for Blocks Framework, as an drop-in replacement, without any changes.

SimpleMigrationMasterBlockFactory() - Constructor for class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory

SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation - Class in org.apache.giraph.examples.block_app

Demonstrates a computation with a centralized part implemented via a MasterCompute.

SimpleMigrationMasterBlockFactory.SimpleMigrationMasterCompute - Class in org.apache.giraph.examples.block_app

MasterCompute used with SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation.

SimpleMigrationMasterBlockFactory.SimpleMigrationMasterWorkerContext - Class in org.apache.giraph.examples.block_app

Worker context used with SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation.

SimpleMigrationMasterComputation() - Constructor for class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation

SimpleMigrationMasterCompute() - Constructor for class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterCompute

SimpleMigrationMasterWorkerContext() - Constructor for class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterWorkerContext

SimpleMsgComputation - Class in org.apache.giraph.examples

Test whether messages can be sent and received by vertices.

SimpleMsgComputation() - Constructor for class org.apache.giraph.examples.SimpleMsgComputation

SimpleMutateGraphComputation - Class in org.apache.giraph.examples

Vertex to allow unit testing of graph mutations.

SimpleMutateGraphComputation() - Constructor for class org.apache.giraph.examples.SimpleMutateGraphComputation

SimpleMutateGraphComputation.SimpleMutateGraphVertexWorkerContext - Class in org.apache.giraph.examples

Worker context used with SimpleMutateGraphComputation.

SimpleMutateGraphVertexWorkerContext() - Constructor for class org.apache.giraph.examples.SimpleMutateGraphComputation.SimpleMutateGraphVertexWorkerContext

SimpleOutDegreeCountComputation - Class in org.apache.giraph.examples

Simple function to return the out degree for each vertex.

SimpleOutDegreeCountComputation() - Constructor for class org.apache.giraph.examples.SimpleOutDegreeCountComputation

SimplePageRankComputation - Class in org.apache.giraph.examples

Demonstrates the basic Pregel PageRank implementation.

SimplePageRankComputation() - Constructor for class org.apache.giraph.examples.SimplePageRankComputation

SimplePageRankComputation.SimplePageRankMasterCompute - Class in org.apache.giraph.examples

Master compute associated with SimplePageRankComputation.

SimplePageRankComputation.SimplePageRankVertexInputFormat - Class in org.apache.giraph.examples

Simple VertexInputFormat that supports SimplePageRankComputation

SimplePageRankComputation.SimplePageRankVertexOutputFormat - Class in org.apache.giraph.examples

Simple VertexOutputFormat that supports SimplePageRankComputation

SimplePageRankComputation.SimplePageRankVertexOutputFormat.SimplePageRankVertexWriter - Class in org.apache.giraph.examples

Simple VertexWriter that supports SimplePageRankComputation

SimplePageRankComputation.SimplePageRankVertexReader - Class in org.apache.giraph.examples

Simple VertexReader that supports SimplePageRankComputation

SimplePageRankComputation.SimplePageRankWorkerContext - Class in org.apache.giraph.examples

Worker context used with SimplePageRankComputation.

SimplePageRankMasterCompute() - Constructor for class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankMasterCompute

SimplePageRankVertexInputFormat() - Constructor for class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankVertexInputFormat

SimplePageRankVertexOutputFormat() - Constructor for class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankVertexOutputFormat

SimplePageRankVertexReader() - Constructor for class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankVertexReader

SimplePageRankVertexWriter() - Constructor for class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankVertexOutputFormat.SimplePageRankVertexWriter

SimplePageRankWorkerContext() - Constructor for class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankWorkerContext

SimpleShortestPathsComputation - Class in org.apache.giraph.examples

Demonstrates the basic Pregel shortest paths implementation.

SimpleShortestPathsComputation() - Constructor for class org.apache.giraph.examples.SimpleShortestPathsComputation

SimpleSuperstepComputation - Class in org.apache.giraph.examples

Just a simple Vertex compute implementation that executes 3 supersteps, then finishes.

SimpleSuperstepComputation() - Constructor for class org.apache.giraph.examples.SimpleSuperstepComputation

SimpleSuperstepComputation.SimpleSuperstepVertexInputFormat - Class in org.apache.giraph.examples

Simple VertexInputFormat that supports SimpleSuperstepComputation

SimpleSuperstepComputation.SimpleSuperstepVertexOutputFormat - Class in org.apache.giraph.examples

Simple VertexOutputFormat that supports SimpleSuperstepComputation

SimpleSuperstepComputation.SimpleSuperstepVertexOutputFormat.SimpleSuperstepVertexWriter - Class in org.apache.giraph.examples

Simple VertexWriter that supports SimpleSuperstepComputation

SimpleSuperstepComputation.SimpleSuperstepVertexReader - Class in org.apache.giraph.examples

Simple VertexReader that supports SimpleSuperstepComputation

SimpleSuperstepVertexInputFormat() - Constructor for class org.apache.giraph.examples.SimpleSuperstepComputation.SimpleSuperstepVertexInputFormat

SimpleSuperstepVertexOutputFormat() - Constructor for class org.apache.giraph.examples.SimpleSuperstepComputation.SimpleSuperstepVertexOutputFormat

SimpleSuperstepVertexReader() - Constructor for class org.apache.giraph.examples.SimpleSuperstepComputation.SimpleSuperstepVertexReader

SimpleSuperstepVertexWriter() - Constructor for class org.apache.giraph.examples.SimpleSuperstepComputation.SimpleSuperstepVertexOutputFormat.SimpleSuperstepVertexWriter

SimpleTextVertexOutputFormat - Class in org.apache.giraph.examples

Simple text based vertex output format example.

SimpleTextVertexOutputFormat() - Constructor for class org.apache.giraph.examples.SimpleTextVertexOutputFormat

SimpleTriangleClosingComputation - Class in org.apache.giraph.examples

Demonstrates triangle closing in simple, unweighted graphs for Giraph.

SimpleTriangleClosingComputation() - Constructor for class org.apache.giraph.examples.SimpleTriangleClosingComputation

SimpleTriangleClosingComputation.IntArrayListWritable - Class in org.apache.giraph.examples

Utility class for delivering the array of vertices THIS vertex should connect with to close triangles with neighbors

SimpleTriangleClosingComputation.Pair - Class in org.apache.giraph.examples

Quick, immutable K,V storage for sorting in tree set

SimpleVertexInputFormat() - Constructor for class org.apache.giraph.examples.AggregatorsTestComputation.SimpleVertexInputFormat

SimpleVertexReader() - Constructor for class org.apache.giraph.examples.AggregatorsTestComputation.SimpleVertexReader

SimpleVertexWithWorkerContext - Class in org.apache.giraph.examples

Fully runnable example of how to emit worker data to HDFS during a graph computation.

SimpleVertexWithWorkerContext() - Constructor for class org.apache.giraph.examples.SimpleVertexWithWorkerContext

SimpleVertexWithWorkerContext.EmitterWorkerContext - Class in org.apache.giraph.examples

Example worker context to emit data as part of a superstep.

SimpleVertexWithWorkerContext.SimpleComputation - Class in org.apache.giraph.examples

Actual vetex implementation

SMC_AGG - Static variable in class org.apache.giraph.examples.block_app.SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation

Aggregator to get values from the master to the workers

SMC_AGG - Static variable in class org.apache.giraph.examples.SimpleMasterComputeComputation

Aggregator to get values from the master to the workers

SOURCE_ID - Static variable in class org.apache.giraph.examples.SimpleShortestPathsComputation

The shortest paths id

SUPERSTEP_COUNT - Static variable in class org.apache.giraph.examples.SimpleCheckpoint

Dynamically set number of supersteps

SUPERSTEP_COUNT - Static variable in class org.apache.giraph.examples.VerifyMessage.VerifyMessageComputation

Dynamically set number of SUPERSTEPS

T

teleportationProbability() - Method in class org.apache.giraph.examples.RandomWalkComputation

Reads the teleportation probability from the configuration

TestComputationStateComputation - Class in org.apache.giraph.examples

Vertex to test the local variables in Computation, and pre/postSuperstep methods

TestComputationStateComputation() - Constructor for class org.apache.giraph.examples.TestComputationStateComputation

TestComputationStateComputation.TestComputationStateWorkerContext - Class in org.apache.giraph.examples

WorkerContext for TestComputationState

TestComputationStateWorkerContext() - Constructor for class org.apache.giraph.examples.TestComputationStateComputation.TestComputationStateWorkerContext

toString() - Method in class org.apache.giraph.examples.scc.SccVertexValue

toString() - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage

toString() - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

toString() - Method in class org.apache.giraph.examples.VerifyMessage.VerifiableMessage

totalRecords - Variable in class org.apache.giraph.examples.GeneratedEdgeReader

Total records to read (on this split alone)

totalRecords - Variable in class org.apache.giraph.examples.GeneratedVertexReader

Total records to read (on this split alone)

transitionProbability(Vertex<LongWritable, DoubleWritable, NullWritable>, double, Edge<LongWritable, NullWritable>) - Method in class org.apache.giraph.examples.PageRankComputation

transitionProbability(Vertex<LongWritable, DoubleWritable, E>, double, Edge<LongWritable, E>) - Method in class org.apache.giraph.examples.RandomWalkComputation

Compute the probability of transitioning to a neighbor vertex

transitionProbability(Vertex<LongWritable, DoubleWritable, DoubleWritable>, double, Edge<LongWritable, DoubleWritable>) - Method in class org.apache.giraph.examples.RandomWalkWithRestartComputation

V

valueOf(String) - Static method in enum org.apache.giraph.examples.scc.SccPhaseMasterCompute.Phases

Returns the enum constant of this type with the specified name.

values() - Static method in enum org.apache.giraph.examples.scc.SccPhaseMasterCompute.Phases

Returns an array containing the constants of this enum type, in the order they are declared.

VerifiableMessage() - Constructor for class org.apache.giraph.examples.VerifyMessage.VerifiableMessage

Default constructor used with reflection.

VerifiableMessage(long, long, float) - Constructor for class org.apache.giraph.examples.VerifyMessage.VerifiableMessage

Constructor with verifiable arguments.

VerifyMessage - Class in org.apache.giraph.examples

An example that simply uses its id, value, and edges to compute new data every iteration to verify that messages are sent and received at the appropriate location and superstep.

VerifyMessage() - Constructor for class org.apache.giraph.examples.VerifyMessage

VerifyMessage.VerifiableMessage - Class in org.apache.giraph.examples

Message that will be sent in VerifyMessage.VerifyMessageComputation.

VerifyMessage.VerifyMessageComputation - Class in org.apache.giraph.examples

Send and verify messages.

VerifyMessage.VerifyMessageComputation.VerifyMessageVertexWorkerContext - Class in org.apache.giraph.examples

Worker context used with VerifyMessage.VerifyMessageComputation.

VerifyMessage.VerifyMessageMasterCompute - Class in org.apache.giraph.examples

Master compute associated with VerifyMessage.VerifyMessageComputation.

VerifyMessageComputation() - Constructor for class org.apache.giraph.examples.VerifyMessage.VerifyMessageComputation

VerifyMessageMasterCompute() - Constructor for class org.apache.giraph.examples.VerifyMessage.VerifyMessageMasterCompute

VerifyMessageVertexWorkerContext() - Constructor for class org.apache.giraph.examples.VerifyMessage.VerifyMessageComputation.VerifyMessageVertexWorkerContext

VertexValue() - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.VertexValue

Constructor

VertexValue(Double) - Constructor for class org.apache.giraph.examples.PageRankWithKryoSimpleWritable.VertexValue

Constructor

VertexWithDoubleValueDoubleEdgeTextOutputFormat - Class in org.apache.giraph.examples

Simple vertex output format for weighted graphs.

VertexWithDoubleValueDoubleEdgeTextOutputFormat() - Constructor for class org.apache.giraph.examples.VertexWithDoubleValueDoubleEdgeTextOutputFormat

VertexWithDoubleValueDoubleEdgeTextOutputFormat.VertexWithDoubleValueWriter - Class in org.apache.giraph.examples

Vertex writer used with VertexWithDoubleValueDoubleEdgeTextOutputFormat.

VertexWithDoubleValueNullEdgeTextOutputFormat - Class in org.apache.giraph.examples

Output format for vertices with a long as id, a double as value and null edges

VertexWithDoubleValueNullEdgeTextOutputFormat() - Constructor for class org.apache.giraph.examples.VertexWithDoubleValueNullEdgeTextOutputFormat

VertexWithDoubleValueNullEdgeTextOutputFormat.VertexWithDoubleValueWriter - Class in org.apache.giraph.examples

Vertex writer used with VertexWithDoubleValueNullEdgeTextOutputFormat.

VertexWithDoubleValueWriter() - Constructor for class org.apache.giraph.examples.VertexWithDoubleValueDoubleEdgeTextOutputFormat.VertexWithDoubleValueWriter

VertexWithDoubleValueWriter() - Constructor for class org.apache.giraph.examples.VertexWithDoubleValueNullEdgeTextOutputFormat.VertexWithDoubleValueWriter

W

waitForMessage(Long, Long) - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

Add a new message that must be expected by the node

write(DataOutput) - Method in class org.apache.giraph.examples.scc.SccVertexValue

write(DataOutput) - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockMessage

write(DataOutput) - Method in class org.apache.giraph.examples.utils.BrachaTouegDeadlockVertexValue

write(DataOutput) - Method in class org.apache.giraph.examples.VerifyMessage.VerifiableMessage

writeAggregator(Iterable<Map.Entry<String, Writable>>, long) - Method in class org.apache.giraph.examples.SimpleAggregatorWriter

writeVertex(Vertex<LongWritable, DoubleWritable, FloatWritable>) - Method in class org.apache.giraph.examples.SimplePageRankComputation.SimplePageRankVertexOutputFormat.SimplePageRankVertexWriter

writeVertex(Vertex<LongWritable, IntWritable, FloatWritable>) - Method in class org.apache.giraph.examples.SimpleSuperstepComputation.SimpleSuperstepVertexOutputFormat.SimpleSuperstepVertexWriter

writeVertex(Vertex<LongWritable, DoubleWritable, DoubleWritable>) - Method in class org.apache.giraph.examples.VertexWithDoubleValueDoubleEdgeTextOutputFormat.VertexWithDoubleValueWriter

writeVertex(Vertex<LongWritable, DoubleWritable, NullWritable>) - Method in class org.apache.giraph.examples.VertexWithDoubleValueNullEdgeTextOutputFormat.VertexWithDoubleValueWriter

A B C D E F G H I L M N O P R S T V W