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	Description
Observable<T>	Observable.configureCapacity(int capacity)	Set the capacity of the underlying Ringbuffer, which defaults to 10000.
<T> Observable<T>	JetService.getObservable(String name)	Returns an Observable instance with the specified name.
default <T> Observable<T>	JetService.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	Description
Collection<Observable<?>>	JetService.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	Description
static <T> Sink<T>	Sinks.observable(Observable<? super T> observable)	Returns a sink that publishes to the provided Observable.