Package | Description |
---|---|
org.apache.giraph.comm |
Package of communication related objects, IPC service.
|
org.apache.giraph.comm.netty |
Package for netty implementations.
|
org.apache.giraph.conf |
Package of Giraph configuration related things.
|
org.apache.giraph.edge |
Package of Vertex implementations.
|
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.filters |
Input/Output filters.
|
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.utils |
Package of all generic utility classes.
|
Modifier and Type | Method and Description |
---|---|
int |
SendEdgeCache.addEdge(WorkerInfo workerInfo,
int partitionId,
I destVertexId,
Edge<I,E> edge)
Add an edge to the cache.
|
int |
SendMutationsCache.addEdgeMutation(Integer partitionId,
I destVertexId,
Edge<I,E> edge)
Add an add edge mutation to the cache.
|
void |
WorkerClientRequestProcessor.addEdgeRequest(I vertexIndex,
Edge<I,E> edge)
Sends a request to the appropriate vertex range owner to add an edge
|
boolean |
WorkerClientRequestProcessor.sendEdgeRequest(I sourceVertexId,
Edge<I,E> edge)
Sends a request to the source vertex owner to add an edge.
|
Modifier and Type | Method and Description |
---|---|
void |
NettyWorkerClientRequestProcessor.addEdgeRequest(I vertexIndex,
Edge<I,E> edge) |
boolean |
NettyWorkerClientRequestProcessor.sendEdgeRequest(I sourceVertexId,
Edge<I,E> edge) |
Modifier and Type | Method and Description |
---|---|
Edge<I,E> |
ImmutableClassesGiraphConfiguration.createEdge()
Create a user edge.
|
Edge<I,E> |
ImmutableClassesGiraphConfiguration.createEdge(TranslateEdge<I,E> translateEdge,
Edge<I,E> edge)
Create edge based on #createEdge definition
|
Modifier and Type | Method and Description |
---|---|
Edge<I,E> |
ImmutableClassesGiraphConfiguration.createEdge(TranslateEdge<I,E> translateEdge,
Edge<I,E> edge)
Create edge based on #createEdge definition
|
Modifier and Type | Method and Description |
---|---|
OutEdges<I,E> |
ImmutableClassesGiraphConfiguration.createAndInitializeOutEdges(Iterable<Edge<I,E>> edges)
Create a
OutEdges instance and initialize
it with the given iterable of edges. |
Modifier and Type | Interface and Description |
---|---|
interface |
MutableEdge<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
An edge whose value can be modified.
|
interface |
ReusableEdge<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
A complete edge, the target vertex and the edge value.
|
Modifier and Type | Class and Description |
---|---|
class |
DefaultEdge<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
A complete edge, the target vertex and the edge value.
|
class |
EdgeNoValue<I extends org.apache.hadoop.io.WritableComparable>
An edge that has no value.
|
class |
MapMutableEdge<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
Helper class for a mutable edge that modifies the backing map entry.
|
Modifier and Type | Method and Description |
---|---|
static <I extends org.apache.hadoop.io.WritableComparable> |
EdgeFactory.create(I id)
Create an edge pointing to a given ID without a value
|
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> |
EdgeFactory.create(I id,
E value)
Create an edge pointing to a given ID with a value
|
Modifier and Type | Method and Description |
---|---|
Iterator<Edge<I,E>> |
MutableEdgesWrapper.getOldEdgesIterator()
Get the iterator over the old edges data structure.
|
Iterator<Edge<I,org.apache.hadoop.io.NullWritable>> |
IdAndNullArrayEdges.iterator() |
Iterator<Edge<I,E>> |
MutableEdgesWrapper.iterator() |
Iterator<Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.ByteWritable>> |
LongByteHashMapEdges.iterator() |
Iterator<Edge<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable>> |
IntNullArrayEdges.iterator() |
Iterator<Edge<I,E>> |
ByteArrayEdges.iterator() |
Iterator<Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.NullWritable>> |
LongDiffNullArrayEdges.iterator() |
Iterator<Edge<I,E>> |
IdAndValueArrayEdges.iterator() |
Iterator<Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable>> |
LongDoubleArrayEdges.iterator() |
Iterator<Edge<I,E>> |
HashMultimapEdges.iterator() |
Iterator<Edge<I,E>> |
HashMapEdges.iterator() |
Iterator<Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.NullWritable>> |
LongNullHashSetEdges.iterator() |
Iterator<Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable>> |
LongDoubleHashMapEdges.iterator() |
Iterator<Edge<I,E>> |
ArrayListEdges.iterator() |
Iterator<Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.NullWritable>> |
LongNullArrayEdges.iterator() |
Modifier and Type | Method and Description |
---|---|
void |
MutableEdgesWrapper.add(Edge<I,E> edge) |
void |
ByteArrayEdges.add(Edge<I,E> edge) |
void |
IdAndValueArrayEdges.add(Edge<I,E> edge) |
void |
HashMultimapEdges.add(Edge<I,E> edge) |
void |
HashMapEdges.add(Edge<I,E> edge) |
void |
ArrayListEdges.add(Edge<I,E> edge) |
void |
OutEdges.add(Edge<I,E> edge)
Add an edge.
|
void |
IntNullArrayEdges.add(Edge<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable> edge) |
void |
IdAndNullArrayEdges.add(Edge<I,org.apache.hadoop.io.NullWritable> edge) |
void |
LongByteHashMapEdges.add(Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.ByteWritable> edge) |
void |
LongDoubleArrayEdges.add(Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable> edge) |
void |
LongDoubleHashMapEdges.add(Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable> edge) |
void |
LongDiffNullArrayEdges.add(Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.NullWritable> edge) |
void |
LongNullHashSetEdges.add(Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.NullWritable> edge) |
void |
LongNullArrayEdges.add(Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.NullWritable> edge) |
Modifier and Type | Method and Description |
---|---|
void |
MutableEdgesWrapper.initialize(Iterable<Edge<I,E>> edges) |
void |
ByteArrayEdges.initialize(Iterable<Edge<I,E>> edges) |
void |
IdAndValueArrayEdges.initialize(Iterable<Edge<I,E>> edges) |
void |
HashMultimapEdges.initialize(Iterable<Edge<I,E>> edges) |
void |
HashMapEdges.initialize(Iterable<Edge<I,E>> edges) |
void |
ArrayListEdges.initialize(Iterable<Edge<I,E>> edges) |
void |
OutEdges.initialize(Iterable<Edge<I,E>> edges)
Initialize the data structure and set the edges from an iterable.
|
void |
IntNullArrayEdges.initialize(Iterable<Edge<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable>> edges) |
void |
IdAndNullArrayEdges.initialize(Iterable<Edge<I,org.apache.hadoop.io.NullWritable>> edges) |
void |
LongByteHashMapEdges.initialize(Iterable<Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.ByteWritable>> edges) |
void |
LongDoubleArrayEdges.initialize(Iterable<Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable>> edges) |
void |
LongDoubleHashMapEdges.initialize(Iterable<Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable>> edges) |
void |
LongDiffNullArrayEdges.initialize(Iterable<Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.NullWritable>> edgeIterator) |
void |
LongNullHashSetEdges.initialize(Iterable<Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.NullWritable>> edges) |
void |
LongNullArrayEdges.initialize(Iterable<Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.NullWritable>> edges) |
Modifier and Type | Method and Description |
---|---|
List<Edge<I,E>> |
VertexMutations.getAddedEdgeList() |
List<Edge<I,E>> |
VertexChanges.getAddedEdgeList()
Get the added edges for this particular vertex index from the previous
superstep
|
Iterable<Edge<I,E>> |
DefaultVertex.getEdges() |
Iterable<Edge<I,org.apache.hadoop.io.Writable>> |
OnlyIdVertex.getEdges() |
Iterable<Edge<I,E>> |
Vertex.getEdges()
Get a read-only view of the out-edges of this vertex.
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultVertex.addEdge(Edge<I,E> edge) |
void |
VertexMutations.addEdge(Edge<I,E> edge)
Add an edge to this vertex
|
void |
Vertex.addEdge(Edge<I,E> edge)
Add an edge for this vertex (happens immediately)
|
void |
OnlyIdVertex.addEdge(Edge<I,org.apache.hadoop.io.Writable> edge) |
void |
AbstractComputation.addEdgeRequest(I sourceVertexId,
Edge<I,E> edge)
Request to add an edge of a vertex in the graph
(processed just prior to the next superstep)
|
void |
Computation.addEdgeRequest(I sourceVertexId,
Edge<I,E> edge)
Request to add an edge of a vertex in the graph
(processed just prior to the next superstep)
|
Modifier and Type | Method and Description |
---|---|
void |
DefaultVertex.initialize(I id,
V value,
Iterable<Edge<I,E>> edges) |
void |
ByteValueVertex.initialize(I id,
V value,
Iterable<Edge<I,E>> edges) |
void |
Vertex.initialize(I id,
V value,
Iterable<Edge<I,E>> edges)
Initialize id, value, and edges.
|
void |
OnlyIdVertex.initialize(I id,
org.apache.hadoop.io.Writable value,
Iterable<Edge<I,org.apache.hadoop.io.Writable>> edges) |
void |
DefaultVertex.setEdges(Iterable<Edge<I,E>> edges) |
void |
Vertex.setEdges(Iterable<Edge<I,E>> edges)
Set the outgoing edges for this vertex.
|
void |
OnlyIdVertex.setEdges(Iterable<Edge<I,org.apache.hadoop.io.Writable>> edges) |
Modifier and Type | Method and Description |
---|---|
Edge<I,E> |
ReverseEdgeDuplicator.getCurrentEdge() |
abstract Edge<I,E> |
EdgeReader.getCurrentEdge()
Get the current edge.
|
Modifier and Type | Method and Description |
---|---|
abstract void |
EdgeWriter.writeEdge(I sourceId,
V sourceValue,
Edge<I,E> edge)
Writes the next vertex and associated data
|
Modifier and Type | Method and Description |
---|---|
boolean |
DefaultEdgeInputFilter.dropEdge(I sourceId,
Edge<I,E> edge) |
boolean |
EdgeInputFilter.dropEdge(I sourceId,
Edge<I,E> edge)
Whether to drop this edge
|
Modifier and Type | Method and Description |
---|---|
Edge<org.apache.hadoop.io.Text,org.apache.hadoop.io.DoubleWritable> |
TextDoubleDoubleAdjacencyListVertexInputFormat.TextDoubleDoubleAdjacencyListVertexReader.decodeEdge(String s1,
String s2) |
abstract Edge<I,E> |
AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader.decodeEdge(String id,
String value)
Decode an edge from the line into an instance of a correctly typed Edge
|
Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable> |
LongDoubleDoubleAdjacencyListVertexInputFormat.LongDoubleDoubleAdjacencyListVertexReader.decodeEdge(String s1,
String s2) |
Edge<I,E> |
TextEdgeInputFormat.TextEdgeReaderFromEachLine.getCurrentEdge() |
Edge<I,E> |
TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed.getCurrentEdge() |
Modifier and Type | Method and Description |
---|---|
protected Iterable<Edge<I,E>> |
JsonBase64VertexInputFormat.JsonBase64VertexReader.getEdges(org.json.JSONObject vertexObject) |
protected Iterable<Edge<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable>> |
IntNullNullTextInputFormat.IntNullNullNullVertexReader.getEdges(String line) |
protected Iterable<Edge<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable>> |
IntIntNullTextVertexInputFormat.IntIntNullVertexReader.getEdges(String[] tokens) |
protected Iterable<Edge<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.NullWritable>> |
LongLongNullTextInputFormat.LongLongNullVertexReader.getEdges(String[] tokens) |
protected Iterable<Edge<I,E>> |
AdjacencyListTextVertexInputFormat.AdjacencyListTextVertexReader.getEdges(String[] values) |
protected Iterable<Edge<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable>> |
IntIntNullTextInputFormat.IntIntNullVertexReader.getEdges(String[] tokens) |
protected abstract Iterable<Edge<I,E>> |
TextVertexInputFormat.TextVertexReaderFromEachLineProcessed.getEdges(T line)
Reads edges from the preprocessed line.
|
protected abstract Iterable<Edge<I,E>> |
TextVertexInputFormat.TextVertexReaderFromEachLineProcessedHandlingExceptions.getEdges(T line)
Reads edges from the preprocessed line.
|
protected abstract Iterable<Edge<I,E>> |
TextVertexInputFormat.TextVertexReaderFromEachLine.getEdges(org.apache.hadoop.io.Text line)
Reads edges value from the current line.
|
Modifier and Type | Method and Description |
---|---|
protected org.apache.hadoop.io.Text |
SrcIdDstIdEdgeValueTextOutputFormat.SrcIdDstIdEdgeValueEdgeWriter.convertEdgeToLine(I sourceId,
V sourceValue,
Edge<I,E> edge) |
protected abstract org.apache.hadoop.io.Text |
TextEdgeOutputFormat.TextEdgeWriterToEachLine.convertEdgeToLine(I sourceId,
V sourceValue,
Edge<I,E> edge)
Writes a line for the given edge.
|
void |
TextEdgeOutputFormat.TextEdgeWriterToEachLine.writeEdge(I sourceId,
V sourceValue,
Edge<I,E> edge) |
Modifier and Type | Method and Description |
---|---|
Edge<I,E> |
WrappedEdgeReader.getCurrentEdge() |
Modifier and Type | Method and Description |
---|---|
Edge<I,E> |
EdgeReaderWrapper.getCurrentEdge() |
Modifier and Type | Method and Description |
---|---|
void |
JythonComputation.addEdgeRequest(Object sourceVertexId,
Edge edge)
Request to add an edge of a vertex in the graph
(processed just prior to the next superstep)
|
Modifier and Type | Method and Description |
---|---|
Edge<I,E> |
ByteArrayVertexIdEdges.createData() |
Edge<I,E> |
ByteStructVertexIdEdgeIterator.getCurrentEdge() |
Edge<I,E> |
VertexIdEdgeIterator.getCurrentEdge()
Get the current edge.
|
Edge<I,E> |
ByteStructVertexIdEdgeIterator.releaseCurrentEdge() |
Edge<I,E> |
VertexIdEdgeIterator.releaseCurrentEdge()
Release the current edge.
|
Modifier and Type | Method and Description |
---|---|
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.WritableComparable> |
EdgeIterables.copy(Iterable<Edge<I,E>> edges)
Make a deep copy of an edge iterable and return it as an
ArrayList . |
protected Iterable<Edge<I,E>> |
TestGraph.createEdges(Map.Entry<I,E>... destEdgess)
Create edges for given ids
|
Modifier and Type | Method and Description |
---|---|
int |
EdgeComparator.compare(Edge<I,E> e1,
Edge<I,E> e2) |
int |
EdgeComparator.compare(Edge<I,E> e1,
Edge<I,E> e2) |
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.WritableComparable> |
EdgeComparator.compareEdges(Edge<I,E> e1,
Edge<I,E> e2)
Compares two edges.
|
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.WritableComparable> |
EdgeComparator.compareEdges(Edge<I,E> e1,
Edge<I,E> e2)
Compares two edges.
|
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.WritableComparable> |
EdgeComparator.equal(Edge<I,E> e1,
Edge<I,E> e2)
Indicates whether two edges are equal.
|
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.WritableComparable> |
EdgeComparator.equal(Edge<I,E> e1,
Edge<I,E> e2)
Indicates whether two edges are equal.
|
void |
ByteArrayVertexIdEdges.readData(ExtendedDataInput in,
Edge<I,E> edge) |
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> |
WritableUtils.readEdge(DataInput in,
Edge<I,E> edge)
Read an edge from an input stream.
|
void |
ByteArrayVertexIdEdges.writeData(ExtendedDataOutput out,
Edge<I,E> edge) |
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> |
WritableUtils.writeEdge(DataOutput out,
Edge<I,E> edge)
Write an edge to an output stream.
|
Modifier and Type | Method and Description |
---|---|
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.WritableComparable> |
EdgeIterables.copy(Iterable<Edge<I,E>> edges)
Make a deep copy of an edge iterable and return it as an
ArrayList . |
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.WritableComparable> |
EdgeIterables.equals(Iterable<Edge<I,E>> e1,
Iterable<Edge<I,E>> e2)
Compare two edge iterables element-wise.
|
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.WritableComparable> |
EdgeIterables.equals(Iterable<Edge<I,E>> e1,
Iterable<Edge<I,E>> e2)
Compare two edge iterables element-wise.
|
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> |
EdgeIterables.initialize(OutEdges<I,E> edges,
Iterable<Edge<I,E>> edgesIterable)
Initialize edges data structure and add the edges from edgesIterable.
|
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.WritableComparable> |
EdgeIterables.sameEdges(Iterable<Edge<I,E>> e1,
Iterable<Edge<I,E>> e2)
Compare two edge iterables up to reordering.
|
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.WritableComparable> |
EdgeIterables.sameEdges(Iterable<Edge<I,E>> e1,
Iterable<Edge<I,E>> e2)
Compare two edge iterables up to reordering.
|
static <I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable> |
EdgeIterables.size(Iterable<Edge<I,E>> edges)
Get the size of edges.
|
Constructor and Description |
---|
ByteStructVertexIdEdgeIterator(AbstractVertexIdData<I,Edge<I,E>> vertexIdData)
Constructor
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.