Uses of Interface
com.hazelcast.jet.Observable

Packages that use Observable

Package	Description
com.hazelcast.jet	Hazelcast Jet is a distributed computation engine running on top of Hazelcast IMDG technology.
com.hazelcast.jet.pipeline	The Pipeline API is Jet's high-level API to build and execute distributed computation jobs.

Uses of Observable in com.hazelcast.jet

Methods in com.hazelcast.jet that return Observable

Modifier and Type	Method and Description
Observable<T>	Observable.configureCapacity(int capacity) Set the capacity of the underlying Ringbuffer, which defaults to .
<T> Observable<T>	JetInstance.getObservable(String name) Returns an Observable instance with the specified name.
default <T> Observable<T>	JetInstance.newObservable() Returns a new observable with a randomly generated name

Methods in com.hazelcast.jet that return types with arguments of type Observable

Modifier and Type	Method and Description
Collection<Observable<?>>	JetInstance.getObservables() Returns a list of all the Observables that are active.

Uses of Observable in com.hazelcast.jet.pipeline

Methods in com.hazelcast.jet.pipeline with parameters of type Observable

Modifier and Type	Method and Description
static <T> Sink<T>	Sinks.observable(Observable<? super T> observable) Returns a sink that publishes to the provided Observable.