Package | Description |
---|---|
com.hazelcast.jet.core.test |
Utilities for writing tests of Core API Processors.
|
Modifier and Type | Method and Description |
---|---|
TestProcessorContext |
TestProcessorContext.setGlobalProcessorIndex(int globalProcessorIndex)
Set the global processor index
|
TestProcessorContext |
TestProcessorContext.setHazelcastInstance(HazelcastInstance instance) |
TestProcessorContext |
TestProcessorContext.setIsLightJob(boolean isLightJob) |
TestProcessorContext |
TestProcessorContext.setJobConfig(JobConfig jobConfig) |
TestProcessorContext |
TestProcessorContext.setLocalParallelism(int localParallelism) |
TestProcessorContext |
TestProcessorContext.setLocalProcessorIndex(int localProcessorIndex)
Set the local processor index
|
TestProcessorContext |
TestProcessorContext.setLogger(ILogger logger) |
TestProcessorContext |
TestProcessorContext.setManagedContext(ManagedContext managedContext) |
TestProcessorContext |
TestProcessorContext.setPartitionAssignment(Map<Address,int[]> partitionAssignment) |
TestProcessorContext |
TestProcessorContext.setProcessingGuarantee(ProcessingGuarantee processingGuarantee) |
TestProcessorContext |
TestProcessorContext.setTotalParallelism(int totalParallelism) |
TestProcessorContext |
TestProcessorContext.setVertexName(String vertexName) |
Copyright © 2021 Hazelcast, Inc.. All rights reserved.