Uses of Interface
com.hazelcast.jet.core.Inbox
Package | Description |
---|---|
com.hazelcast.jet.core |
Jet's Core API.
|
com.hazelcast.jet.core.test |
Utilities for writing tests of Core API Processors.
|
-
Uses of Inbox in com.hazelcast.jet.core
Methods in com.hazelcast.jet.core with parameters of type Inbox Modifier and Type Method Description 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. process(int ordinal, Inbox inbox)
Called with a batch of items retrieved from an inbound edge's stream.void
AbstractProcessor. restoreFromSnapshot(Inbox inbox)
Implements the boilerplate of polling the inbox, casting the items toMap.Entry
, and extracting the key and value.default void
Processor. restoreFromSnapshot(Inbox inbox)
Called when a batch of items is received during the "restore from snapshot" operation. -
Uses of Inbox in com.hazelcast.jet.core.test
Classes in com.hazelcast.jet.core.test that implement Inbox Modifier and Type Class Description class
TestInbox
Inbox
implementation suitable to be used in tests.