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 |
---|---|
default void |
Processor.process(int ordinal,
Inbox inbox)
Called with a batch of items retrieved from an inbound edge's stream.
|
void |
AbstractProcessor.process(int ordinal,
Inbox inbox)
Implements the boilerplate of dispatching against the ordinal,
taking items from the inbox one by one, and invoking the
processing logic on each.
|
default void |
Processor.restoreFromSnapshot(Inbox inbox)
Called when a batch of items is received during the "restore from
snapshot" operation.
|
void |
AbstractProcessor.restoreFromSnapshot(Inbox inbox)
Implements the boilerplate of polling the inbox, casting the items to
Map.Entry , and extracting the key and value. |
Modifier and Type | Class and Description |
---|---|
class |
TestInbox
Inbox implementation suitable to be used in tests. |
Copyright © 2023 Hazelcast, Inc.. All rights reserved.