Skip navigation links
A B C D E F G H I K L M N O P R S T U V W 

A

A() - Constructor for class org.apache.giraph.conf.TestGiraphConfiguration.A
 
AccumuloEdgeInputFormat - Class in org.apache.giraph.io.accumulo.edgemarker
 
AccumuloEdgeInputFormat() - Constructor for class org.apache.giraph.io.accumulo.edgemarker.AccumuloEdgeInputFormat
 
AccumuloEdgeInputFormat.AccumuloEdgeVertexReader - Class in org.apache.giraph.io.accumulo.edgemarker
 
AccumuloEdgeOutputFormat - Class in org.apache.giraph.io.accumulo.edgemarker
 
AccumuloEdgeOutputFormat() - Constructor for class org.apache.giraph.io.accumulo.edgemarker.AccumuloEdgeOutputFormat
 
AccumuloEdgeOutputFormat.AccumuloEdgeVertexWriter - Class in org.apache.giraph.io.accumulo.edgemarker
 
AccumuloEdgeVertexReader(RecordReader<Key, Value>) - Constructor for class org.apache.giraph.io.accumulo.edgemarker.AccumuloEdgeInputFormat.AccumuloEdgeVertexReader
 
AccumuloEdgeVertexWriter(RecordWriter<Text, Mutation>, String) - Constructor for class org.apache.giraph.io.accumulo.edgemarker.AccumuloEdgeOutputFormat.AccumuloEdgeVertexWriter
 
add(Edge<LongWritable, DoubleWritable>) - Method in class org.apache.giraph.graph.TestVertexAndEdges.TestOutEdges
 
add(Edge<IntWritable, NullWritable>) - Method in class org.apache.giraph.io.TestVertexEdgeInput.TestOutEdgesFilterEven
 
add256kIntegers() - Method in class org.apache.giraph.comm.IncreasingBitSetTest
 
add256kIntegersAlternate() - Method in class org.apache.giraph.comm.IncreasingBitSetTest
 
add256kIntegersOutOfOrder() - Method in class org.apache.giraph.comm.IncreasingBitSetTest
 
addDoubleMessages(Iterable<Writable>) - Method in class org.apache.giraph.master.TestSwitchClasses.StatusValue
 
addIntMessages(Iterable<IntWritable>) - Method in class org.apache.giraph.master.TestSwitchClasses.StatusValue
 
addVertex(TestGraph<LongWritable, SccVertexValue, NullWritable>, long, long...) - Static method in class org.apache.giraph.examples.scc.SccComputationTestInMemory
Connects the outgoingVertices to the given vertex id with null-valued edges.
addVertex(TestGraph<LongWritable, LongWritable, NullWritable>, long, long, long...) - Static method in class org.apache.giraph.utils.TestTestGraph
 
alreadyProcessedRequest() - Method in class org.apache.giraph.comm.RequestFailureTest
 
assertValid(Vertex<I, V, E>, Vertex<I, V, E>) - Static method in class org.apache.giraph.io.TestTextDoubleDoubleAdjacencyListVertexInputFormat
 
assertValidVertex(ImmutableClassesGiraphConfiguration<I, V, E>, Vertex<I, V, E>, I, V, Edge<I, E>...) - Static method in class org.apache.giraph.io.TestTextDoubleDoubleAdjacencyListVertexInputFormat
 
AsyncMessageStoreWrapperTest - Class in org.apache.giraph.comm.messages.queue
Test case for AsyncMessageStoreWrapper
AsyncMessageStoreWrapperTest() - Constructor for class org.apache.giraph.comm.messages.queue.AsyncMessageStoreWrapperTest
 

B

B() - Constructor for class org.apache.giraph.conf.TestGiraphConfiguration.B
 
BASE_PATH - Static variable in class org.apache.giraph.zk.TestZooKeeperExt
 
BlockApiHandleTest - Class in org.apache.giraph.block_app.framework
Test the use of BlockApiHandle.
BlockApiHandleTest() - Constructor for class org.apache.giraph.block_app.framework.BlockApiHandleTest
 
BlockApiHandleTest.DummyObjectWithApiHandle - Class in org.apache.giraph.block_app.framework
 
BlockApiHandleTest.TestPiece - Class in org.apache.giraph.block_app.framework
 
BlockExecutionTest - Class in org.apache.giraph.block_app.framework
Test of barebones of Blocks Framework.
BlockExecutionTest() - Constructor for class org.apache.giraph.block_app.framework.BlockExecutionTest
 
BlockTestingUtils - Class in org.apache.giraph.block_app.framework.block
 
BlockTestingUtils.CheckIterator<T> - Class in org.apache.giraph.block_app.framework.block
 
BrachaTouegDeadlockComputationTest - Class in org.apache.giraph.examples
BrachaTouegDeadlockComputationTest() - Constructor for class org.apache.giraph.examples.BrachaTouegDeadlockComputationTest
 
BspCase - Class in org.apache.giraph
Extended TestCase for making setting up Bsp testing.
BspCase(String) - Constructor for class org.apache.giraph.BspCase
Create the test case
buildVertex(Class<? extends OutEdges>) - Method in class org.apache.giraph.graph.TestVertexAndEdges
 

C

C() - Constructor for class org.apache.giraph.conf.TestGiraphConfiguration.C
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.accumulo.edgemarker.AccumuloEdgeInputFormat
 
checkInputSpecs(Configuration) - Method in class org.apache.giraph.io.hbase.edgemarker.TableEdgeInputFormat
 
CheckIterator(Iterator<T>, Iterator<T>) - Constructor for class org.apache.giraph.block_app.framework.block.BlockTestingUtils.CheckIterator
 
CheckpointComputation() - Constructor for class org.apache.giraph.TestCheckpointing.CheckpointComputation
 
CheckpointVertexMasterCompute() - Constructor for class org.apache.giraph.TestCheckpointing.CheckpointVertexMasterCompute
 
CheckpointVertexWorkerContext() - Constructor for class org.apache.giraph.TestCheckpointing.CheckpointVertexWorkerContext
 
cleanUp() - Method in class org.apache.giraph.comm.TestMessageStores
 
cleanUp() - Method in class org.apache.giraph.conf.TestObjectCreation
 
combine(IntWritable, IntWritable) - Method in class org.apache.giraph.io.TestVertexEdgeInput.IntSumVertexValueCombiner
 
combine(IntWritable, IntWritable, IntWritable) - Method in class org.apache.giraph.master.TestSwitchClasses.MinimumMessageCombiner
 
combine(IntWritable, IntWritable, IntWritable) - Method in class org.apache.giraph.master.TestSwitchClasses.SumMessageCombiner
 
combine(LongWritable, LongWritable) - Method in class org.apache.giraph.utils.TestTestGraph.SumLongVertexValueCombiner
 
combine(LongWritable, FloatWritable, FloatWritable) - Method in class org.apache.giraph.vertex.TestComputationTypes.GeneratedVertexMatchMessageCombiner
 
combine(LongWritable, DoubleWritable, DoubleWritable) - Method in class org.apache.giraph.vertex.TestComputationTypes.GeneratedVertexMismatchMessageCombiner
 
commaPattern - Static variable in class org.apache.giraph.io.accumulo.edgemarker.AccumuloEdgeInputFormat.AccumuloEdgeVertexReader
 
Computation1() - Constructor for class org.apache.giraph.master.TestSwitchClasses.Computation1
 
Computation2() - Constructor for class org.apache.giraph.master.TestSwitchClasses.Computation2
 
Computation3() - Constructor for class org.apache.giraph.master.TestSwitchClasses.Computation3
 
ComputationCountEdges - Class in org.apache.giraph.utils
Computation which sets the value of vertex to its number of edges, used for testing.
ComputationCountEdges() - Constructor for class org.apache.giraph.utils.ComputationCountEdges
 
ComputationDoneNameTest - Class in org.apache.giraph.zk
Test the name generation and parsing
ComputationDoneNameTest() - Constructor for class org.apache.giraph.zk.ComputationDoneNameTest
 
compute(Vertex<Text, Text, Text>, Iterable<Text>) - Method in class org.apache.giraph.io.accumulo.TestAccumuloVertexFormat.EdgeNotification
 
compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<LongWritable>) - Method in class org.apache.giraph.io.gora.TestGoraEdgeInputFormat.EmptyComputation
 
compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<LongWritable>) - Method in class org.apache.giraph.io.gora.TestGoraEdgeOutputFormat.EmptyComputation
 
compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<LongWritable>) - Method in class org.apache.giraph.io.gora.TestGoraVertexInputFormat.EmptyComputation
 
compute(Vertex<Text, Text, Text>, Iterable<Text>) - Method in class org.apache.giraph.io.hbase.TestHBaseRootMarkerVertextFormat.EdgeNotification
 
compute(Vertex<IntWritable, IntWritable, NullWritable>, Iterable<NullWritable>) - Method in class org.apache.giraph.io.TestVertexEdgeInput.TestComputationCheckEdgesType
 
compute(Vertex<I, V, E>, Iterable<M1>) - Method in class org.apache.giraph.master.TestComputationCombinerTypes.NoOpComputation
 
compute(Vertex<IntWritable, IntWritable, NullWritable>, Iterable<NullWritable>) - Method in class org.apache.giraph.master.TestMasterObserver.SimpleComputation
 
compute(Vertex<IntWritable, TestSwitchClasses.StatusValue, IntWritable>, Iterable<IntWritable>) - Method in class org.apache.giraph.master.TestSwitchClasses.Computation1
 
compute(Vertex<IntWritable, TestSwitchClasses.StatusValue, IntWritable>, Iterable<IntWritable>) - Method in class org.apache.giraph.master.TestSwitchClasses.Computation2
 
compute(Vertex<IntWritable, TestSwitchClasses.StatusValue, IntWritable>, Iterable<Writable>) - Method in class org.apache.giraph.master.TestSwitchClasses.Computation3
 
compute() - Method in class org.apache.giraph.master.TestSwitchClasses.SwitchingClassesMasterCompute
 
compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<LongWritable>) - Method in class org.apache.giraph.partition.TestPartitionStores.EmptyComputation
 
compute(Vertex<IntWritable, IntWritable, NullWritable>, Iterable<IntWritable>) - Method in class org.apache.giraph.partition.TestPartitionStores.TestOutOfCoreMessagesComputation
 
compute(Vertex<LongWritable, IntWritable, FloatWritable>, Iterable<FloatWritable>) - Method in class org.apache.giraph.TestCheckpointing.CheckpointComputation
 
compute() - Method in class org.apache.giraph.TestCheckpointing.CheckpointVertexMasterCompute
 
compute(Vertex<LongWritable, DoubleWritable, FloatWritable>, Iterable<DoubleWritable>) - Method in class org.apache.giraph.TestMaxSuperstep.InfiniteLoopComputation
 
compute(Vertex<IntWritable, IntWritable, NullWritable>, Iterable<NullWritable>) - Method in class org.apache.giraph.utils.ComputationCountEdges
 
compute(Vertex<I, V, E>, Iterable<M>) - Method in class org.apache.giraph.utils.NoOpComputation
 
ConnectedComponentsComputationTest - Class in org.apache.giraph.examples
ConnectedComponentsComputationTest() - Constructor for class org.apache.giraph.examples.ConnectedComponentsComputationTest
 
ConnectedComponentsComputationTestInMemory - Class in org.apache.giraph.examples
ConnectedComponentsComputationTestInMemory() - Constructor for class org.apache.giraph.examples.ConnectedComponentsComputationTestInMemory
 
ConnectionTest - Class in org.apache.giraph.comm
Test the netty connections
ConnectionTest() - Constructor for class org.apache.giraph.comm.ConnectionTest
 
connectOneClientToThreeServers() - Method in class org.apache.giraph.comm.ConnectionTest
Test connecting one client to three servers.
connectSingleClientServer() - Method in class org.apache.giraph.comm.ConnectionTest
Test connecting a single client to a single server.
connectSingleClientServer() - Method in class org.apache.giraph.comm.SaslConnectionTest
Test connecting a single client to a single server.
connectThreeClientsToOneServer() - Method in class org.apache.giraph.comm.ConnectionTest
Test connecting three clients to one server.
createBlock(GiraphConfiguration) - Method in class org.apache.giraph.block_app.framework.MultipleSimultanousMutationsTest.SendingAndAddEdgeBlockFactory
 
createBlock(GiraphConfiguration) - Method in class org.apache.giraph.block_app.framework.SendingMessagesTest.SendingMessagesToNeighborsBlockFactory
 
createBlock(GiraphConfiguration) - Method in class org.apache.giraph.block_app.framework.TestWorkerMessages.TestWorkerMessagesBlockFactory
 
createEdgeReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.gora.GoraTestEdgeInputFormat
Creates specific vertex reader to be used inside Hadoop.
createEdgeWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.gora.GoraTestEdgeOutputFormat
 
createExecutionStage(GiraphConfiguration) - Method in class org.apache.giraph.block_app.framework.TestLongNullNullBlockFactory
 
createInitialMessage() - Method in class org.apache.giraph.master.TestSwitchClasses.MinimumMessageCombiner
 
createInitialMessage() - Method in class org.apache.giraph.master.TestSwitchClasses.SumMessageCombiner
 
createInitialMessage() - Method in class org.apache.giraph.vertex.TestComputationTypes.GeneratedVertexMatchMessageCombiner
 
createInitialMessage() - Method in class org.apache.giraph.vertex.TestComputationTypes.GeneratedVertexMismatchMessageCombiner
 
createMultiMsgs() - Method in class org.apache.giraph.block_app.framework.SendingMessagesTest
 
createNewServerData(ImmutableClassesGiraphConfiguration, Mapper.Context) - Static method in class org.apache.giraph.utils.MockUtils
Prepare a ServerData object.
createVertex(String, Map<String, String>) - Static method in class org.apache.giraph.io.gora.GoraTestVertexInputFormat
Creates a vertex using an id and a set of edges.
createVertex(String, Map<String, String>) - Method in class org.apache.giraph.io.gora.GoraTestVertexOutputFormat.GoraGVertexVertexWriter
Creates a vertex using an id and a set of edges.
createVertexOnMsgsTest() - Method in class org.apache.giraph.block_app.framework.MultipleSimultanousMutationsTest
 
