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.disableRunUntilCompleted(long timeoutMillis)
If the timeout > 0, the
complete() method is called repeatedly
until the timeout elapses. |
TestSupport |
TestSupport.disableSnapshots()
Disable snapshot save and restore before first item and after each
process() and complete() call. |
TestSupport |
TestSupport.input(List<?> input)
Sets the input objects for processor.
|
TestSupport |
TestSupport.outputChecker(java.util.function.BiPredicate<? super List<?>,? super List<?>> outputChecker)
Predicate to compare expected and actual output.
|
static TestSupport |
TestSupport.verifyProcessor(Processor processor) |
static TestSupport |
TestSupport.verifyProcessor(ProcessorMetaSupplier supplier) |
static TestSupport |
TestSupport.verifyProcessor(ProcessorSupplier supplier) |
static TestSupport |
TestSupport.verifyProcessor(java.util.function.Supplier<Processor> supplier) |
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.