| 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.