org.apache.giraph.utils

Class MockUtils.MockedEnvironment<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>

java.lang.Object

org.apache.giraph.utils.MockUtils.MockedEnvironment<I,V,E,M>

Type Parameters:

I - vertex id

V - vertex data

E - edge data

M - message data

Enclosing class:

MockUtils

public static class MockUtils.MockedEnvironment<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>
extends Object

mocks and holds "environment objects" that are injected into a vertex

Constructor Summary

Constructors

Constructor and Description
MockedEnvironment()

Method Summary

Modifier and Type	Method and Description
org.apache.hadoop.conf.Configuration	getConfiguration() the injected hadoop configuration
org.apache.hadoop.mapreduce.Mapper.Context	getContext() the injected mapper context
GraphState	getGraphState() the injected graph state
WorkerClientRequestProcessor	getWorkerClientRequestProcessor() the injected worker communications
void	verifyMessageSent(I targetVertexId, M message) assert that the test vertex message has been sent to a particular vertex
void	verifyMessageSentToAllEdges(Vertex<I,V,E> vertex, M message)
void	verifyNoMessageSent() assert that the test vertex has sent no message to a particular vertex

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

MockedEnvironment

public MockedEnvironment()

Method Detail

getGraphState

public GraphState getGraphState()

the injected graph state

getContext

public org.apache.hadoop.mapreduce.Mapper.Context getContext()

the injected mapper context

getConfiguration

public org.apache.hadoop.conf.Configuration getConfiguration()

the injected hadoop configuration

getWorkerClientRequestProcessor

public WorkerClientRequestProcessor getWorkerClientRequestProcessor()

the injected worker communications

verifyMessageSent

public void verifyMessageSent(I targetVertexId,
                              M message)

assert that the test vertex message has been sent to a particular vertex

verifyMessageSentToAllEdges

public void verifyMessageSentToAllEdges(Vertex<I,V,E> vertex,
                                        M message)

verifyNoMessageSent

public void verifyNoMessageSent()

assert that the test vertex has sent no message to a particular vertex