Package | Description |
---|---|
com.hazelcast.console |
This package contains classes related to ConsoleApp
|
com.hazelcast.core |
Provides core API interfaces/classes.
|
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 |
---|---|
ITopic<Object> |
ConsoleApp.getTopic() |
Modifier and Type | Method and Description |
---|---|
<E> ITopic<E> |
HazelcastInstance.getReliableTopic(String name)
Creates or returns the reliable topic instance with the specified name.
|
<E> ITopic<E> |
HazelcastInstance.getTopic(String name)
Creates or returns the distributed topic instance with the specified name.
|
Modifier and Type | Method and Description |
---|---|
<E> ITopic<E> |
JetInstance.getReliableTopic(String name)
Returns a distributed reliable topic instance with the specified name.
|
Modifier and Type | Method and Description |
---|---|
static <T> Sink<T> |
Sinks.reliableTopic(ITopic<Object> reliableTopic)
Returns a sink which publishes the items it receives to the provided
distributed reliable topic.
|
Copyright © 2021 Hazelcast, Inc.. All rights reserved.