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.addFile(String id,
File file)
Add an attached file or folder.
|
TestProcessorSupplierContext |
TestProcessorSupplierContext.setHazelcastInstance(HazelcastInstance instance) |
TestProcessorSupplierContext |
TestProcessorSupplierContext.setIsLightJob(boolean isLightJob) |
TestProcessorSupplierContext |
TestProcessorSupplierContext.setJobConfig(JobConfig jobConfig) |
TestProcessorSupplierContext |
TestProcessorSupplierContext.setLocalParallelism(int localParallelism) |
TestProcessorSupplierContext |
TestProcessorSupplierContext.setLogger(ILogger logger) |
TestProcessorSupplierContext |
TestProcessorSupplierContext.setManagedContext(ManagedContext managedContext)
Sets the
ManagedContext |
TestProcessorSupplierContext |
TestProcessorSupplierContext.setMemberIndex(int memberIndex)
Sets the member index
|
TestProcessorSupplierContext |
TestProcessorSupplierContext.setPartitionAssignment(Map<Address,int[]> partitionAssignment) |
TestProcessorSupplierContext |
TestProcessorSupplierContext.setProcessingGuarantee(ProcessingGuarantee processingGuarantee) |
TestProcessorSupplierContext |
TestProcessorSupplierContext.setTotalParallelism(int totalParallelism) |
TestProcessorSupplierContext |
TestProcessorSupplierContext.setVertexName(String vertexName) |
Copyright © 2021 Hazelcast, Inc.. All rights reserved.