Package | Description |
---|---|
org.apache.giraph.aggregators.matrix.dense |
Package of dense matrix aggregator.
|
org.apache.giraph.aggregators.matrix.sparse |
Package of sparce matrix aggregator.
|
org.apache.giraph.benchmark |
Package of benchmarks for performance testing and optimization
|
org.apache.giraph.graph |
Package of all the graph related objects, built on the
org.apache.bsp package.
|
org.apache.giraph.io |
Input/Output related things.
|
org.apache.giraph.io.formats |
Package of reusable library Giraph objects.
|
org.apache.giraph.io.internal |
Input/Output classes for internal use only.
|
org.apache.giraph.io.iterables |
Iterable wrappers for IO readers/writers
|
org.apache.giraph.jython |
Jython integration.
|
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 |
---|---|
FloatDenseMatrix |
FloatDenseMatrixSumAggregator.getMatrix(int numRows,
AggregatorUsage aggUser)
Read the aggregated values of the matrix.
|
LongDenseMatrix |
LongDenseMatrixSumAggregator.getMatrix(int numRows,
AggregatorUsage aggUser)
Read the aggregated values of the matrix.
|
IntDenseMatrix |
IntDenseMatrixSumAggregator.getMatrix(int numRows,
AggregatorUsage aggUser)
Read the aggregated values of the matrix.
|
DoubleDenseMatrix |
DoubleDenseMatrixSumAggregator.getMatrix(int numRows,
AggregatorUsage aggUser)
Read the aggregated values of the matrix.
|
Modifier and Type | Method and Description |
---|---|
LongSparseMatrix |
LongSparseMatrixSumAggregator.getMatrix(int numRows,
AggregatorUsage aggUser)
Read the aggregated values of the matrix.
|
FloatSparseMatrix |
FloatSparseMatrixSumAggregator.getMatrix(int numRows,
AggregatorUsage aggUser)
Read the aggregated values of the matrix.
|
DoubleSparseMatrix |
DoubleSparseMatrixSumAggregator.getMatrix(int numRows,
AggregatorUsage aggUser)
Read the aggregated values of the matrix.
|
IntSparseMatrix |
IntSparseMatrixSumAggregator.getMatrix(int numRows,
AggregatorUsage aggUser)
Read the aggregated values of the matrix.
|
Modifier and Type | Class and Description |
---|---|
static class |
AggregatorsBenchmark.AggregatorsBenchmarkComputation
Vertex class for AggregatorsBenchmark
|
static class |
AggregatorsBenchmark.AggregatorsBenchmarkMasterCompute
MasterCompute 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.RandomMessageBenchmarkMasterCompute
Master compute associated with
RandomMessageBenchmark . |
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.ReducersBenchmarkMasterCompute
MasterCompute 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 |
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 |
BasicVertexValueReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable>
Abstract base class for VertexValueReader.
|
class |
EdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
Analogous to org.apache.giraph.bsp.BspRecordReader for edges.
|
class |
MappingReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,B extends org.apache.hadoop.io.Writable>
Will read the mapping from an input split.
|
class |
ReverseEdgeDuplicator<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
An EdgeReader that creates the opposite direction edge for each edge read.
|
class |
VertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Analogous to Hadoop's RecordReader for vertices.
|
class |
VertexValueReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable>
Vertex reader for
VertexValueInputFormat . |
Modifier and Type | Class and Description |
---|---|
protected class |
AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader
Vertex reader associated with
AdjacencyListTextVertexInputFormat . |
class |
IntIntNullTextInputFormat.IntIntNullVertexReader
Vertex reader associated with
IntIntNullTextInputFormat . |
class |
IntIntNullTextVertexInputFormat.IntIntNullVertexReader
Vertex reader associated with
IntIntNullTextVertexInputFormat . |
class |
IntIntTextVertexValueInputFormat.IntIntTextVertexValueReader
VertexValueReader associated with
IntIntTextVertexValueInputFormat . |
class |
IntNullNullTextInputFormat.IntNullNullNullVertexReader
Reader for this InputFormat.
|
class |
IntNullTextEdgeInputFormat.IntNullTextEdgeReader
EdgeReader associated with
IntNullTextEdgeInputFormat . |
protected class |
JsonBase64VertexInputFormat.JsonBase64VertexReader
Simple reader that supports
JsonBase64VertexInputFormat |
protected class |
LongDoubleDoubleAdjacencyListVertexInputFormat.LongDoubleDoubleAdjacencyListVertexReader
VertexReader associated with
LongDoubleDoubleAdjacencyListVertexInputFormat . |
class |
LongLongNullTextInputFormat.LongLongNullVertexReader
Vertex reader associated with
LongLongNullTextInputFormat . |
static class |
SequenceFileVertexInputFormat.SequenceFileVertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,X extends Vertex<I,V,E>>
Vertex reader used with
SequenceFileVertexInputFormat . |
protected class |
TextDoubleDoubleAdjacencyListVertexInputFormat.TextDoubleDoubleAdjacencyListVertexReader
Vertex reader used with
TextDoubleDoubleAdjacencyListVertexInputFormat |
protected class |
TextEdgeInputFormat.TextEdgeReader
|
protected class |
TextEdgeInputFormat.TextEdgeReaderFromEachLine
Abstract class to be implemented by the user to read an edge from each
text line.
|
protected class |
TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed<T>
Abstract class to be implemented by the user to read an edge from each
text line after preprocessing it.
|
protected class |
TextVertexInputFormat.TextVertexReader
Abstract class to be implemented by the user based on their specific
vertex input.
|
protected class |
TextVertexInputFormat.TextVertexReaderFromEachLine
Abstract class to be implemented by the user to read a vertex from each
text line.
|
protected class |
TextVertexInputFormat.TextVertexReaderFromEachLineProcessed<T>
Abstract class to be implemented by the user to read a vertex from each
text line after preprocessing it.
|
protected class |
TextVertexInputFormat.TextVertexReaderFromEachLineProcessedHandlingExceptions<T,X extends Throwable>
Abstract class to be implemented by the user to read a vertex from each
text line after preprocessing it with exception handling.
|
protected class |
TextVertexValueInputFormat.TextVertexValueReader
|
protected class |
TextVertexValueInputFormat.TextVertexValueReaderFromEachLine
Abstract class to be implemented by the user to read a vertex value from
each text line.
|
protected class |
TextVertexValueInputFormat.TextVertexValueReaderFromEachLineProcessed<T>
Abstract class to be implemented by the user to read a vertex value from
each text line after preprocessing it.
|
Modifier and Type | Class and Description |
---|---|
class |
WrappedEdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
For internal use only.
|
class |
WrappedMappingReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,B extends org.apache.hadoop.io.Writable>
For internal use only.
|
class |
WrappedVertexReader<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
For internal use only.
|
Modifier and Type | Class and Description |
---|---|
class |
EdgeReaderWrapper<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
Wraps
GiraphReader for edges into EdgeReader |
class |
MappingReaderWrapper<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,B extends org.apache.hadoop.io.Writable>
Wraps
GiraphReader for mapping into
MappingReader |
class |
VertexReaderWrapper<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Wraps
GiraphReader for vertices into VertexReader |
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 | Interface and Description |
---|---|
interface |
MasterAggregatorUsage
Master compute can access and change aggregators through this interface
|
Modifier and Type | Class and Description |
---|---|
class |
AggregatorToGlobalCommTranslation
Class that translates aggregator handling on the master to
reduce and broadcast operations supported by the MasterAggregatorHandler.
|
class |
DefaultMasterCompute
A dumb implementation of
MasterCompute . |
class |
MasterCompute
Interface for defining a master vertex that can perform centralized
computation between supersteps.
|
Modifier and Type | Interface and Description |
---|---|
interface |
WorkerAggregatorUsage
Vertex classes can access and change aggregators through this interface
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultWorkerContext
A dummy implementation of
WorkerContext . |
class |
WorkerAggregatorDelegator<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Class for delegating WorkerAggregatorUsage and
WorkerGlobalCommUsage methods to corresponding interface.
|
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.