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.setJetInstance(JetInstance jetInstance)
Set the jet instance.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setLocalParallelism(int localParallelism)
Set local parallelism.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setLogger(ILogger logger)
Set the logger.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setTotalParallelism(int totalParallelism)
Set total parallelism.
|
TestProcessorMetaSupplierContext |
TestProcessorMetaSupplierContext.setVertexName(String vertexName)
Set the vertex name.
|
Copyright © 2018 Hazelcast, Inc.. All rights reserved.