Uses of Interface
com.hazelcast.jet.core.Inbox
Packages that use Inbox
Package
Description
Jet's Core API.
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 InboxModifier and TypeMethodDescriptionvoidImplements the boilerplate of dispatching against the ordinal, taking items from the inbox one by one, and invoking the processing logic on each.default voidCalled with a batch of items retrieved from an inbound edge's stream.final voidAbstractProcessor.restoreFromSnapshot(Inbox inbox) Implements the boilerplate of polling the inbox, casting the items toMap.Entry, and extracting the key and value.default voidProcessor.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