Uses of Interface
com.hazelcast.jet.core.Inbox
Package
Description
Jet's Core API.
Utilities for writing tests of Core API Processors.
-
Uses of Inbox in com.hazelcast.jet.core
Modifier and TypeMethodDescriptionvoid
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
Called with a batch of items retrieved from an inbound edge's stream.final 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