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
ProcessorSupplier.Context implementation suitable to be used in tests. |
Modifier and Type | Method and Description |
---|---|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setExecutionId(long executionId)
Sets the execution ID.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setJetInstance(JetInstance jetInstance)
Sets the jet instance.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setJobConfig(JobConfig jobConfig)
Sets the job name.
|
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 © 2020 Hazelcast, Inc.. All rights reserved.