public interface JetInstance
Modifier and Type | Method and Description |
---|---|
JetCacheManager |
getCacheManager()
Obtain the
JetCacheManager that provides access to JSR-107 (JCache) caches
configured on a Hazelcast Jet cluster. |
com.hazelcast.core.Cluster |
getCluster()
Returns information about the cluster this Jet instance is part of.
|
JetConfig |
getConfig()
Returns the configuration for this Jet member.
|
com.hazelcast.core.HazelcastInstance |
getHazelcastInstance()
Returns the underlying Hazelcast IMDG instance used by Jet.
|
Collection<Job> |
getJobs()
Returns all submitted jobs including running and completed ones
|
<E> IStreamList<E> |
getList(String name)
Returns the distributed list instance with the specified name.
|
<K,V> IStreamMap<K,V> |
getMap(String name)
Returns the distributed map instance with the specified name.
|
String |
getName()
Returns the name of the Jet instance.
|
Job |
newJob(DAG dag)
Creates and returns a Jet job based on the supplied DAG.
|
Job |
newJob(DAG dag,
JobConfig config)
Creates and returns a Jet job based on the supplied DAG and job
configuration.
|
default Job |
newJob(Pipeline pipeline)
Creates and returns an executable job based on the supplied pipeline.
|
default Job |
newJob(Pipeline pipeline,
JobConfig config)
Creates and returns a Jet job based on the supplied pipeline and job
configuration.
|
void |
shutdown()
Shutdowns the current instance.
|
String getName()
com.hazelcast.core.HazelcastInstance getHazelcastInstance()
JetInstance
.com.hazelcast.core.Cluster getCluster()
JetConfig getConfig()
Job newJob(DAG dag)
Job newJob(DAG dag, JobConfig config)
default Job newJob(Pipeline pipeline)
default Job newJob(Pipeline pipeline, JobConfig config)
Collection<Job> getJobs()
<K,V> IStreamMap<K,V> getMap(String name)
name
- name of the distributed map<E> IStreamList<E> getList(String name)
name
- name of the distributed listJetCacheManager getCacheManager()
JetCacheManager
that provides access to JSR-107 (JCache) caches
configured on a Hazelcast Jet cluster.
Note that this method does not return a JCache CacheManager
JetCacheManager
JetCacheManager
void shutdown()
Copyright © 2017 Hazelcast, Inc.. All Rights Reserved.