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

void	run(ILocalCluster cluster) run the testing logic with the cluster.

Method Detail

run

void run(ILocalCluster cluster)

run the testing logic with the cluster.

Parameters:

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