|Constructor and Description|
|Modifier and Type||Method and Description|
Return a condition that is valid only if all of
Submit the topology for this tester and wait for it to complete, or reach an end condition.
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
atLeastTupleCount, contentsUnordered, streamContents, tupleCount
public boolean complete(Submitter<Topology,? extends Job> submitter, com.google.gson.JsonObject config, Condition<?> endCondition, long timeout, TimeUnit unit) throws Exception
timeoutthen it is terminated.
End condition is usually a
Condition returned from
Tester.atLeastTupleCount(TStream, long) or
Tester.tupleCount(TStream, long) so that this method returns once the
stream has submitted a sufficient number of tuples.
Note that the condition will be only checked periodically up to
timeout, so that if the condition is only valid for a brief
period of time, then its valid state may not be seen, and thus this
method will wait for the timeout period.
config- submission configuration.
endCondition- Condition that will cause this method to return if it is true.
timeout- Maximum time to wait for the topology to complete or reach its end condition.
unit- Unit for
Exception- Failure submitting or executing the topology.
public Job getJob()
Jobreference for the topology submitted by
conditionsare valid. The result of the condition is
Copyright © 2016–2017 The Apache Software Foundation. All rights reserved.