Uses of Class
com.hazelcast.jet.core.test.TestSupport
Package | Description |
---|---|
com.hazelcast.jet.core.test |
Utilities for writing tests of Core API Processors.
|
-
Uses of TestSupport in com.hazelcast.jet.core.test
Methods in com.hazelcast.jet.core.test that return TestSupport Modifier and Type Method Description TestSupport
TestSupport. cooperativeTimeout(long timeout)
Iftimeout > 0
, the test will fail if any call to processing method in a cooperative processor exceeds this timeout.TestSupport
TestSupport. disableCompleteCall()
Disables callingcomplete()
method during the test.TestSupport
TestSupport. disableLogging()
Disables logging of input and output objects.TestSupport
TestSupport. disableProgressAssertion()
Disables checking of progress of processing methods (seeclass javadoc
for information on what is "progress").TestSupport
TestSupport. disableSnapshots()
Disable snapshot save and restore before first item and after eachprocess()
andcomplete()
call.TestSupport
TestSupport. executeBeforeEachRun(Runnable runnable)
Execute test before each test runTestSupport
TestSupport. globalProcessorIndex(int globalProcessorIndex)
Sets the globalProcessorIndex for the ProcessorTestSupport
TestSupport. input(List<?> input)
Sets the input objects for processor.TestSupport
TestSupport. inputs(List<List<?>> inputs)
Sets the input objects for the processor on multiple input ordinals.TestSupport
TestSupport. inputs(List<List<?>> inputs, int[] priorities)
Sets the input objects for the processor on multiple input ordinals.TestSupport
TestSupport. jetInstance(JetInstance jetInstance)
Use the given instance forProcessorMetaSupplier.Context.jetInstance()
TestSupport
TestSupport. localParallelism(int localParallelism)
Sets the localParallelism for the ProcessorTestSupport
TestSupport. localProcessorIndex(int localProcessorIndex)
Sets the localProcessorIndex for the ProcessorTestSupport
TestSupport. outputChecker(BiPredicate<? super List<?>,? super List<?>> outputChecker)
Predicate to compare expected and actual output.TestSupport
TestSupport. runUntilOutputMatches(long timeoutMillis, long extraTimeMillis)
Normally, thecomplete()
method is run repeatedly until it returnstrue
.TestSupport
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)