Uses of Class
com.hazelcast.jet.core.test.TestSupport
-
Uses of TestSupport in com.hazelcast.jet.core.test
Modifier and TypeMethodDescriptionTestSupport.cooperativeTimeout
(long timeout) Iftimeout > 0
, the test will fail if any call to processing method in a cooperative processor exceeds this timeout.TestSupport.disableCompleteCall()
Disables callingcomplete()
method during the test.TestSupport.disableLogging()
Disables logging of input and output objects.TestSupport.disableProgressAssertion()
Disables checking of progress of processing methods (seeclass javadoc
for information on what is "progress").TestSupport.disableSnapshots()
Disable snapshot save and restore before first item and after eachprocess()
andcomplete()
call.TestSupport.executeBeforeEachRun
(Runnable runnable) Action to execute before each test scenario.TestSupport.globalProcessorIndex
(int globalProcessorIndex) Sets the globalProcessorIndex for the ProcessorTestSupport.hazelcastInstance
(HazelcastInstance hazelcastInstance) Use the given instance forProcessorMetaSupplier.Context.hazelcastInstance()
Sets the input objects for processor.Sets the input objects for the processor on multiple input ordinals.Sets the input objects for the processor on multiple input ordinals.Use the given instance forProcessorMetaSupplier.Context.jobConfig()
TestSupport.localParallelism
(int localParallelism) Sets the localParallelism for the ProcessorTestSupport.localProcessorIndex
(int localProcessorIndex) Sets the localProcessorIndex for the ProcessorTestSupport.outputChecker
(BiPredicate<? super List<?>, ? super List<?>> outputChecker) Predicate to compare expected and actual output.TestSupport.runUntilOutputMatches
(long timeoutMillis, long extraTimeMillis) Normally, thecomplete()
method is run repeatedly until it returnstrue
.TestSupport.totalParallelism
(int totalParallelism) Sets the totalParallelism for the Processorstatic TestSupport
TestSupport.verifyProcessor
(SupplierEx<Processor> supplier) static TestSupport
TestSupport.verifyProcessor
(ProcessorMetaSupplier supplier) static TestSupport
TestSupport.verifyProcessor
(ProcessorSupplier supplier)