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.
|
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> |
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
|
Modifier and Type | Method and Description |
---|---|
Collection<Observable<?>> |
JetService.getObservables()
Returns a list of all the
Observables that are active. |
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 . |
Copyright © 2023 Hazelcast, Inc.. All rights reserved.