Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
com.hazelcast.jet.core.test |
Utilities for writing tests of Core API Processors.
|
Modifier and Type | Interface and Description |
---|---|
static interface |
Processor.Context
Context passed to the processor in the
init() call. |
Modifier and Type | Method and Description |
---|---|
default void |
ProcessorSupplier.init(ProcessorSupplier.Context context)
Called on each cluster member after deserialization.
|
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 |
---|---|
static Supplier<Processor> |
TestSupport.supplierFrom(ProcessorMetaSupplier supplier,
ProcessorSupplier.Context context)
Wraps the provided
ProcessorMetaSupplier with a Supplier<Processor> that returns processors obtained from it. |
static Supplier<Processor> |
TestSupport.supplierFrom(ProcessorSupplier supplier,
ProcessorSupplier.Context context)
Wraps the provided
ProcessorSupplier with a Supplier<Processor> that returns processors obtained from it. |
Copyright © 2019 Hazelcast, Inc.. All rights reserved.