Uses of Class
com.hazelcast.jet.core.test.TestSupport

Packages that use 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)	If timeout > 0, the test will fail if any call to processing method in a cooperative processor exceeds this timeout.
TestSupport	TestSupport.disableCompleteCall()	Disables calling complete() method during the test.
TestSupport	TestSupport.disableLogging()	Disables logging of input and output objects.
TestSupport	TestSupport.disableProgressAssertion()	Disables checking of progress of processing methods (see class javadoc for information on what is "progress").
TestSupport	TestSupport.disableSnapshots()	Disable snapshot save and restore before first item and after each process() and complete() call.
TestSupport	TestSupport.executeBeforeEachRun(Runnable runnable)	Execute test before each test run
TestSupport	TestSupport.globalProcessorIndex(int globalProcessorIndex)	Sets the globalProcessorIndex for the Processor
TestSupport	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 for ProcessorMetaSupplier.Context.jetInstance()
TestSupport	TestSupport.localParallelism(int localParallelism)	Sets the localParallelism for the Processor
TestSupport	TestSupport.localProcessorIndex(int localProcessorIndex)	Sets the localProcessorIndex for the Processor
TestSupport	TestSupport.outputChecker(BiPredicate<? super List<?>,? super List<?>> outputChecker)	Predicate to compare expected and actual output.
TestSupport	TestSupport.runUntilOutputMatches(long timeoutMillis, long extraTimeMillis)	Normally, the complete() method is run repeatedly until it returns true.
TestSupport	TestSupport.totalParallelism(int totalParallelism)	Sets the totalParallelism for the Processor
static TestSupport	TestSupport.verifyProcessor(SupplierEx<Processor> supplier)
static TestSupport	TestSupport.verifyProcessor(ProcessorMetaSupplier supplier)
static TestSupport	TestSupport.verifyProcessor(ProcessorSupplier supplier)