Package titan.manual

Class TitanDAGEndToEnd

java.lang.Object

titan.manual.TitanDAGEndToEnd

public class TitanDAGEndToEnd
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static Scheduler	scheduler

Constructor Summary

Constructors

Constructor	Description
TitanDAGEndToEnd()

Method Summary

Modifier and Type	Method	Description
private static void	assertAffinity(String parentId, String childId)
private static void	assertStatus(String id, Job.Status expected)
private static String	findWorkerForJob(String json, String jobId)
static void	main(String[] args)
private static void	sendDag(String dagPayload)
private static void	testCascadingFailure()
private static void	testComplexFanOutAffinity()
private static void	testDiamondDag()
private static void	testSimpleAffinity()
private static void	testSimpleSequence()

Methods inherited from class java.lang.Object

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

Field Details

scheduler

private static Scheduler scheduler

Constructor Details

TitanDAGEndToEnd

public TitanDAGEndToEnd()

Method Details

main

public static void main(String[] args)
                 throws Exception

Throws:

Exception

testSimpleSequence

private static void testSimpleSequence()
                                throws Exception

Throws:

Exception

testDiamondDag

private static void testDiamondDag()
                            throws Exception

Throws:

Exception

testCascadingFailure

private static void testCascadingFailure()
                                  throws Exception

Throws:

Exception

testSimpleAffinity

private static void testSimpleAffinity()
                                throws Exception

Throws:

Exception

testComplexFanOutAffinity

private static void testComplexFanOutAffinity()
                                       throws Exception

Throws:

Exception

assertStatus

private static void assertStatus(String id,
 Job.Status expected)
                          throws InterruptedException

Throws:

InterruptedException

assertAffinity

private static void assertAffinity(String parentId,
 String childId)

findWorkerForJob

private static String findWorkerForJob(String json,
 String jobId)

sendDag

private static void sendDag(String dagPayload)