Uses of Interface
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 Inbox Modifier and Type Method Description
Inbox inbox)(int ordinal,Implements the boilerplate of dispatching against the ordinal, taking items from the inbox one by one, and invoking the processing logic on each.
Inbox inbox)(int ordinal,Called with a batch of items retrieved from an inbound edge's stream.
Inbox inbox)(Implements the boilerplate of polling the inbox, casting the items to
Map.Entry, and extracting the key and value.
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