Uses of Interface
com.hazelcast.jet.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 underlyingRingbuffer
, which defaults to 10000.<T> Observable<T>
JetInstance. getObservable(String name)
Returns anObservable
instance with the specified name.default <T> Observable<T>
JetInstance. newObservable()
Returns a new observable with a randomly generated nameMethods in com.hazelcast.jet that return types with arguments of type Observable Modifier and Type Method Description Collection<Observable<?>>
JetInstance. getObservables()
Returns a list of all theObservables
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 providedObservable
.