Package | Description |
---|---|
com.hazelcast.jet.core.test |
Utilities for writing tests of Core API Processors.
|
Modifier and Type | Class and Description |
---|---|
class |
TestProcessorContext
Processor.Context implementation suitable to be used in tests. |
Modifier and Type | Method and Description |
---|---|
TestProcessorSupplierContext |
TestProcessorSupplierContext.setJetInstance(JetInstance jetInstance) |
TestProcessorSupplierContext |
TestProcessorSupplierContext.setLocalParallelism(int localParallelism) |
TestProcessorSupplierContext |
TestProcessorSupplierContext.setLogger(ILogger logger) |
TestProcessorSupplierContext |
TestProcessorSupplierContext.setMemberIndex(int memberIndex)
Set the member index.
|
TestProcessorSupplierContext |
TestProcessorSupplierContext.setProcessingGuarantee(ProcessingGuarantee processingGuarantee) |
TestProcessorSupplierContext |
TestProcessorSupplierContext.setTotalParallelism(int totalParallelism) |
TestProcessorSupplierContext |
TestProcessorSupplierContext.setVertexName(String vertexName) |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.