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. |
class |
TestProcessorSupplierContext
Implementation of
ProcessorSupplier.Context suitable to be used
in tests. |
Modifier and Type | Method and Description |
---|---|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setExecutionId(long executionId)
Sets the execution ID.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setIsLightJob(boolean isLightJob)
Sets the isLightJob flag.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setJetInstance(JetInstance jetInstance)
Sets the jet instance.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setJobConfig(JobConfig jobConfig)
Sets the config for the job.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setJobId(long jobId)
Sets the job ID.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setLocalParallelism(int localParallelism)
Sets local parallelism.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setLogger(ILogger logger)
Sets the logger.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setProcessingGuarantee(ProcessingGuarantee processingGuarantee)
Sets the processing guarantee.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setTotalParallelism(int totalParallelism)
Sets the total parallelism.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setVertexName(String vertexName)
Sets the vertex name.
|
Copyright © 2021 Hazelcast, Inc.. All rights reserved.