Package | Description |
---|---|
com.hazelcast.jet.core.test |
Utilities for writing tests of Core API Processors.
|
Modifier and Type | Method and 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.hazelcastInstance(HazelcastInstance hazelcastInstance)
Use the given instance for
ProcessorMetaSupplier.Context.hazelcastInstance() |
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.jobConfig(JobConfig jobConfig)
Use the given instance for
ProcessorMetaSupplier.Context.jobConfig() |
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(ProcessorMetaSupplier supplier) |
static TestSupport |
TestSupport.verifyProcessor(ProcessorSupplier supplier) |
static TestSupport |
TestSupport.verifyProcessor(SupplierEx<Processor> supplier) |
Copyright © 2023 Hazelcast, Inc.. All rights reserved.