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 | Method and Description |
---|---|
protected Outbox |
AbstractProcessor.getOutbox() |
Modifier and Type | Method and Description |
---|---|
void |
AbstractProcessor.init(Outbox outbox,
Processor.Context context) |
default void |
Processor.init(Outbox outbox,
Processor.Context context)
Initializes this processor with the outbox that the processing
methods must use to deposit their output items.
|
Modifier and Type | Class and Description |
---|---|
class |
TestOutbox
Outbox implementation suitable to be used in tests. |
Copyright © 2021 Hazelcast, Inc.. All rights reserved.