createVertexOnMsgsTest() - Method in class org.apache.giraph.block_app.framework.SendingMessagesTest
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.accumulo.edgemarker.AccumuloEdgeInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.gora.GoraTestVertexInputFormat
Creates specific vertex reader to be used inside Hadoop.
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.io.hbase.edgemarker.TableEdgeInputFormat
 
createVertexReader(RecordReader<LongWritable, Text>) - Method in class org.apache.giraph.io.TestLongDoubleDoubleAdjacencyListVertexInputFormat
 
createVertexReader(RecordReader<LongWritable, Text>, AdjacencyListTextVertexInputFormat.LineSanitizer) - Method in class org.apache.giraph.io.TestLongDoubleDoubleAdjacencyListVertexInputFormat
 
createVertexReader(RecordReader<LongWritable, Text>) - Method in class org.apache.giraph.io.TestTextDoubleDoubleAdjacencyListVertexInputFormat
 
createVertexReader(RecordReader<LongWritable, Text>, AdjacencyListTextVertexInputFormat.LineSanitizer) - Method in class org.apache.giraph.io.TestTextDoubleDoubleAdjacencyListVertexInputFormat
 
createVertexReader(InputSplit, TaskAttemptContext) - Method in class org.apache.giraph.master.TestMasterObserver.InputFormat
 
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.accumulo.edgemarker.AccumuloEdgeOutputFormat
 
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.gora.GoraTestVertexOutputFormat
 
createVertexWriter(TaskAttemptContext) - Method in class org.apache.giraph.io.hbase.edgemarker.TableEdgeOutputFormat
 
createVertexWriter(RecordWriter<Text, Text>) - Method in class org.apache.giraph.io.TestAdjacencyListTextVertexOutputFormat
 

D

defaultMap() - Static method in class org.apache.giraph.generate.GeneratePrimitiveClasses
 
DirectWritableSerializerCopyTest - Class in org.apache.giraph.writable.kryo
 
DirectWritableSerializerCopyTest() - Constructor for class org.apache.giraph.writable.kryo.DirectWritableSerializerCopyTest
 
doNotCreateVertexOnMsgsTest() - Method in class org.apache.giraph.block_app.framework.SendingMessagesTest
 
doSomethingAtMaster() - Method in class org.apache.giraph.block_app.framework.BlockApiHandleTest.DummyObjectWithApiHandle
 
doSomethingAtWorker() - Method in class org.apache.giraph.block_app.framework.BlockApiHandleTest.DummyObjectWithApiHandle
 
doSomethingAtWorkerContext() - Method in class org.apache.giraph.block_app.framework.BlockApiHandleTest.DummyObjectWithApiHandle
 
dropEdge(IntWritable, Edge<IntWritable, NullWritable>) - Method in class org.apache.giraph.io.TestFilters.EdgeFilter
 
dropVertex(Vertex<IntWritable, NullWritable, NullWritable>) - Method in class org.apache.giraph.io.TestFilters.VertexFilter
 
DummyComputation() - Constructor for class org.apache.giraph.io.TestAdjacencyListTextVertexOutputFormat.DummyComputation
 
DummyComputation() - Constructor for class org.apache.giraph.io.TestIdWithValueTextOutputFormat.DummyComputation
 
DummyComputation() - Constructor for class org.apache.giraph.io.TestLongDoubleDoubleAdjacencyListVertexInputFormat.DummyComputation
 
DummyComputation() - Constructor for class org.apache.giraph.io.TestSrcIdDstIdEdgeValueTextOutputFormat.DummyComputation
 
DummyComputation() - Constructor for class org.apache.giraph.io.TestTextDoubleDoubleAdjacencyListVertexInputFormat.DummyComputation
 
DummyObjectWithApiHandle(BlockApiHandle) - Constructor for class org.apache.giraph.block_app.framework.BlockApiHandleTest.DummyObjectWithApiHandle
 

E

EdgeFilter() - Constructor for class org.apache.giraph.io.TestFilters.EdgeFilter
 
EdgeNotification() - Constructor for class org.apache.giraph.io.accumulo.TestAccumuloVertexFormat.EdgeNotification
 
EdgeNotification() - Constructor for class org.apache.giraph.io.hbase.TestHBaseRootMarkerVertextFormat.EdgeNotification
 
EmptyComputation() - Constructor for class org.apache.giraph.io.gora.TestGoraEdgeInputFormat.EmptyComputation
 
EmptyComputation() - Constructor for class org.apache.giraph.io.gora.TestGoraEdgeOutputFormat.EmptyComputation
 
EmptyComputation() - Constructor for class org.apache.giraph.io.gora.TestGoraVertexInputFormat.EmptyComputation
 
EmptyComputation() - Constructor for class org.apache.giraph.partition.TestPartitionStores.EmptyComputation
 
EPSILON - Static variable in class org.apache.giraph.examples.RandomWalkTestUtils
Minimum difference between doubles

F

FIRST_PATH - Static variable in class org.apache.giraph.zk.TestZooKeeperExt
 

G

GeneratedVertexMatchMessageCombiner() - Constructor for class org.apache.giraph.vertex.TestComputationTypes.GeneratedVertexMatchMessageCombiner
 
GeneratedVertexMismatchMessageCombiner() - Constructor for class org.apache.giraph.vertex.TestComputationTypes.GeneratedVertexMismatchMessageCombiner
 
GeneratedVertexMismatchValueFactory() - Constructor for class org.apache.giraph.vertex.TestComputationTypes.GeneratedVertexMismatchValueFactory
 
GeneratePrimitiveClasses - Class in org.apache.giraph.generate
Code generation utility that generates set of classes from a template files.
GeneratePrimitiveClasses() - Constructor for class org.apache.giraph.generate.GeneratePrimitiveClasses
 
GeneratePrimitiveClasses.PrimitiveType - Enum in org.apache.giraph.generate
 
get() - Method in class org.apache.giraph.writable.kryo.KryoWritableTest.LongKryoWritable
 
getBoxed() - Method in enum org.apache.giraph.generate.GeneratePrimitiveClasses.PrimitiveType
 
getCallingMethodName() - Static method in class org.apache.giraph.BspCase
 
getCamel() - Method in enum org.apache.giraph.generate.GeneratePrimitiveClasses.PrimitiveType
 
getConfiguration() - Method in class org.apache.giraph.utils.MockUtils.MockedEnvironment
the injected hadoop configuration
getContext() - Method in class org.apache.giraph.utils.MockUtils.MockedEnvironment
the injected mapper context
getCurrentSourceId() - Method in class org.apache.giraph.io.gora.GoraTestEdgeInputFormat.GoraGEdgeEdgeReader
Gets the currentSourceId for the edge.
getCurrentVertex() - Method in class org.apache.giraph.io.accumulo.edgemarker.AccumuloEdgeInputFormat.AccumuloEdgeVertexReader
 
getCurrentVertex() - Method in class org.apache.giraph.io.hbase.edgemarker.TableEdgeInputFormat.TableEdgeVertexReader
For each row, create a vertex with the row ID as a text, and it's 'children' qualifier as a single edge.
getEdgeValueClass(GiraphConfiguration) - Method in class org.apache.giraph.block_app.framework.MultipleSimultanousMutationsTest.SendingAndAddEdgeBlockFactory
 
getEdgeValueClass(GiraphConfiguration) - Method in class org.apache.giraph.block_app.framework.TestLongNullNullBlockFactory
 
getEmptyDb() - Method in class org.apache.giraph.io.gora.TestGoraEdgeInputFormat
 
getEmptyDb() - Method in class org.apache.giraph.io.gora.TestGoraVertexInputFormat
 
getFinalSum() - Static method in class org.apache.giraph.TestCheckpointing.CheckpointVertexWorkerContext
 
getGoraEdge(LongWritable, DoubleWritable, Edge<LongWritable, FloatWritable>) - Method in class org.apache.giraph.io.gora.GoraTestEdgeOutputFormat.GoraGEdgeEdgeWriter
 
getGoraKey(LongWritable, DoubleWritable, Edge<LongWritable, FloatWritable>) - Method in class org.apache.giraph.io.gora.GoraTestEdgeOutputFormat.GoraGEdgeEdgeWriter
 
getGoraKey(Vertex<LongWritable, DoubleWritable, FloatWritable>) - Method in class org.apache.giraph.io.gora.GoraTestVertexOutputFormat.GoraGVertexVertexWriter
 
getGoraVertex(Vertex<LongWritable, DoubleWritable, FloatWritable>) - Method in class org.apache.giraph.io.gora.GoraTestVertexOutputFormat.GoraGVertexVertexWriter
 
getGraphState() - Method in class org.apache.giraph.utils.MockUtils.MockedEnvironment
the injected graph state
getLower() - Method in enum org.apache.giraph.generate.GeneratePrimitiveClasses.PrimitiveType
 
getMessageClass() - Method in class org.apache.giraph.block_app.framework.BlockApiHandleTest.TestPiece
 
getName() - Method in enum org.apache.giraph.generate.GeneratePrimitiveClasses.PrimitiveType
 
getNumResults(Configuration, Path) - Method in class org.apache.giraph.BspCase
Read all parts- files in the output and count their lines.
getNumWorkers() - Method in class org.apache.giraph.BspCase
Get the number of workers used in the BSP application
getSinglePartFileStatus(Configuration, Path) - Static method in class org.apache.giraph.BspCase
Get the single part file status and make sure there is only one part
getTempPath(String) - Method in class org.apache.giraph.BspCase
Create a temporary path
getTestDb() - Method in class org.apache.giraph.io.gora.TestGoraEdgeInputFormat
 
getTestDb() - Method in class org.apache.giraph.io.gora.TestGoraVertexInputFormat
 
getVertexIDClass(GiraphConfiguration) - Method in class org.apache.giraph.block_app.framework.TestLongNullNullBlockFactory
 
getVertexReceiver(BlockWorkerReceiveApi<WritableComparable>, Object) - Method in class org.apache.giraph.block_app.framework.BlockApiHandleTest.TestPiece
 
getVertexSender(BlockWorkerSendApi<WritableComparable, LongWritable, Writable, NullWritable>, Object) - Method in class org.apache.giraph.block_app.framework.BlockApiHandleTest.TestPiece
 
getVertexValueClass(GiraphConfiguration) - Method in class org.apache.giraph.block_app.framework.SendingMessagesTest.SendingMessagesToNeighborsBlockFactory
 
getVertexValueClass(GiraphConfiguration) - Method in class org.apache.giraph.block_app.framework.TestLongNullNullBlockFactory
 
getWorkerClientRequestProcessor() - Method in class org.apache.giraph.utils.MockUtils.MockedEnvironment
the injected worker communications
getWritingDb() - Method in class org.apache.giraph.io.gora.TestGoraEdgeOutputFormat
 
getWritingDb() - Method in class org.apache.giraph.io.gora.TestGoraVertexOutputFormat
 
getZooKeeperList() - Method in class org.apache.giraph.BspCase
Get the ZooKeeper list
GoraGEdgeEdgeReader() - Constructor for class org.apache.giraph.io.gora.GoraTestEdgeInputFormat.GoraGEdgeEdgeReader
 
GoraGEdgeEdgeWriter() - Constructor for class org.apache.giraph.io.gora.GoraTestEdgeOutputFormat.GoraGEdgeEdgeWriter
 
GoraGVertexVertexReader() - Constructor for class org.apache.giraph.io.gora.GoraTestVertexInputFormat.GoraGVertexVertexReader
 
GoraGVertexVertexWriter() - Constructor for class org.apache.giraph.io.gora.GoraTestVertexOutputFormat.GoraGVertexVertexWriter
 
GoraTestEdgeInputFormat - Class in org.apache.giraph.io.gora
Implementation of a specific reader for a generated data bean.
GoraTestEdgeInputFormat() - Constructor for class org.apache.giraph.io.gora.GoraTestEdgeInputFormat
Default constructor
GoraTestEdgeInputFormat.GoraGEdgeEdgeReader - Class in org.apache.giraph.io.gora
Gora edge reader
GoraTestEdgeOutputFormat - Class in org.apache.giraph.io.gora
Implementation of a specific writer for a generated data bean.
GoraTestEdgeOutputFormat() - Constructor for class org.apache.giraph.io.gora.GoraTestEdgeOutputFormat
Default constructor
GoraTestEdgeOutputFormat.GoraGEdgeEdgeWriter - Class in org.apache.giraph.io.gora
Gora edge writer.
GoraTestVertexInputFormat - Class in org.apache.giraph.io.gora
Implementation of a specific reader for a generated data bean.
GoraTestVertexInputFormat() - Constructor for class org.apache.giraph.io.gora.GoraTestVertexInputFormat
DEfault constructor
GoraTestVertexInputFormat.GoraGVertexVertexReader - Class in org.apache.giraph.io.gora
Gora vertex reader
GoraTestVertexOutputFormat - Class in org.apache.giraph.io.gora
Implementation of a specific reader for a generated data bean.
GoraTestVertexOutputFormat() - Constructor for class org.apache.giraph.io.gora.GoraTestVertexOutputFormat
DEfault constructor
GoraTestVertexOutputFormat.GoraGVertexVertexWriter - Class in org.apache.giraph.io.gora
Gora vertex writer.

H

hasNext() - Method in class org.apache.giraph.block_app.framework.block.BlockTestingUtils.CheckIterator
 
hasWritable() - Method in enum org.apache.giraph.generate.GeneratePrimitiveClasses.PrimitiveType
 

I

IncreasingBitSetTest - Class in org.apache.giraph.comm
Test IncreasingBitSetTest
IncreasingBitSetTest() - Constructor for class org.apache.giraph.comm.IncreasingBitSetTest
 
InfiniteLoopComputation() - Constructor for class org.apache.giraph.TestMaxSuperstep.InfiniteLoopComputation
 
initialize(Iterable<Edge<LongWritable, DoubleWritable>>) - Method in class org.apache.giraph.graph.TestVertexAndEdges.TestOutEdges
 
initialize(int) - Method in class org.apache.giraph.graph.TestVertexAndEdges.TestOutEdges
 
initialize() - Method in class org.apache.giraph.graph.TestVertexAndEdges.TestOutEdges
 
initialize() - Method in class org.apache.giraph.TestCheckpointing.CheckpointVertexMasterCompute
 
