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. |
run
void run(ILocalCluster cluster)
- run the testing logic with the cluster.
- Parameters:
cluster
- the cluster which created by Testing.withSimulatedTimeLocalCluster
and Testing.withTrackedCluster
.