backtype.storm.testing

Interface TestJob

public interface TestJob

This is the core interface for the storm java testing, usually we put our java unit testing logic in the run method. A sample code will be: Testing.withSimulatedTimeLocalCluster(new TestJob() { public void run(Cluster cluster) { // your testing logic here. } });

Method Summary

Methods

Modifier and Type	Method and Description
void	run(ILocalCluster cluster) run the testing logic with the cluster.

Method Detail

run

void run(ILocalCluster cluster)
         throws Exception

run the testing logic with the cluster.

Parameters:

cluster - the cluster which created by Testing.withSimulatedTimeLocalCluster and Testing.withTrackedCluster.

Throws:

Exception