InputFormat() - Constructor for class org.apache.giraph.master.TestMasterObserver.InputFormat
 
instantiateOutEdges(Class<? extends OutEdges>) - Static method in class org.apache.giraph.graph.TestVertexAndEdges
 
instantiateVertex(Class<? extends OutEdges>) - Method in class org.apache.giraph.graph.TestByteValueVertex
 
instantiateVertex(Class<? extends OutEdges>) - Method in class org.apache.giraph.graph.TestVertexAndEdges
 
IntIntNullNoOpComputation - Class in org.apache.giraph.utils
Computation which does nothing, used for testing.
IntIntNullNoOpComputation() - Constructor for class org.apache.giraph.utils.IntIntNullNoOpComputation
 
IntNoOpComputation - Class in org.apache.giraph.utils
Computation which does nothing, used for testing.
IntNoOpComputation() - Constructor for class org.apache.giraph.utils.IntNoOpComputation
 
IntSumVertexValueCombiner() - Constructor for class org.apache.giraph.io.TestVertexEdgeInput.IntSumVertexValueCombiner
 
isFloating() - Method in enum org.apache.giraph.generate.GeneratePrimitiveClasses.PrimitiveType
 
isId() - Method in enum org.apache.giraph.generate.GeneratePrimitiveClasses.PrimitiveType
 
isNumeric() - Method in enum org.apache.giraph.generate.GeneratePrimitiveClasses.PrimitiveType
 
iterator() - Method in class org.apache.giraph.graph.TestVertexAndEdges.TestOutEdges
 

K

kryoSerDeser(T) - Static method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
KryoWritableTest - Class in org.apache.giraph.writable.kryo
Tests some subtle cases of kryo serialization.
KryoWritableTest() - Constructor for class org.apache.giraph.writable.kryo.KryoWritableTest
 
KryoWritableTest.LongKryoWritable - Class in org.apache.giraph.writable.kryo
 
KryoWritableTest.LongListKryoWritable - Class in org.apache.giraph.writable.kryo
 
KryoWritableTest.NestedKryoWritable<T> - Class in org.apache.giraph.writable.kryo
 
KryoWritableTest.TestClassA - Class in org.apache.giraph.writable.kryo
 
KryoWritableWrapperTest - Class in org.apache.giraph.writable.kryo
Tests some subtle cases of kryo serialization.
KryoWritableWrapperTest() - Constructor for class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 

L

LongDiffNullArrayEdgesTest - Class in org.apache.giraph.edge
 
LongDiffNullArrayEdgesTest() - Constructor for class org.apache.giraph.edge.LongDiffNullArrayEdgesTest
 
LongKryoWritable(long) - Constructor for class org.apache.giraph.writable.kryo.KryoWritableTest.LongKryoWritable
 
LongListKryoWritable(LongArrayList) - Constructor for class org.apache.giraph.writable.kryo.KryoWritableTest.LongListKryoWritable
 
LongNoOpComputation - Class in org.apache.giraph.utils
Computation which does nothing, used for testing.
LongNoOpComputation() - Constructor for class org.apache.giraph.utils.LongNoOpComputation
 

M

main(String[]) - Static method in class org.apache.giraph.generate.GeneratePrimitiveClasses
 
makeEdges(int...) - Static method in class org.apache.giraph.examples.ConnectedComponentsComputationTestInMemory
 
makeEdges(long...) - Static method in class org.apache.giraph.examples.scc.SccComputationTestInMemory
 
masterCompute(BlockMasterApi, Object) - Method in class org.apache.giraph.block_app.framework.BlockApiHandleTest.TestPiece
 
MaxComputationTest - Class in org.apache.giraph.examples
Test for max computation
MaxComputationTest() - Constructor for class org.apache.giraph.examples.MaxComputationTest
 
MinimumIntCombinerTest - Class in org.apache.giraph.examples
 
MinimumIntCombinerTest() - Constructor for class org.apache.giraph.examples.MinimumIntCombinerTest
 
MinimumMessageCombiner() - Constructor for class org.apache.giraph.master.TestSwitchClasses.MinimumMessageCombiner
 
MockedEnvironment() - Constructor for class org.apache.giraph.utils.MockUtils.MockedEnvironment
 
MockExceptionHandler - Class in org.apache.giraph.comm
 
MockExceptionHandler() - Constructor for class org.apache.giraph.comm.MockExceptionHandler
 
mockServiceGetVertexPartitionOwner(int) - Static method in class org.apache.giraph.utils.MockUtils
Prepare a mocked CentralizedServiceWorker.
MockUtils - Class in org.apache.giraph.utils
simplify mocking for unit testing vertices
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> - Class in org.apache.giraph.utils
mocks and holds "environment objects" that are injected into a vertex
MultipleSimultanousMutationsTest - Class in org.apache.giraph.block_app.framework
Test when vertex gets multiple simultaneous mutations (i.e.
MultipleSimultanousMutationsTest() - Constructor for class org.apache.giraph.block_app.framework.MultipleSimultanousMutationsTest
 
MultipleSimultanousMutationsTest.SendingAndAddEdgeBlockFactory - Class in org.apache.giraph.block_app.framework
 
MyComputation() - Constructor for class org.apache.giraph.partition.TestPartitionStores.MyComputation
 

N

name - Variable in class org.apache.giraph.conf.TestObjectCreation
 
NestedKryoWritable(KryoWritableTest.LongKryoWritable, T) - Constructor for class org.apache.giraph.writable.kryo.KryoWritableTest.NestedKryoWritable
 
newInstance() - Method in class org.apache.giraph.io.TestVertexEdgeInput.TestVertexValueFactory
 
newInstance() - Method in class org.apache.giraph.vertex.TestComputationTypes.GeneratedVertexMismatchValueFactory
 
next() - Method in class org.apache.giraph.block_app.framework.block.BlockTestingUtils.CheckIterator
 
nextVertex() - Method in class org.apache.giraph.io.accumulo.edgemarker.AccumuloEdgeInputFormat.AccumuloEdgeVertexReader
 
nextVertex() - Method in class org.apache.giraph.io.hbase.edgemarker.TableEdgeInputFormat.TableEdgeVertexReader
 
NoOpComputation() - Constructor for class org.apache.giraph.master.TestComputationCombinerTypes.NoOpComputation
 
NoOpComputation<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.utils
Computation which does nothing, just halts, used for testing
NoOpComputation() - Constructor for class org.apache.giraph.utils.NoOpComputation
 

O

ObjectStripingTest - Class in org.apache.giraph.block_app.reducers.array
 
ObjectStripingTest() - Constructor for class org.apache.giraph.block_app.reducers.array.ObjectStripingTest
 
Obs() - Constructor for class org.apache.giraph.master.TestMasterObserver.Obs
 
org.apache.giraph - package org.apache.giraph
 
org.apache.giraph.aggregators - package org.apache.giraph.aggregators
 
org.apache.giraph.aggregators.matrix.dense - package org.apache.giraph.aggregators.matrix.dense
 
org.apache.giraph.aggregators.matrix.sparse - package org.apache.giraph.aggregators.matrix.sparse
 
org.apache.giraph.block_app.framework - package org.apache.giraph.block_app.framework
 
org.apache.giraph.block_app.framework.block - package org.apache.giraph.block_app.framework.block
 
org.apache.giraph.block_app.reducers.array - package org.apache.giraph.block_app.reducers.array
 
org.apache.giraph.comm - package org.apache.giraph.comm
 
org.apache.giraph.comm.messages - package org.apache.giraph.comm.messages
 
org.apache.giraph.comm.messages.queue - package org.apache.giraph.comm.messages.queue
 
org.apache.giraph.conf - package org.apache.giraph.conf
 
org.apache.giraph.edge - package org.apache.giraph.edge
 
org.apache.giraph.examples - package org.apache.giraph.examples
 
org.apache.giraph.examples.block_app - package org.apache.giraph.examples.block_app
Package of tests for Giraph examples for Block Applications.
org.apache.giraph.examples.scc - package org.apache.giraph.examples.scc
 
org.apache.giraph.generate - package org.apache.giraph.generate
 
org.apache.giraph.graph - package org.apache.giraph.graph
 
org.apache.giraph.io - package org.apache.giraph.io
 
org.apache.giraph.io.accumulo - package org.apache.giraph.io.accumulo
 
org.apache.giraph.io.accumulo.edgemarker - package org.apache.giraph.io.accumulo.edgemarker
 
org.apache.giraph.io.gora - package org.apache.giraph.io.gora
 
org.apache.giraph.io.hbase - package org.apache.giraph.io.hbase
 
org.apache.giraph.io.hbase.edgemarker - package org.apache.giraph.io.hbase.edgemarker
 
org.apache.giraph.io.hcatalog - package org.apache.giraph.io.hcatalog
 
org.apache.giraph.jython - package org.apache.giraph.jython
 
org.apache.giraph.master - package org.apache.giraph.master
 
org.apache.giraph.partition - package org.apache.giraph.partition
 
org.apache.giraph.reducers.impl - package org.apache.giraph.reducers.impl
 
org.apache.giraph.types - package org.apache.giraph.types
 
org.apache.giraph.types.heaps - package org.apache.giraph.types.heaps
 
org.apache.giraph.utils - package org.apache.giraph.utils
 
org.apache.giraph.utils.hashing - package org.apache.giraph.utils.hashing
 
org.apache.giraph.vertex - package org.apache.giraph.vertex
 
org.apache.giraph.writable.kryo - package org.apache.giraph.writable.kryo
 
org.apache.giraph.yarn - package org.apache.giraph.yarn
 
org.apache.giraph.zk - package org.apache.giraph.zk
 

P

PageRankComputationTest - Class in org.apache.giraph.examples
PageRankComputationTest() - Constructor for class org.apache.giraph.examples.PageRankComputationTest
 
parseSteadyStateProbabilities(Iterable<String>) - Static method in class org.apache.giraph.examples.RandomWalkTestUtils
Parse steady state probabilities.
postApp - Static variable in class org.apache.giraph.master.TestMasterObserver.Obs
 
postApplication() - Method in class org.apache.giraph.master.TestMasterObserver.Obs
 
postApplication() - Method in class org.apache.giraph.TestCheckpointing.CheckpointVertexWorkerContext
 
postSuperstep - Static variable in class org.apache.giraph.master.TestMasterObserver.Obs
 
postSuperstep(long) - Method in class org.apache.giraph.master.TestMasterObserver.Obs
 
postSuperstep() - Method in class org.apache.giraph.TestCheckpointing.CheckpointVertexWorkerContext
 
preApp - Static variable in class org.apache.giraph.master.TestMasterObserver.Obs
 
preApplication() - Method in class org.apache.giraph.master.TestMasterObserver.Obs
 
prepare() - Method in class org.apache.giraph.comm.messages.TestIntFloatPrimitiveMessageStores
 
prepare() - Method in class org.apache.giraph.comm.messages.TestLongDoublePrimitiveMessageStores
 
prepare() - Method in class org.apache.giraph.comm.TestMessageStores
 
prepareConf() - Method in class org.apache.giraph.examples.BrachaTouegDeadlockComputationTest
 
prepareJob(String, GiraphConfiguration) - Method in class org.apache.giraph.BspCase
Prepare a GiraphJob for test purposes
prepareJob(String, GiraphConfiguration, Path) - Method in class org.apache.giraph.BspCase
Prepare a GiraphJob for test purposes
prepareTest() - Method in class org.apache.giraph.TestOutOfCore
 
prepareVertexAndComputation(Vertex<I, V, E>, I, V, boolean, Computation<I, V, E, M, M>, long) - Static method in class org.apache.giraph.utils.MockUtils
prepare a vertex and computation for use in a unit test by setting its internal state and injecting mocked dependencies,
preSuperstep - Static variable in class org.apache.giraph.master.TestMasterObserver.Obs
 
preSuperstep(long) - Method in class org.apache.giraph.master.TestMasterObserver.Obs
 
preSuperstep() - Method in class org.apache.giraph.TestCheckpointing.CheckpointVertexWorkerContext
 
process(WatchedEvent) - Method in class org.apache.giraph.BspCase
 
process(WatchedEvent) - Method in class org.apache.giraph.yarn.TestYarnJob
Logging this stuff will help you debug integration test issues.
process(WatchedEvent) - Method in class org.apache.giraph.zk.TestZooKeeperExt
 

R

RandomWalkTestUtils - Class in org.apache.giraph.examples
 
RandomWalkTestUtils() - Constructor for class org.apache.giraph.examples.RandomWalkTestUtils
 
RandomWalkWithRestartComputationTest - Class in org.apache.giraph.examples
RandomWalkWithRestartComputationTest() - Constructor for class org.apache.giraph.examples.RandomWalkWithRestartComputationTest
 
READER_VERTICES_OPT - Static variable in class org.apache.giraph.BspCase
 
readFields(DataInput) - Method in class org.apache.giraph.graph.TestVertexAndEdges.TestOutEdges
 
readFields(DataInput) - Method in class org.apache.giraph.master.TestSwitchClasses.StatusValue
 
readFields(DataInput) - Method in class org.apache.giraph.TestCheckpointing.CheckpointVertexMasterCompute
 
readFields(DataInput) - Method in class org.apache.giraph.TestCheckpointing.CheckpointVertexWorkerContext
 
remove() - Method in class org.apache.giraph.block_app.framework.block.BlockTestingUtils.CheckIterator
 
remove(LongWritable) - Method in class org.apache.giraph.graph.TestVertexAndEdges.TestOutEdges
 
removeAndSetOutput(GiraphJob, Path) - Static method in class org.apache.giraph.BspCase
Helper method to remove an old output directory if it exists, and set the output path for any VertexOutputFormat that uses FileOutputFormat.
REPEAT_TIMES - Static variable in class org.apache.giraph.block_app.framework.block.TestRepeatBlock
 
REPEAT_TIMES - Static variable in class org.apache.giraph.block_app.framework.block.TestRepeatUntilBlock
 
REPS - Static variable in class org.apache.giraph.graph.TestVertexAndEdges
Number of repetitions.
RequestFailureTest - Class in org.apache.giraph.comm
Test all the netty failure scenarios
RequestFailureTest() - Constructor for class org.apache.giraph.comm.RequestFailureTest
 
RequestTest - Class in org.apache.giraph.comm
Test all the different netty requests.
RequestTest() - Constructor for class org.apache.giraph.comm.RequestTest
 
resendRequest() - Method in class org.apache.giraph.comm.RequestFailureTest
 
resolve(WritableComparable, Vertex, VertexChanges, boolean) - Method in class org.apache.giraph.TestMutateGraph.TestVertexResolver
 
runningInDistributedMode() - Method in class org.apache.giraph.BspCase
Are the tests executed on a real hadoop instance?

S

SaslConnectionTest - Class in org.apache.giraph.comm
Netty connection with mocked authentication.
SaslConnectionTest() - Constructor for class org.apache.giraph.comm.SaslConnectionTest
 
SccComputationTestInMemory - Class in org.apache.giraph.examples.scc
Tests for SccComputation
SccComputationTestInMemory() - Constructor for class org.apache.giraph.examples.scc.SccComputationTestInMemory
 
send2Requests() - Method in class org.apache.giraph.comm.RequestFailureTest
 
SendingAndAddEdgeBlockFactory() - Constructor for class org.apache.giraph.block_app.framework.MultipleSimultanousMutationsTest.SendingAndAddEdgeBlockFactory
 
SendingMessagesTest - Class in org.apache.giraph.block_app.framework
 
SendingMessagesTest() - Constructor for class org.apache.giraph.block_app.framework.SendingMessagesTest
 
SendingMessagesTest.SendingMessagesToNeighborsBlockFactory - Class in org.apache.giraph.block_app.framework
 
SendingMessagesToNeighborsBlockFactory() - Constructor for class org.apache.giraph.block_app.framework.SendingMessagesTest.SendingMessagesToNeighborsBlockFactory
 
sendPartitionMutationsRequest() - Method in class org.apache.giraph.comm.RequestTest
 
sendVertexPartition() - Method in class org.apache.giraph.comm.RequestTest
 
sendWorkerIndividualMessagesRequest() - Method in class org.apache.giraph.comm.RequestTest
 
sendWorkerMessagesRequest() - Method in class org.apache.giraph.comm.RequestTest
 
set(long) - Method in class org.apache.giraph.writable.kryo.KryoWritableTest.LongKryoWritable
 
setUp() - Method in class org.apache.giraph.BspCase
 
setUp() - Method in class org.apache.giraph.comm.ConnectionTest
 
setUp() - Method in class org.apache.giraph.comm.RequestFailureTest
 
setUp() - Method in class org.apache.giraph.comm.RequestTest
 
setUp() - Method in class org.apache.giraph.comm.SaslConnectionTest
 
setUp() - Method in class org.apache.giraph.conf.TestObjectCreation
 
setUp() - Method in class org.apache.giraph.edge.TestMultiGraphEdges
 
setUp() - Method in class org.apache.giraph.edge.TestMultiRandomAccessEdges
 
setUp() - Method in class org.apache.giraph.edge.TestNullValueEdges
 
setUp() - Method in class org.apache.giraph.edge.TestStrictGraphEdges
 
setUp() - Method in class org.apache.giraph.edge.TestStrictRandomAccessEdges
 
setUp() - Method in class org.apache.giraph.graph.TestVertexAndEdges
 
setUp() - Method in class org.apache.giraph.io.TestAdjacencyListTextVertexOutputFormat
 
setUp() - Method in class org.apache.giraph.io.TestIdWithValueTextOutputFormat
 
setUp() - Method in class org.apache.giraph.io.TestLongDoubleDoubleAdjacencyListVertexInputFormat
 
setUp() - Method in class org.apache.giraph.io.TestSrcIdDstIdEdgeValueTextOutputFormat
 
setUp() - Method in class org.apache.giraph.io.TestTextDoubleDoubleAdjacencyListVertexInputFormat
 
setUp() - Method in class org.apache.giraph.partition.TestGiraphTransferRegulator
 
setUp() - Method in class org.apache.giraph.partition.TestPartitionStores
 
setUp() - Method in class org.apache.giraph.zk.TestPredicateLock
 
setUp() - Method in class org.apache.giraph.zk.TestZooKeeperExt
 
setupConfiguration(GiraphJob) - Method in class org.apache.giraph.BspCase
Adjust the configuration to the basic test case
SimpleComputation() - Constructor for class org.apache.giraph.master.TestMasterObserver.SimpleComputation
 
SimpleRangePartitionFactoryTest - Class in org.apache.giraph.partition
SimpleRangePartitionFactoryTest() - Constructor for class org.apache.giraph.partition.SimpleRangePartitionFactoryTest
 
SimpleShortestPathsComputationTest - Class in org.apache.giraph.examples
Contains a simple unit test for SimpleShortestPathsComputation
SimpleShortestPathsComputationTest() - Constructor for class org.apache.giraph.examples.SimpleShortestPathsComputationTest
 
SimpleTriangleClosingComputationTest - Class in org.apache.giraph.examples
Contains a simple unit test for SimpleTriangleClosingComputation
SimpleTriangleClosingComputationTest() - Constructor for class org.apache.giraph.examples.SimpleTriangleClosingComputationTest
 
size() - Method in class org.apache.giraph.graph.TestVertexAndEdges.TestOutEdges
 
StatusValue() - Constructor for class org.apache.giraph.master.TestSwitchClasses.StatusValue
 
SumLongVertexValueCombiner() - Constructor for class org.apache.giraph.utils.TestTestGraph.SumLongVertexValueCombiner
 
SumMessageCombiner() - Constructor for class org.apache.giraph.master.TestSwitchClasses.SumMessageCombiner
 
SwitchingClassesMasterCompute() - Constructor for class org.apache.giraph.master.TestSwitchClasses.SwitchingClassesMasterCompute
 

T

TableEdgeInputFormat - Class in org.apache.giraph.io.hbase.edgemarker
Test subclass for HBaseVertexInputFormat.
TableEdgeInputFormat() - Constructor for class org.apache.giraph.io.hbase.edgemarker.TableEdgeInputFormat
 
TableEdgeInputFormat.TableEdgeVertexReader - Class in org.apache.giraph.io.hbase.edgemarker
Uses the RecordReader to return Hbase rows
TableEdgeOutputFormat - Class in org.apache.giraph.io.hbase.edgemarker
 
TableEdgeOutputFormat() - Constructor for class org.apache.giraph.io.hbase.edgemarker.TableEdgeOutputFormat
 
TableEdgeOutputFormat.TableEdgeVertexWriter - Class in org.apache.giraph.io.hbase.edgemarker
 
TableEdgeVertexReader(InputSplit, TaskAttemptContext) - Constructor for class org.apache.giraph.io.hbase.edgemarker.TableEdgeInputFormat.TableEdgeVertexReader
 
TableEdgeVertexWriter(TaskAttemptContext) - Constructor for class org.apache.giraph.io.hbase.edgemarker.TableEdgeOutputFormat.TableEdgeVertexWriter
 
tearDown() - Method in class org.apache.giraph.BspCase
 
tearDown() - Method in class org.apache.giraph.zk.TestZooKeeperExt
 
test() - Method in class org.apache.giraph.block_app.reducers.array.ObjectStripingTest
 
test1() - Method in class org.apache.giraph.writable.kryo.DirectWritableSerializerCopyTest
 
test2() - Method in class org.apache.giraph.writable.kryo.DirectWritableSerializerCopyTest
 
TEST_JOB_ID - Static variable in class org.apache.giraph.TestCheckpointing
ID to be used with test job
testAccumuloInputOutput() - Method in class org.apache.giraph.io.accumulo.TestAccumuloVertexFormat
 
TestAccumuloVertexFormat - Class in org.apache.giraph.io.accumulo
 
TestAccumuloVertexFormat() - Constructor for class org.apache.giraph.io.accumulo.TestAccumuloVertexFormat
Create the test case
TestAccumuloVertexFormat.EdgeNotification - Class in org.apache.giraph.io.accumulo
 
testAddedSmalerValues() - Method in class org.apache.giraph.edge.LongDiffNullArrayEdgesTest
 
testAddToClasses() - Method in class org.apache.giraph.conf.TestGiraphConfiguration
 
TestAdjacencyListTextVertexOutputFormat - Class in org.apache.giraph.io
 
TestAdjacencyListTextVertexOutputFormat() - Constructor for class org.apache.giraph.io.TestAdjacencyListTextVertexOutputFormat
 
TestAdjacencyListTextVertexOutputFormat.DummyComputation - Class in org.apache.giraph.io
Dummy class to allow ImmutableClassesGiraphConfiguration to be created.
testAggregatorsCheckpointing() - Method in class org.apache.giraph.aggregators.TestAggregatorsHandling
Test if aggregators are are handled properly when restarting from a checkpoint
TestAggregatorsHandling - Class in org.apache.giraph.aggregators
Tests if aggregators are handled on a proper way
TestAggregatorsHandling() - Constructor for class org.apache.giraph.aggregators.TestAggregatorsHandling
 
testAggregatorsHandling() - Method in class org.apache.giraph.aggregators.TestAggregatorsHandling
Tests if aggregators are handled on a proper way during supersteps
testAllMatchWithCombiner() - Method in class org.apache.giraph.master.TestComputationCombinerTypes
 
testAllMatchWithoutCombiner() - Method in class org.apache.giraph.master.TestComputationCombinerTypes
 
testAndAggregator() - Method in class org.apache.giraph.aggregators.TestBooleanAggregators
 
testArraysAsList() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testArraysAsListMultiRef() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testAsyncMessageStoreCheckpoint() - Method in class org.apache.giraph.TestCheckpointing
 
testAsyncQueue() - Method in class org.apache.giraph.comm.messages.queue.AsyncMessageStoreWrapperTest
 
TestAutoCheckpoint - Class in org.apache.giraph
Unit test for automated checkpoint restarting
TestAutoCheckpoint() - Constructor for class org.apache.giraph.TestAutoCheckpoint
 
testAvoidOverflowWithZero() - Method in class org.apache.giraph.edge.LongDiffNullArrayEdgesTest
 
testBasic() - Method in class org.apache.giraph.jython.TestJythonBasic
 
testBasicSet() - Method in class org.apache.giraph.types.TestCollections
 
testBlacklistedClasses() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testBlockApiHandle() - Method in class org.apache.giraph.block_app.framework.BlockApiHandleTest
 
TestBooleanAggregators - Class in org.apache.giraph.aggregators
 
TestBooleanAggregators() - Constructor for class org.apache.giraph.aggregators.TestBooleanAggregators
 
TestBspBasic - Class in org.apache.giraph
Unit test for many simple BSP applications.
TestBspBasic() - Constructor for class org.apache.giraph.TestBspBasic
 
testBspCheckpoint() - Method in class org.apache.giraph.TestCheckpointing
 
testBspCheckpoint(boolean) - Method in class org.apache.giraph.TestCheckpointing
 
testBspCheckpoint() - Method in class org.apache.giraph.TestManualCheckpoint
Run a sample BSP job locally and test checkpointing.
testBspCombiner() - Method in class org.apache.giraph.TestBspBasic
Run a sample BSP job locally with message combiner and checkout output value.
testBspFail() - Method in class org.apache.giraph.TestBspBasic
Run a sample BSP job in JobTracker, kill a task, and make sure the job fails (not enough attempts to restart)
testBspMasterCompute() - Method in class org.apache.giraph.TestBspBasic
Run a sample BSP job locally and test MasterCompute.
testBspMigrationToBlocksFramework() - Method in class org.apache.giraph.examples.block_app.TestMigrationBspBasic
Run a sample BSP job locally and test using migration library for Blocks Framework, as an drop-in replacement.
testBspMsg() - Method in class org.apache.giraph.TestBspBasic
Run a sample BSP job locally and test messages.
testBspPageRankSingleCompute() - Method in class org.apache.giraph.examples.TestPageRank
 
testBspPageRankWithAggregatorWriter() - Method in class org.apache.giraph.TestBspBasic
Run a sample BSP job locally and test PageRank with AggregatorWriter.
testBspShortestPaths() - Method in class org.apache.giraph.TestBspBasic
Run a sample BSP job locally and test shortest paths.
testBspSuperStep() - Method in class org.apache.giraph.TestBspBasic
Run a sample BSP job locally and test supersteps.
testByteArrayMessagesPerVertexStore() - Method in class org.apache.giraph.comm.TestMessageStores
 
TestByteValueVertex - Class in org.apache.giraph.graph
Tests whether ByteValueVertex works -- same test as for DefaultVertex but with different factory method for vertices.
TestByteValueVertex() - Constructor for class org.apache.giraph.graph.TestByteValueVertex
 
testCachedValue() - Method in class org.apache.giraph.graph.TestByteValueVertex
 
TestCheckpointing - Class in org.apache.giraph
Tests that worker context and master computation are properly saved and loaded back at checkpoint.
TestCheckpointing() - Constructor for class org.apache.giraph.TestCheckpointing
Create the test case
TestCheckpointing.CheckpointComputation - Class in org.apache.giraph
Actual computation.
TestCheckpointing.CheckpointVertexMasterCompute - Class in org.apache.giraph
Master compute
TestCheckpointing.CheckpointVertexWorkerContext - Class in org.apache.giraph
Worker context associated.
TestClassA(String, List, int) - Constructor for class org.apache.giraph.writable.kryo.KryoWritableTest.TestClassA
 
TestClassA() - Constructor for class org.apache.giraph.writable.kryo.KryoWritableTest.TestClassA
 
TestCollections - Class in org.apache.giraph.types
Test basic collections
TestCollections() - Constructor for class org.apache.giraph.types.TestCollections
 
testCollectionsNCopiesList() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testCollectionsNCopiesObjectList() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testCombiner() - Method in class org.apache.giraph.examples.MinimumIntCombinerTest
 
TestComputation() - Constructor for class org.apache.giraph.graph.TestVertexAndEdges.TestComputation
 
TestComputation() - Constructor for class org.apache.giraph.partition.TestGiraphTransferRegulator.TestComputation
 
TestComputationCheckEdgesType() - Constructor for class org.apache.giraph.io.TestVertexEdgeInput.TestComputationCheckEdgesType
 
TestComputationCombinerTypes - Class in org.apache.giraph.master
Test type verification when switching computation and combiner types
TestComputationCombinerTypes() - Constructor for class org.apache.giraph.master.TestComputationCombinerTypes
 
TestComputationCombinerTypes.NoOpComputation<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> - Class in org.apache.giraph.master
 
TestComputationState - Class in org.apache.giraph
 
TestComputationState() - Constructor for class org.apache.giraph.TestComputationState
 
testComputationState() - Method in class org.apache.giraph.TestComputationState
 
TestComputationTypes - Class in org.apache.giraph.vertex
 
TestComputationTypes() - Constructor for class org.apache.giraph.vertex.TestComputationTypes
 
TestComputationTypes.GeneratedVertexMatchMessageCombiner - Class in org.apache.giraph.vertex
Matches the GeneratedComputationMatch
TestComputationTypes.GeneratedVertexMismatchMessageCombiner - Class in org.apache.giraph.vertex
Mismatches the GeneratedComputationMatch
TestComputationTypes.GeneratedVertexMismatchValueFactory - Class in org.apache.giraph.vertex
Mismatches the GeneratedComputationMatch
testConfigurable() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testConfiguration() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testConstructorNewInstance() - Method in class org.apache.giraph.conf.TestObjectCreation
 
testContinue() - Method in class org.apache.giraph.io.TestJsonBase64Format
Start a job and finish after i supersteps, then begin a new job and continue on more j supersteps.
testCountEdges(Class<? extends MessageStoreFactory>) - Method in class org.apache.giraph.jython.TestJythonComputation
 
testCountEdgesInMemoryMessageStoreFactory() - Method in class org.apache.giraph.jython.TestJythonComputation
 
testCreateClass() - Method in class org.apache.giraph.conf.TestObjectCreation
 
testCreateExt() - Method in class org.apache.giraph.zk.TestZooKeeperExt
 
TestCreateSourceVertex - Class in org.apache.giraph.io
Test createSourceVertex configuration option
TestCreateSourceVertex() - Constructor for class org.apache.giraph.io.TestCreateSourceVertex
 
testDeleteExt() - Method in class org.apache.giraph.zk.TestZooKeeperExt
 
testDerivedInputFormatType() - Method in class org.apache.giraph.vertex.TestComputationTypes
 
testDerivedMatchingType() - Method in class org.apache.giraph.vertex.TestComputationTypes
 
testDifferentCombinerIdType() - Method in class org.apache.giraph.master.TestComputationCombinerTypes
 
testDifferentCombinerMessageType() - Method in class org.apache.giraph.master.TestComputationCombinerTypes
 
testDifferentEdgeDataTypes() - Method in class org.apache.giraph.master.TestComputationCombinerTypes
 
testDifferentIdTypes() - Method in class org.apache.giraph.master.TestComputationCombinerTypes
 
testDifferentInputEdgesClass() - Method in class org.apache.giraph.io.TestVertexEdgeInput
 
testDifferentMessageTypes() - Method in class org.apache.giraph.master.TestComputationCombinerTypes
 
testDifferentSeparators() - Method in class org.apache.giraph.io.TestLongDoubleDoubleAdjacencyListVertexInputFormat
 
testDifferentSeparators() - Method in class org.apache.giraph.io.TestTextDoubleDoubleAdjacencyListVertexInputFormat
 
testDifferentVertexValueTypes() - Method in class org.apache.giraph.master.TestComputationCombinerTypes
 
testDiskBackedPartitionStore() - Method in class org.apache.giraph.partition.TestPartitionStores
 
testDiskBackedPartitionStoreAdaptiveOOC() - Method in class org.apache.giraph.partition.TestPartitionStores
 
testDiskBackedPartitionStoreComputation() - Method in class org.apache.giraph.partition.TestPartitionStores
 
testDiskBackedPartitionStoreMT() - Method in class org.apache.giraph.partition.TestPartitionStores
 
testDiskBackedPartitionStoreMTStatic() - Method in class org.apache.giraph.partition.TestPartitionStores
 
testDiskBackedPartitionStoreWithByteArrayComputation() - Method in class org.apache.giraph.partition.TestPartitionStores
 
testDiskBackedPartitionStoreWithByteArrayPartition() - Method in class org.apache.giraph.partition.TestPartitionStores
 
TestDoubleAggregators - Class in org.apache.giraph.aggregators
 
TestDoubleAggregators() - Constructor for class org.apache.giraph.aggregators.TestDoubleAggregators
 
TestDoubleDenseMatrix - Class in org.apache.giraph.aggregators.matrix.dense
 
TestDoubleDenseMatrix() - Constructor for class org.apache.giraph.aggregators.matrix.dense.TestDoubleDenseMatrix
 
TestDoubleSparseMatrix - Class in org.apache.giraph.aggregators.matrix.sparse
 
TestDoubleSparseMatrix() - Constructor for class org.apache.giraph.aggregators.matrix.sparse.TestDoubleSparseMatrix
 
testEdgeCombineWithByteArrayPartition() - Method in class org.apache.giraph.partition.TestPartitionStores
 
testEdgeCombineWithSimplePartition() - Method in class org.apache.giraph.partition.TestPartitionStores
 
testEdgeFilter() - Method in class org.apache.giraph.io.TestFilters
 
testEdges() - Method in class org.apache.giraph.edge.LongDiffNullArrayEdgesTest
 
testEdges() - Method in class org.apache.giraph.edge.TestNullValueEdges
 
testEdges() - Method in class org.apache.giraph.graph.TestVertexAndEdges
Test the provided OutEdges implementations for instantiation, initialization, edge addition, and edge removal.
testEdgesMustHaveValues() - Method in class org.apache.giraph.io.TestLongDoubleDoubleAdjacencyListVertexInputFormat
 
testEdgesMustHaveValues() - Method in class org.apache.giraph.io.TestTextDoubleDoubleAdjacencyListVertexInputFormat
 
testEdgesOnly() - Method in class org.apache.giraph.io.TestVertexEdgeInput
 
testEdgesOnlyWithReverse() - Method in class org.apache.giraph.io.TestVertexEdgeInput
 
testEdgeValues() - Method in class org.apache.giraph.edge.LongDiffNullArrayEdgesTest
 
testEmptyGraph() - Method in class org.apache.giraph.examples.BrachaTouegDeadlockComputationTest
 
testEmptyVertexInputFormat() - Method in class org.apache.giraph.TestBspBasic
Run a sample BSP job locally with no vertices and make sure it completes.
testEvent() - Method in class org.apache.giraph.zk.TestPredicateLock
Single threaded case where the event is signaled.
testFailSafeOnPotentialOverflow() - Method in class org.apache.giraph.edge.LongDiffNullArrayEdgesTest
 
testFastutil2ObjMap() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testFastutilFloatList() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testFastutilLongList() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testFastutilMap() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testFastutilSet() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
TestFilters - Class in org.apache.giraph.io
 
TestFilters() - Constructor for class org.apache.giraph.io.TestFilters
 
TestFilters.EdgeFilter - Class in org.apache.giraph.io
 
TestFilters.VertexFilter - Class in org.apache.giraph.io
 
testFiveNodesAllNodesBlockedNOutOfMGraph() - Method in class org.apache.giraph.examples.BrachaTouegDeadlockComputationTest
 
testFiveNodesAllNodesFreeNOutOfMGraph() - Method in class org.apache.giraph.examples.BrachaTouegDeadlockComputationTest
 
TestFixedCapacityIntByteMinHeap - Class in org.apache.giraph.types.heaps
 
TestFixedCapacityIntByteMinHeap() - Constructor for class org.apache.giraph.types.heaps.TestFixedCapacityIntByteMinHeap
 
TestFixedCapacityIntDoubleMinHeap - Class in org.apache.giraph.types.heaps
 
TestFixedCapacityIntDoubleMinHeap() - Constructor for class org.apache.giraph.types.heaps.TestFixedCapacityIntDoubleMinHeap
 
TestFixedCapacityIntFloatMinHeap - Class in org.apache.giraph.types.heaps
 
TestFixedCapacityIntFloatMinHeap() - Constructor for class org.apache.giraph.types.heaps.TestFixedCapacityIntFloatMinHeap
 
TestFixedCapacityIntIntMinHeap - Class in org.apache.giraph.types.heaps
 
TestFixedCapacityIntIntMinHeap() - Constructor for class org.apache.giraph.types.heaps.TestFixedCapacityIntIntMinHeap
 
TestFixedCapacityIntLongMinHeap - Class in org.apache.giraph.types.heaps
 
TestFixedCapacityIntLongMinHeap() - Constructor for class org.apache.giraph.types.heaps.TestFixedCapacityIntLongMinHeap
 
TestFixedCapacityLongByteMinHeap - Class in org.apache.giraph.types.heaps
 
TestFixedCapacityLongByteMinHeap() - Constructor for class org.apache.giraph.types.heaps.TestFixedCapacityLongByteMinHeap
 
TestFixedCapacityLongDoubleMinHeap - Class in org.apache.giraph.types.heaps
 
TestFixedCapacityLongDoubleMinHeap() - Constructor for class org.apache.giraph.types.heaps.TestFixedCapacityLongDoubleMinHeap
 
TestFixedCapacityLongFloatMinHeap - Class in org.apache.giraph.types.heaps
 
TestFixedCapacityLongFloatMinHeap() - Constructor for class org.apache.giraph.types.heaps.TestFixedCapacityLongFloatMinHeap
 
TestFixedCapacityLongIntMinHeap - Class in org.apache.giraph.types.heaps
 
TestFixedCapacityLongIntMinHeap() - Constructor for class org.apache.giraph.types.heaps.TestFixedCapacityLongIntMinHeap
 
TestFixedCapacityLongLongMinHeap - Class in org.apache.giraph.types.heaps
 
TestFixedCapacityLongLongMinHeap() - Constructor for class org.apache.giraph.types.heaps.TestFixedCapacityLongLongMinHeap
 
TestFloatAggregators - Class in org.apache.giraph.aggregators
 
TestFloatAggregators() - Constructor for class org.apache.giraph.aggregators.TestFloatAggregators
 
TestFloatDenseMatrix - Class in org.apache.giraph.aggregators.matrix.dense
 
TestFloatDenseMatrix() - Constructor for class org.apache.giraph.aggregators.matrix.dense.TestFloatDenseMatrix
 
TestFloatSparseMatrix - Class in org.apache.giraph.aggregators.matrix.sparse
 
TestFloatSparseMatrix() - Constructor for class org.apache.giraph.aggregators.matrix.sparse.TestFloatSparseMatrix
 
testGenerateNameAndParseIt() - Method in class org.apache.giraph.zk.ComputationDoneNameTest
 
testGetBasePath() - Method in class org.apache.giraph.zk.TestZooKeeperManager
 
testGetChildrenExt() - Method in class org.apache.giraph.zk.TestZooKeeperExt
 
testGetsCalled() - Method in class org.apache.giraph.master.TestMasterObserver
 
TestGiraphConfiguration - Class in org.apache.giraph.conf
 
TestGiraphConfiguration() - Constructor for class org.apache.giraph.conf.TestGiraphConfiguration
 
TestGiraphConfiguration.A - Class in org.apache.giraph.conf
 
TestGiraphConfiguration.B - Class in org.apache.giraph.conf
 
TestGiraphConfiguration.C - Class in org.apache.giraph.conf
 
TestGiraphConfiguration.If - Interface in org.apache.giraph.conf
 
TestGiraphTransferRegulator - Class in org.apache.giraph.partition
Test the GiraphTransferRegulator.
TestGiraphTransferRegulator() - Constructor for class org.apache.giraph.partition.TestGiraphTransferRegulator
 
testGiraphTransferRegulator() - Method in class org.apache.giraph.partition.TestGiraphTransferRegulator
 
TestGiraphTransferRegulator.TestComputation - Class in org.apache.giraph.partition
Dummy vertex.
TestGoraEdgeInputFormat - Class in org.apache.giraph.io.gora
Test class for Gora vertex input/output formats.
TestGoraEdgeInputFormat() - Constructor for class org.apache.giraph.io.gora.TestGoraEdgeInputFormat
 
TestGoraEdgeInputFormat.EmptyComputation - Class in org.apache.giraph.io.gora
 
TestGoraEdgeOutputFormat - Class in org.apache.giraph.io.gora
Test class for Gora edge output formats.
TestGoraEdgeOutputFormat() - Constructor for class org.apache.giraph.io.gora.TestGoraEdgeOutputFormat
 
TestGoraEdgeOutputFormat.EmptyComputation - Class in org.apache.giraph.io.gora
 
TestGoraVertexInputFormat - Class in org.apache.giraph.io.gora
Test class for Gora vertex input/output formats.
TestGoraVertexInputFormat() - Constructor for class org.apache.giraph.io.gora.TestGoraVertexInputFormat
 
TestGoraVertexInputFormat.EmptyComputation - Class in org.apache.giraph.io.gora
 
TestGoraVertexOutputFormat - Class in org.apache.giraph.io.gora
Test class for Gora vertex output formats.
TestGoraVertexOutputFormat() - Constructor for class org.apache.giraph.io.gora.TestGoraVertexOutputFormat
 
TestGraphPartitioner - Class in org.apache.giraph
Unit test for manual checkpoint restarting
TestGraphPartitioner() - Constructor for class org.apache.giraph.TestGraphPartitioner
 
testHaltSuperstep0() - Method in class org.apache.giraph.TestBspBasic
Test halting at superstep 0
testHappyPath() - Method in class org.apache.giraph.io.TestIdWithValueTextOutputFormat
 
testHappyPath() - Method in class org.apache.giraph.io.TestLongDoubleDoubleAdjacencyListVertexInputFormat
 
testHappyPath() - Method in class org.apache.giraph.io.TestSrcIdDstIdEdgeValueTextOutputFormat
 
testHappyPath() - Method in class org.apache.giraph.io.TestTextDoubleDoubleAdjacencyListVertexInputFormat
 
testHBaseInputOutput() - Method in class org.apache.giraph.io.hbase.TestHBaseRootMarkerVertextFormat
 
TestHBaseRootMarkerVertextFormat - Class in org.apache.giraph.io.hbase
Test case for HBase reading/writing vertices from an HBase instance.
TestHBaseRootMarkerVertextFormat() - Constructor for class org.apache.giraph.io.hbase.TestHBaseRootMarkerVertextFormat
 
TestHBaseRootMarkerVertextFormat.EdgeNotification - Class in org.apache.giraph.io.hbase
Test compute method that sends each edge a notification of its parents.
testHeap() - Method in class org.apache.giraph.types.heaps.TestFixedCapacityIntByteMinHeap
 
testHeap() - Method in class org.apache.giraph.types.heaps.TestFixedCapacityIntDoubleMinHeap
 
testHeap() - Method in class org.apache.giraph.types.heaps.TestFixedCapacityIntFloatMinHeap
 
testHeap() - Method in class org.apache.giraph.types.heaps.TestFixedCapacityIntIntMinHeap
 
testHeap() - Method in class org.apache.giraph.types.heaps.TestFixedCapacityIntLongMinHeap
 
testHeap() - Method in class org.apache.giraph.types.heaps.TestFixedCapacityLongByteMinHeap
 
testHeap() - Method in class org.apache.giraph.types.heaps.TestFixedCapacityLongDoubleMinHeap
 
testHeap() - Method in class org.apache.giraph.types.heaps.TestFixedCapacityLongFloatMinHeap
 
testHeap() - Method in class org.apache.giraph.types.heaps.TestFixedCapacityLongIntMinHeap
 
testHeap() - Method in class org.apache.giraph.types.heaps.TestFixedCapacityLongLongMinHeap
 
TestHiveUtils - Class in org.apache.giraph.io.hcatalog
 
TestHiveUtils() - Constructor for class org.apache.giraph.io.hcatalog.TestHiveUtils
 
TestIdWithValueTextOutputFormat - Class in org.apache.giraph.io
 
TestIdWithValueTextOutputFormat() - Constructor for class org.apache.giraph.io.TestIdWithValueTextOutputFormat
 
TestIdWithValueTextOutputFormat.DummyComputation - Class in org.apache.giraph.io
Dummy class to allow ImmutableClassesGiraphConfiguration to be created.
TestIfBlock - Class in org.apache.giraph.block_app.framework.block
 
TestIfBlock() - Constructor for class org.apache.giraph.block_app.framework.block.TestIfBlock
 
testIfBlockElse() - Method in class org.apache.giraph.block_app.framework.block.TestIfBlock
 
testIfBlockThen() - Method in class org.apache.giraph.block_app.framework.block.TestIfBlock
 
testIfNestedInRepeat() - Method in class org.apache.giraph.block_app.framework.block.TestIfBlock
 
testImmutableClassesGiraphConfigurationNewInstance() - Method in class org.apache.giraph.conf.TestObjectCreation
 
testImmutableList() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testIndependence(Iterable<? extends AbstractPiece>, Iterable<? extends AbstractPiece>) - Static method in class org.apache.giraph.block_app.framework.block.BlockTestingUtils
Tests both the length of the iterator returned by the block, as-well as the deterministic behavior expected by calling .iterator() against the referenceImpl.
testIndexMustHaveValue() - Method in class org.apache.giraph.io.TestLongDoubleDoubleAdjacencyListVertexInputFormat
 
testIndexMustHaveValue() - Method in class org.apache.giraph.io.TestTextDoubleDoubleAdjacencyListVertexInputFormat
 
testInferTypeParams() - Method in class org.apache.giraph.utils.TestReflectionUtils
 
testInferWithGenerics() - Method in class org.apache.giraph.utils.TestReflectionUtils
 
testInputSplitLocality() - Method in class org.apache.giraph.TestBspBasic
Run a test to see if the InputSplitPathOrganizer can correctly sort locality information from a mocked znode of data.
testInstantiateNullVertex() - Method in class org.apache.giraph.TestBspBasic
Test whether vertices with NullWritable for vertex value type, edge value type and message value type can be instantiated.
testInstantiateVertex() - Method in class org.apache.giraph.TestBspBasic
Just instantiate the vertex (all functions are implemented) and the VertexInputFormat using reflection.
TestIntAggregators - Class in org.apache.giraph.aggregators
 
TestIntAggregators() - Constructor for class org.apache.giraph.aggregators.TestIntAggregators
 
testIntArray() - Method in class org.apache.giraph.utils.TestWritableUtils
 
testIntByteArrayMessageStore() - Method in class org.apache.giraph.comm.messages.TestIntFloatPrimitiveMessageStores
 
testIntByteArrayMessageStoreWithMessageEncoding() - Method in class org.apache.giraph.comm.messages.TestIntFloatPrimitiveMessageStores
 
TestIntDenseMatrix - Class in org.apache.giraph.aggregators.matrix.dense
 
TestIntDenseMatrix() - Constructor for class org.apache.giraph.aggregators.matrix.dense.TestIntDenseMatrix
 
testIntFloatMessageStore() - Method in class org.apache.giraph.comm.messages.TestIntFloatPrimitiveMessageStores
 
TestIntFloatPrimitiveMessageStores - Class in org.apache.giraph.comm.messages
 
TestIntFloatPrimitiveMessageStores() - Constructor for class org.apache.giraph.comm.messages.TestIntFloatPrimitiveMessageStores
 
TestIntSparseMatrix - Class in org.apache.giraph.aggregators.matrix.sparse
 
TestIntSparseMatrix() - Constructor for class org.apache.giraph.aggregators.matrix.sparse.TestIntSparseMatrix
 
testIteratorsConcat() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
TestJsonBase64Format - Class in org.apache.giraph.io
Test out the JsonBase64 format.
TestJsonBase64Format() - Constructor for class org.apache.giraph.io.TestJsonBase64Format
Constructor.
testJsonBase64FormatType() - Method in class org.apache.giraph.vertex.TestComputationTypes
 
TestJythonBasic - Class in org.apache.giraph.jython
 
TestJythonBasic() - Constructor for class org.apache.giraph.jython.TestJythonBasic
 
TestJythonComputation - Class in org.apache.giraph.jython
 
TestJythonComputation() - Constructor for class org.apache.giraph.jython.TestJythonComputation
 
TestJythonWritableWrapper - Class in org.apache.giraph.jython
 
TestJythonWritableWrapper() - Constructor for class org.apache.giraph.jython.TestJythonWritableWrapper
 
testKryoImmutableMap() - Method in class org.apache.giraph.writable.kryo.KryoWritableTest
 
testLargeBasicList() - Method in class org.apache.giraph.types.TestCollections
 
testLargeBasicSet() - Method in class org.apache.giraph.types.TestCollections
 
testLineSanitizer() - Method in class org.apache.giraph.io.TestTextDoubleDoubleAdjacencyListVertexInputFormat
 
testListSerialization() - Method in class org.apache.giraph.utils.TestWritableUtils
Tests readList and writeList functions in writable utils.
testLocalJobRunnerConfig() - Method in class org.apache.giraph.TestBspBasic
Do some checks for local job runner.
TestLongAggregators - Class in org.apache.giraph.aggregators
 
TestLongAggregators() - Constructor for class org.apache.giraph.aggregators.TestLongAggregators
 
testLongArray() - Method in class org.apache.giraph.utils.TestWritableUtils
 
testLongByteArrayMessageStore() - Method in class org.apache.giraph.comm.messages.TestLongDoublePrimitiveMessageStores
 
TestLongDenseMatrix - Class in org.apache.giraph.aggregators.matrix.dense
 
TestLongDenseMatrix() - Constructor for class org.apache.giraph.aggregators.matrix.dense.TestLongDenseMatrix
 
TestLongDoubleDoubleAdjacencyListVertexInputFormat - Class in org.apache.giraph.io
 
TestLongDoubleDoubleAdjacencyListVertexInputFormat() - Constructor for class org.apache.giraph.io.TestLongDoubleDoubleAdjacencyListVertexInputFormat
 
TestLongDoubleDoubleAdjacencyListVertexInputFormat.DummyComputation - Class in org.apache.giraph.io
 
testLongDoubleMessageStore() - Method in class org.apache.giraph.comm.messages.TestLongDoublePrimitiveMessageStores
 
TestLongDoublePrimitiveMessageStores - Class in org.apache.giraph.comm.messages
 
TestLongDoublePrimitiveMessageStores() - Constructor for class org.apache.giraph.comm.messages.TestLongDoublePrimitiveMessageStores
 
testLongFastutilListProfile() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testLongKryoWritable() - Method in class org.apache.giraph.writable.kryo.KryoWritableTest
 
testLongListKryoWritable() - Method in class org.apache.giraph.writable.kryo.KryoWritableTest
 
testLongListWritable() - Method in class org.apache.giraph.writable.kryo.KryoWritableTest
 
TestLongNullNullBlockFactory - Class in org.apache.giraph.block_app.framework
 
TestLongNullNullBlockFactory() - Constructor for class org.apache.giraph.block_app.framework.TestLongNullNullBlockFactory
 
testLongRangePartitionerFactory() - Method in class org.apache.giraph.partition.SimpleRangePartitionFactoryTest
 
TestLongSparseMatrix - Class in org.apache.giraph.aggregators.matrix.sparse
 
TestLongSparseMatrix() - Constructor for class org.apache.giraph.aggregators.matrix.sparse.TestLongSparseMatrix
 
testLongWritable() - Method in class org.apache.giraph.writable.kryo.KryoWritableTest
 
TestLongWritableFunnel - Class in org.apache.giraph.utils.hashing
 
TestLongWritableFunnel() - Constructor for class org.apache.giraph.utils.hashing.TestLongWritableFunnel
 
TestLongXorReduce - Class in org.apache.giraph.reducers.impl
 
TestLongXorReduce() - Constructor for class org.apache.giraph.reducers.impl.TestLongXorReduce
 
testManualCheckpoint() - Method in class org.apache.giraph.TestCheckpointing
 
TestManualCheckpoint - Class in org.apache.giraph
Unit test for manual checkpoint restarting
TestManualCheckpoint() - Constructor for class org.apache.giraph.TestManualCheckpoint
 
testManualCheckpointAtTheBeginning() - Method in class org.apache.giraph.TestCheckpointing
 
TestMasterObserver - Class in org.apache.giraph.master
 
TestMasterObserver() - Constructor for class org.apache.giraph.master.TestMasterObserver
 
TestMasterObserver.InputFormat - Class in org.apache.giraph.master
 
TestMasterObserver.Obs - Class in org.apache.giraph.master
 
TestMasterObserver.SimpleComputation - Class in org.apache.giraph.master
 
testMatchingType() - Method in class org.apache.giraph.vertex.TestComputationTypes
 
testMax() - Method in class org.apache.giraph.examples.MaxComputationTest
 
testMaxAggregator() - Method in class org.apache.giraph.aggregators.TestDoubleAggregators
 
testMaxAggregator() - Method in class org.apache.giraph.aggregators.TestFloatAggregators
 
testMaxAggregator() - Method in class org.apache.giraph.aggregators.TestIntAggregators
 
testMaxAggregator() - Method in class org.apache.giraph.aggregators.TestLongAggregators
 
TestMaxSuperstep - Class in org.apache.giraph
Unit test for testing max superstep feature of Giraph
TestMaxSuperstep() - Constructor for class org.apache.giraph.TestMaxSuperstep
 
testMaxSuperstep() - Method in class org.apache.giraph.TestMaxSuperstep
Run a job that tests that this job completes in the desired number of supersteps
TestMaxSuperstep.InfiniteLoopComputation - Class in org.apache.giraph
Simple test vertex class that will run forever (voteToHalt is never called).
testMessageSending() - Method in class org.apache.giraph.block_app.framework.BlockExecutionTest
 
TestMessageStores - Class in org.apache.giraph.comm
Test for different types of message stores
TestMessageStores() - Constructor for class org.apache.giraph.comm.TestMessageStores
 
TestMigrationBspBasic - Class in org.apache.giraph.examples.block_app
Unit test for many simple BSP applications.
TestMigrationBspBasic() - Constructor for class org.apache.giraph.examples.block_app.TestMigrationBspBasic
 
testMinAggregator() - Method in class org.apache.giraph.aggregators.TestDoubleAggregators
 
testMinAggregator() - Method in class org.apache.giraph.aggregators.TestFloatAggregators
 
testMinAggregator() - Method in class org.apache.giraph.aggregators.TestIntAggregators
 
testMinAggregator() - Method in class org.apache.giraph.aggregators.TestLongAggregators
 
testMismatchingCombiner() - Method in class org.apache.giraph.vertex.TestComputationTypes
 
testMismatchingVertex() - Method in class org.apache.giraph.vertex.TestComputationTypes
 
testMismatchingVertexValueFactory() - Method in class org.apache.giraph.vertex.TestComputationTypes
 
testMixedVertexEdgeFormat() - Method in class org.apache.giraph.io.TestVertexEdgeInput
 
testMixedVertexValueEdgeFormat() - Method in class org.apache.giraph.io.TestVertexEdgeInput
 
TestMultiGraphEdges - Class in org.apache.giraph.edge
Tests OutEdges implementations that allow parallel edges.
TestMultiGraphEdges() - Constructor for class org.apache.giraph.edge.TestMultiGraphEdges
 
TestMultiRandomAccessEdges - Class in org.apache.giraph.edge
Tests MultiRandomAccessOutEdges implementations.
TestMultiRandomAccessEdges() - Constructor for class org.apache.giraph.edge.TestMultiRandomAccessEdges
 
testMutateEdges() - Method in class org.apache.giraph.edge.LongDiffNullArrayEdgesTest
 
testMutateEdges() - Method in class org.apache.giraph.edge.TestNullValueEdges
Test in-place edge mutations via the iterable returned by Vertex.getMutableEdges().
testMutateEdges() - Method in class org.apache.giraph.graph.TestVertexAndEdges
Test in-place edge mutations via the iterable returned by Vertex.getMutableEdges().
TestMutateGraph - Class in org.apache.giraph
Unit test for graph mutation
TestMutateGraph() - Constructor for class org.apache.giraph.TestMutateGraph
 
testMutateGraph() - Method in class org.apache.giraph.TestMutateGraph
Run a job that tests the various graph mutations that can occur
TestMutateGraph.TestVertexResolver<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
Custom vertex resolver
testNativeCreateClass() - Method in class org.apache.giraph.conf.TestObjectCreation
 
testNegativeCreateSourceVertex() - Method in class org.apache.giraph.io.TestCreateSourceVertex
 
testNestedKryoWritable() - Method in class org.apache.giraph.writable.kryo.KryoWritableTest
 
testNestedRepeatBlock(Iterable<? extends AbstractPiece>, Block) - Static method in class org.apache.giraph.block_app.framework.block.BlockTestingUtils
Test how the block interacts with a repeatBlock.
testNestedRepeatBlock() - Method in class org.apache.giraph.block_app.framework.block.TestRepeatBlock
 
testNestedRepeatUntilBlock() - Method in class org.apache.giraph.block_app.framework.block.TestRepeatUntilBlock
 
testNewInstance() - Method in class org.apache.giraph.conf.TestObjectCreation
 
TestNotEnoughMapTasks - Class in org.apache.giraph
Unit test for not enough map tasks
TestNotEnoughMapTasks() - Constructor for class org.apache.giraph.TestNotEnoughMapTasks
 
testNotEnoughMapTasks() - Method in class org.apache.giraph.TestNotEnoughMapTasks
This job should always fail gracefully with not enough map tasks.
testNull() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
TestNullValueEdges - Class in org.apache.giraph.edge
Tests OutEdges implementations with null edge values.
TestNullValueEdges() - Constructor for class org.apache.giraph.edge.TestNullValueEdges
 
TestObjectCreation - Class in org.apache.giraph.conf
Benchmark tests to insure that object creation via ImmutableClassesGiraphConfiguration is fast
TestObjectCreation() - Constructor for class org.apache.giraph.conf.TestObjectCreation
 
testOneInitNodeGraph() - Method in class org.apache.giraph.examples.BrachaTouegDeadlockComputationTest
 
testOneNotInitNodeGraph() - Method in class org.apache.giraph.examples.BrachaTouegDeadlockComputationTest
 
testOnNoShorterPathFound() - Method in class org.apache.giraph.examples.SimpleShortestPathsComputationTest
Test the behavior when a new, but not shorter path to a vertex has been found.
testOnShorterPathFound() - Method in class org.apache.giraph.examples.SimpleShortestPathsComputationTest
Test the behavior when a shorter path to a vertex has been found
testOrAggregator() - Method in class org.apache.giraph.aggregators.TestBooleanAggregators
 
TestOutEdges() - Constructor for class org.apache.giraph.graph.TestVertexAndEdges.TestOutEdges
 
TestOutEdgesFilterEven() - Constructor for class org.apache.giraph.io.TestVertexEdgeInput.TestOutEdgesFilterEven
 
TestOutOfCore - Class in org.apache.giraph
Unit test for out-of-core mechanism
TestOutOfCore() - Constructor for class org.apache.giraph.TestOutOfCore
 
testOutOfCoreInMemoryAccessor() - Method in class org.apache.giraph.TestOutOfCore
 
testOutOfCoreLocalDiskAccessor() - Method in class org.apache.giraph.TestOutOfCore
 
testOutOfCoreMessages() - Method in class org.apache.giraph.partition.TestPartitionStores
 
TestOutOfCoreMessagesComputation() - Constructor for class org.apache.giraph.partition.TestPartitionStores.TestOutOfCoreMessagesComputation
 
testOverwriteAggregator() - Method in class org.apache.giraph.aggregators.TestBooleanAggregators
 
testOverwriteAggregator() - Method in class org.apache.giraph.aggregators.TestDoubleAggregators
 
testOverwriteAggregator() - Method in class org.apache.giraph.aggregators.TestFloatAggregators
 
testOverwriteAggregator() - Method in class org.apache.giraph.aggregators.TestIntAggregators
 
testOverwriteAggregator() - Method in class org.apache.giraph.aggregators.TestLongAggregators
 
testPackagePath() - Method in class org.apache.giraph.utils.TestReflectionUtils
 
TestPageRank - Class in org.apache.giraph.examples
Test page rank (with and without multithreading)
TestPageRank() - Constructor for class org.apache.giraph.examples.TestPageRank
Constructor
testPageRankTenThreadsCompute() - Method in class org.apache.giraph.examples.TestPageRank
 
testParallelEdges() - Method in class org.apache.giraph.edge.LongDiffNullArrayEdgesTest
 
testParallelEdges() - Method in class org.apache.giraph.edge.TestMultiGraphEdges
Ensures that all multigraph OutEdges implementations allow parallel edges.
testParallelEdges() - Method in class org.apache.giraph.edge.TestMultiRandomAccessEdges
Ensures that all MultiRandomAccessOutEdges implementations correctly return edge values.
testParallelEdges() - Method in class org.apache.giraph.edge.TestStrictGraphEdges
Ensures that all strict graph OutEdges implementations disallow parallel edges.
testParallelEdges() - Method in class org.apache.giraph.edge.TestStrictRandomAccessEdges
Ensures that all StrictRandomAccessOutEdges implementations correctly return edge values.
testParsePartition() - Method in class org.apache.giraph.io.hcatalog.TestHiveUtils
 
testPartitioners() - Method in class org.apache.giraph.TestGraphPartitioner
Run a sample BSP job locally and test various partitioners and partition algorithms.
TestPartitionStores - Class in org.apache.giraph.partition
Test case for partition stores.
TestPartitionStores() - Constructor for class org.apache.giraph.partition.TestPartitionStores
 
TestPartitionStores.EmptyComputation - Class in org.apache.giraph.partition
Test compute method that sends each edge a notification of its parents.
TestPartitionStores.MyComputation - Class in org.apache.giraph.partition
 
TestPartitionStores.TestOutOfCoreMessagesComputation - Class in org.apache.giraph.partition
 
TestPiece(BlockApiHandleTest.DummyObjectWithApiHandle) - Constructor for class org.apache.giraph.block_app.framework.BlockApiHandleTest.TestPiece
 
testPositiveAndNegativeEdges() - Method in class org.apache.giraph.edge.LongDiffNullArrayEdgesTest
 
testPositiveCreateSourceVertex() - Method in class org.apache.giraph.io.TestCreateSourceVertex
 
TestPredicateLock - Class in org.apache.giraph.zk
Ensure that PredicateLock objects work correctly.
TestPredicateLock() - Constructor for class org.apache.giraph.zk.TestPredicateLock
 
testProductAggregator() - Method in class org.apache.giraph.aggregators.TestDoubleAggregators
 
testProductAggregator() - Method in class org.apache.giraph.aggregators.TestFloatAggregators
 
testProductAggregator() - Method in class org.apache.giraph.aggregators.TestIntAggregators
 
testProductAggregator() - Method in class org.apache.giraph.aggregators.TestLongAggregators
 
TestProgressableUtils - Class in org.apache.giraph.utils
Test ProgressableUtils
TestProgressableUtils() - Constructor for class org.apache.giraph.utils.TestProgressableUtils
 
testProgressableUtils() - Method in class org.apache.giraph.utils.TestProgressableUtils
 
testPureYarnJob() - Method in class org.apache.giraph.yarn.TestYarnJob
 
testRandom() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testReadWrite(PartitionStore<IntWritable, IntWritable, NullWritable>, ImmutableClassesGiraphConfiguration<IntWritable, IntWritable, NullWritable>) - Method in class org.apache.giraph.partition.TestPartitionStores
Test reading/writing to/from a partition store
testRecursive() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testRecursiveKryoWritable() - Method in class org.apache.giraph.writable.kryo.KryoWritableTest
 
testReducing() - Method in class org.apache.giraph.block_app.framework.BlockExecutionTest
 
TestReflectionUtils - Class in org.apache.giraph.utils
 
TestReflectionUtils() - Constructor for class org.apache.giraph.utils.TestReflectionUtils
 
testReflectionUtilsNewInstance() - Method in class org.apache.giraph.conf.TestObjectCreation
 
TestRepeatBlock - Class in org.apache.giraph.block_app.framework.block
Tests repeatBlock's correctness
TestRepeatBlock() - Constructor for class org.apache.giraph.block_app.framework.block.TestRepeatBlock
 
testRepeatBlockBasic() - Method in class org.apache.giraph.block_app.framework.block.TestRepeatBlock
 
testRepeatBlockEmpty() - Method in class org.apache.giraph.block_app.framework.block.TestRepeatBlock
 
TestRepeatUntilBlock - Class in org.apache.giraph.block_app.framework.block
Tests repeatUntilBlock's correctness
TestRepeatUntilBlock() - Constructor for class org.apache.giraph.block_app.framework.block.TestRepeatUntilBlock
 
testRepeatUntilBlockBasic() - Method in class org.apache.giraph.block_app.framework.block.TestRepeatUntilBlock
 
testRepeatUntilBlockUnlimited() - Method in class org.apache.giraph.block_app.framework.block.TestRepeatUntilBlock
 
testReverseIdAndValue() - Method in class org.apache.giraph.io.TestIdWithValueTextOutputFormat
 
testReverseIdAndValue() - Method in class org.apache.giraph.io.TestSrcIdDstIdEdgeValueTextOutputFormat
 
testSerialization() - Method in class org.apache.giraph.edge.LongDiffNullArrayEdgesTest
 
testSerialize() - Method in class org.apache.giraph.graph.TestVertexAndEdges
Test Vertex and OutEdges serialization.
testSetClasses() - Method in class org.apache.giraph.conf.TestGiraphConfiguration
 
testSimplePartitionStore() - Method in class org.apache.giraph.partition.TestPartitionStores
 
testSingleFault() - Method in class org.apache.giraph.TestAutoCheckpoint
Run a job that requires checkpointing and will have a worker crash and still recover from a previous checkpoint.
testSmall() - Method in class org.apache.giraph.utils.TestVarint
 
TestSrcIdDstIdEdgeValueTextOutputFormat - Class in org.apache.giraph.io
 
TestSrcIdDstIdEdgeValueTextOutputFormat() - Constructor for class org.apache.giraph.io.TestSrcIdDstIdEdgeValueTextOutputFormat
 
TestSrcIdDstIdEdgeValueTextOutputFormat.DummyComputation - Class in org.apache.giraph.io
Dummy class to allow ImmutableClassesGiraphConfiguration to be created.
TestStrictGraphEdges - Class in org.apache.giraph.edge
Tests OutEdges implementations that disallow parallel edges.
TestStrictGraphEdges() - Constructor for class org.apache.giraph.edge.TestStrictGraphEdges
 
TestStrictRandomAccessEdges - Class in org.apache.giraph.edge
Tests StrictRandomAccessOutEdges implementations.
TestStrictRandomAccessEdges() - Constructor for class org.apache.giraph.edge.TestStrictRandomAccessEdges
 
testSumAggregator() - Method in class org.apache.giraph.aggregators.TestDoubleAggregators
 
testSumAggregator() - Method in class org.apache.giraph.aggregators.TestFloatAggregators
 
testSumAggregator() - Method in class org.apache.giraph.aggregators.TestIntAggregators
 
testSumAggregator() - Method in class org.apache.giraph.aggregators.TestLongAggregators
 
testSuperstepOne() - Method in class org.apache.giraph.examples.SimpleTriangleClosingComputationTest
Test behavior of compute() with incoming messages (superstep 1)
testSuperstepZero() - Method in class org.apache.giraph.examples.SimpleTriangleClosingComputationTest
Test the behavior of the triangle closing algorithm: does it send all its out edge values to all neighbors?
TestSwitchClasses - Class in org.apache.giraph.master
Test switching Computation and MessageCombiner class during application
TestSwitchClasses() - Constructor for class org.apache.giraph.master.TestSwitchClasses
 
TestSwitchClasses.Computation1 - Class in org.apache.giraph.master
 
TestSwitchClasses.Computation2 - Class in org.apache.giraph.master
 
TestSwitchClasses.Computation3 - Class in org.apache.giraph.master
 
TestSwitchClasses.MinimumMessageCombiner - Class in org.apache.giraph.master
 
TestSwitchClasses.StatusValue - Class in org.apache.giraph.master
 
TestSwitchClasses.SumMessageCombiner - Class in org.apache.giraph.master
 
TestSwitchClasses.SwitchingClassesMasterCompute - Class in org.apache.giraph.master
 
testSwitchingClasses() - Method in class org.apache.giraph.master.TestSwitchClasses
 
testSyncNewInstance() - Method in class org.apache.giraph.conf.TestObjectCreation
 
testTestClassA() - Method in class org.apache.giraph.writable.kryo.KryoWritableTest
 
TestTestGraph - Class in org.apache.giraph.utils
Test TestGraph
TestTestGraph() - Constructor for class org.apache.giraph.utils.TestTestGraph
 
testTestGraph() - Method in class org.apache.giraph.utils.TestTestGraph
 
TestTestGraph.SumLongVertexValueCombiner - Class in org.apache.giraph.utils
Vertex value combiner that sums up long vertex values
TestTextDoubleDoubleAdjacencyListVertexInputFormat - Class in org.apache.giraph.io
 
TestTextDoubleDoubleAdjacencyListVertexInputFormat() - Constructor for class org.apache.giraph.io.TestTextDoubleDoubleAdjacencyListVertexInputFormat
 
TestTextDoubleDoubleAdjacencyListVertexInputFormat.DummyComputation - Class in org.apache.giraph.io
 
testThreeNodesAllNodesBlockedGraph() - Method in class org.apache.giraph.examples.BrachaTouegDeadlockComputationTest
 
testThreeNodesAllNodesBlockedNOutOfMGraph() - Method in class org.apache.giraph.examples.BrachaTouegDeadlockComputationTest
 
testThreeNodesAllNodesFreeGraph() - Method in class org.apache.giraph.examples.BrachaTouegDeadlockComputationTest
 
testThreeNodesAllNodesFreeMultiEdgesGraph() - Method in class org.apache.giraph.examples.BrachaTouegDeadlockComputationTest
 
testThreeNodesAllNodesFreeNOutOfMGraph() - Method in class org.apache.giraph.examples.BrachaTouegDeadlockComputationTest
 
testThreeNodesInitNodeFreeNOutOfMGraph() - Method in class org.apache.giraph.examples.BrachaTouegDeadlockComputationTest
 
testToyData() - Method in class org.apache.giraph.examples.ConnectedComponentsComputationTest
A local integration test on toy data
testToyData() - Method in class org.apache.giraph.examples.ConnectedComponentsComputationTestInMemory
A local integration test on toy data
testToyData() - Method in class org.apache.giraph.examples.PageRankComputationTest
A local integration test on toy data
testToyData() - Method in class org.apache.giraph.examples.RandomWalkWithRestartComputationTest
A local integration test on toy data
testToyData() - Method in class org.apache.giraph.examples.scc.SccComputationTestInMemory
 
testToyData() - Method in class org.apache.giraph.examples.SimpleShortestPathsComputationTest
A local integration test on toy data
testToyData() - Method in class org.apache.giraph.examples.TryMultiIpcBindingPortsTest
A local integration test on toy data
testToyDataJson() - Method in class org.apache.giraph.examples.SimpleShortestPathsComputationTest
A local integration test on toy data
testUnmodifiableIterator() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
TestUnsafeByteArrayOutputStream - Class in org.apache.giraph.utils
 
TestUnsafeByteArrayOutputStream() - Constructor for class org.apache.giraph.utils.TestUnsafeByteArrayOutputStream
 
testUnsafePartitionSerializationClass() - Method in class org.apache.giraph.partition.TestPartitionStores
 
TestVarint - Class in org.apache.giraph.utils
 
TestVarint() - Constructor for class org.apache.giraph.utils.TestVarint
 
testVarIntLarge() - Method in class org.apache.giraph.utils.TestVarint
 
testVarIntSmall() - Method in class org.apache.giraph.utils.TestVarint
 
testVarLongLarge() - Method in class org.apache.giraph.utils.TestVarint
 
testVarLongSmall() - Method in class org.apache.giraph.utils.TestVarint
 
testVars() - Method in class org.apache.giraph.utils.TestVarint
 
testVectorAdd() - Method in class org.apache.giraph.aggregators.matrix.dense.TestDoubleDenseMatrix
 
testVectorAdd() - Method in class org.apache.giraph.aggregators.matrix.dense.TestFloatDenseMatrix
 
testVectorAdd() - Method in class org.apache.giraph.aggregators.matrix.dense.TestIntDenseMatrix
 
testVectorAdd() - Method in class org.apache.giraph.aggregators.matrix.dense.TestLongDenseMatrix
 
testVectorAdd() - Method in class org.apache.giraph.aggregators.matrix.sparse.TestDoubleSparseMatrix
 
testVectorAdd() - Method in class org.apache.giraph.aggregators.matrix.sparse.TestFloatSparseMatrix
 
testVectorAdd() - Method in class org.apache.giraph.aggregators.matrix.sparse.TestIntSparseMatrix
 
testVectorAdd() - Method in class org.apache.giraph.aggregators.matrix.sparse.TestLongSparseMatrix
 
testVectorSerialize() - Method in class org.apache.giraph.aggregators.matrix.dense.TestDoubleDenseMatrix
 
testVectorSerialize() - Method in class org.apache.giraph.aggregators.matrix.dense.TestFloatDenseMatrix
 
testVectorSerialize() - Method in class org.apache.giraph.aggregators.matrix.dense.TestIntDenseMatrix
 
testVectorSerialize() - Method in class org.apache.giraph.aggregators.matrix.dense.TestLongDenseMatrix
 
testVectorSerialize() - Method in class org.apache.giraph.aggregators.matrix.sparse.TestDoubleSparseMatrix
 
testVectorSerialize() - Method in class org.apache.giraph.aggregators.matrix.sparse.TestFloatSparseMatrix
 
testVectorSerialize() - Method in class org.apache.giraph.aggregators.matrix.sparse.TestIntSparseMatrix
 
testVectorSerialize() - Method in class org.apache.giraph.aggregators.matrix.sparse.TestLongSparseMatrix
 
testVectorSerializeSingleton() - Method in class org.apache.giraph.aggregators.matrix.dense.TestDoubleDenseMatrix
 
testVectorSerializeSingleton() - Method in class org.apache.giraph.aggregators.matrix.dense.TestFloatDenseMatrix
 
testVectorSerializeSingleton() - Method in class org.apache.giraph.aggregators.matrix.dense.TestIntDenseMatrix
 
testVectorSerializeSingleton() - Method in class org.apache.giraph.aggregators.matrix.dense.TestLongDenseMatrix
 
testVectorSingleton() - Method in class org.apache.giraph.aggregators.matrix.dense.TestDoubleDenseMatrix
 
testVectorSingleton() - Method in class org.apache.giraph.aggregators.matrix.dense.TestFloatDenseMatrix
 
testVectorSingleton() - Method in class org.apache.giraph.aggregators.matrix.dense.TestIntDenseMatrix
 
testVectorSingleton() - Method in class org.apache.giraph.aggregators.matrix.dense.TestLongDenseMatrix
 
TestVertexAndEdges - Class in org.apache.giraph.graph
Test Vertex functionality across the provided OutEdges classes.
TestVertexAndEdges() - Constructor for class org.apache.giraph.graph.TestVertexAndEdges
 
TestVertexAndEdges.TestComputation - Class in org.apache.giraph.graph
Dummy concrete vertex.
TestVertexAndEdges.TestOutEdges - Class in org.apache.giraph.graph
A basic OutEdges implementation that doesn't provide any special functionality.
TestVertexEdgeInput - Class in org.apache.giraph.io
A test case to ensure that loading a graph from vertices and edges works as expected.
TestVertexEdgeInput() - Constructor for class org.apache.giraph.io.TestVertexEdgeInput
 
TestVertexEdgeInput.IntSumVertexValueCombiner - Class in org.apache.giraph.io
Simple vertex value combiner that sums up the vertex values.
TestVertexEdgeInput.TestComputationCheckEdgesType - Class in org.apache.giraph.io
 
TestVertexEdgeInput.TestOutEdgesFilterEven - Class in org.apache.giraph.io
 
TestVertexEdgeInput.TestVertexValueFactory - Class in org.apache.giraph.io
 
testVertexFilter() - Method in class org.apache.giraph.io.TestFilters
 
testVertexIdAndValue() - Method in class org.apache.giraph.graph.TestVertexAndEdges
Test vertex instantiation, initialization, and updating the vertex value.
testVertexReceiver() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testVertexRemoval() - Method in class org.apache.giraph.block_app.framework.BlockExecutionTest
 
TestVertexResolver() - Constructor for class org.apache.giraph.TestMutateGraph.TestVertexResolver
 
testVertexValueCombiner() - Method in class org.apache.giraph.io.TestVertexEdgeInput
 
TestVertexValueFactory() - Constructor for class org.apache.giraph.io.TestVertexEdgeInput.TestVertexValueFactory
 
testVertexWithEdges() - Method in class org.apache.giraph.io.TestAdjacencyListTextVertexOutputFormat
 
testVertexWithNoEdges() - Method in class org.apache.giraph.io.TestAdjacencyListTextVertexOutputFormat
 
testWaitForever() - Method in class org.apache.giraph.zk.TestPredicateLock
Thread signaled test for PredicateLock.waitForever()
testWaitMsecs() - Method in class org.apache.giraph.zk.TestPredicateLock
Thread signaled test to make sure the the event is signaled correctly
testWaitMsecsNoEvent() - Method in class org.apache.giraph.zk.TestPredicateLock
SMake sure the the event is not signaled.
testWeightedGraph() - Method in class org.apache.giraph.examples.RandomWalkWithRestartComputationTest
A local integration test on toy data
testWFastutilLongList() - Method in class org.apache.giraph.writable.kryo.KryoWritableWrapperTest
 
testWithDifferentDelimiter() - Method in class org.apache.giraph.io.TestAdjacencyListTextVertexOutputFormat
 
testWithDifferentDelimiter() - Method in class org.apache.giraph.io.TestIdWithValueTextOutputFormat
 
testWithDifferentDelimiter() - Method in class org.apache.giraph.io.TestSrcIdDstIdEdgeValueTextOutputFormat
 
testWithTestSetup() - Method in class org.apache.giraph.block_app.framework.TestWorkerMessages
 
TestWorkerMessages - Class in org.apache.giraph.block_app.framework
Test sending worker to worker messages
TestWorkerMessages() - Constructor for class org.apache.giraph.block_app.framework.TestWorkerMessages
 
testWorkerMessages() - Method in class org.apache.giraph.block_app.framework.TestWorkerMessages
 
TestWorkerMessages.TestWorkerMessagesBlockFactory - Class in org.apache.giraph.block_app.framework
 
TestWorkerMessages.TestWorkerMessagesPiece - Class in org.apache.giraph.block_app.framework
 
TestWorkerMessagesBlockFactory() - Constructor for class org.apache.giraph.block_app.framework.TestWorkerMessages.TestWorkerMessagesBlockFactory
 
TestWorkerMessagesPiece(long...) - Constructor for class org.apache.giraph.block_app.framework.TestWorkerMessages.TestWorkerMessagesPiece
 
testWrap() - Method in class org.apache.giraph.jython.TestJythonWritableWrapper
 
TestWritableUtils - Class in org.apache.giraph.utils
Test case for WritableUtils.
TestWritableUtils() - Constructor for class org.apache.giraph.utils.TestWritableUtils
 
testWriteBytes() - Method in class org.apache.giraph.utils.TestUnsafeByteArrayOutputStream
 
testWriteChars() - Method in class org.apache.giraph.utils.TestUnsafeByteArrayOutputStream
 
testWriteLongUTF() - Method in class org.apache.giraph.utils.TestUnsafeByteArrayOutputStream
 
testWritesALong() - Method in class org.apache.giraph.utils.hashing.TestLongWritableFunnel
 
testWriteUTF() - Method in class org.apache.giraph.utils.TestUnsafeByteArrayOutputStream
 
testXor() - Method in class org.apache.giraph.reducers.impl.TestLongXorReduce
 
TestYarnJob - Class in org.apache.giraph.yarn
Tests the Giraph on YARN workflow.
TestYarnJob() - Constructor for class org.apache.giraph.yarn.TestYarnJob
 
testZero() - Method in class org.apache.giraph.reducers.impl.TestLongXorReduce
 
TestZooKeeperExt - Class in org.apache.giraph.zk
Test the ZooKeeperExt class.
TestZooKeeperExt() - Constructor for class org.apache.giraph.zk.TestZooKeeperExt
 
TestZooKeeperManager - Class in org.apache.giraph.zk
 
TestZooKeeperManager() - Constructor for class org.apache.giraph.zk.TestZooKeeperManager
 
toString() - Method in class org.apache.giraph.master.TestSwitchClasses.StatusValue
 
transformEdge(Object) - Method in class org.apache.giraph.io.gora.GoraTestEdgeInputFormat.GoraGEdgeEdgeReader
Transforms a GoraObject into an Edge object.
transformVertex(Object) - Method in class org.apache.giraph.io.gora.GoraTestVertexInputFormat.GoraGVertexVertexReader
Transforms a GoraObject into a Vertex object.
TryMultiIpcBindingPortsTest - Class in org.apache.giraph.examples
TryMultiIpcBindingPortsTest() - Constructor for class org.apache.giraph.examples.TryMultiIpcBindingPortsTest
 

U

uncaughtException(Thread, Throwable) - Method in class org.apache.giraph.comm.MockExceptionHandler
 

V

value - Variable in class org.apache.giraph.writable.kryo.KryoWritableTest.LongListKryoWritable
 
value1 - Variable in class org.apache.giraph.writable.kryo.KryoWritableTest.NestedKryoWritable
 
value2 - Variable in class org.apache.giraph.writable.kryo.KryoWritableTest.NestedKryoWritable
 
valueOf(String) - Static method in enum org.apache.giraph.generate.GeneratePrimitiveClasses.PrimitiveType
Returns the enum constant of this type with the specified name.
values() - Static method in enum org.apache.giraph.generate.GeneratePrimitiveClasses.PrimitiveType
Returns an array containing the constants of this enum type, in the order they are declared.
verifyMessageSent(I, M) - Method in class org.apache.giraph.utils.MockUtils.MockedEnvironment
assert that the test vertex message has been sent to a particular vertex
verifyMessageSentToAllEdges(Vertex<I, V, E>, M) - Method in class org.apache.giraph.utils.MockUtils.MockedEnvironment
 
verifyNoMessageSent() - Method in class org.apache.giraph.utils.MockUtils.MockedEnvironment
assert that the test vertex has sent no message to a particular vertex
VertexFilter() - Constructor for class org.apache.giraph.io.TestFilters.VertexFilter
 

W

workerContextReceive(BlockWorkerContextReceiveApi, Object, Object, List<DoubleWritable>) - Method in class org.apache.giraph.block_app.framework.BlockApiHandleTest.TestPiece
Override to have worker context receive computation.
workerContextReceive(BlockWorkerContextReceiveApi, Object, Object, List<LongWritable>) - Method in class org.apache.giraph.block_app.framework.TestWorkerMessages.TestWorkerMessagesPiece
 
workerContextSend(BlockWorkerContextSendApi<WritableComparable, DoubleWritable>, Object, Writable) - Method in class org.apache.giraph.block_app.framework.BlockApiHandleTest.TestPiece
 
workerContextSend(BlockWorkerContextSendApi<LongWritable, LongWritable>, Object, Object) - Method in class org.apache.giraph.block_app.framework.TestWorkerMessages.TestWorkerMessagesPiece
 
write(DataOutput) - Method in class org.apache.giraph.graph.TestVertexAndEdges.TestOutEdges
 
write(DataOutput) - Method in class org.apache.giraph.master.TestSwitchClasses.StatusValue
 
write(DataOutput) - Method in class org.apache.giraph.TestCheckpointing.CheckpointVertexMasterCompute
 
write(DataOutput) - Method in class org.apache.giraph.TestCheckpointing.CheckpointVertexWorkerContext
 
writeEdge(LongWritable, DoubleWritable, Edge<LongWritable, FloatWritable>) - Method in class org.apache.giraph.io.gora.GoraTestEdgeOutputFormat.GoraGEdgeEdgeWriter
 
writeVertex(Vertex<Text, Text, Text>) - Method in class org.apache.giraph.io.accumulo.edgemarker.AccumuloEdgeOutputFormat.AccumuloEdgeVertexWriter
 
writeVertex(Vertex<LongWritable, DoubleWritable, FloatWritable>) - Method in class org.apache.giraph.io.gora.GoraTestVertexOutputFormat.GoraGVertexVertexWriter
 
writeVertex(Vertex<Text, Text, Text>) - Method in class org.apache.giraph.io.hbase.edgemarker.TableEdgeOutputFormat.TableEdgeVertexWriter
 
A B C D E F G H I K L M N O P R S T U V W 
Skip navigation links

Copyright © 2011-2016 The Apache Software Foundation. All Rights Reserved.