com.hazelcast.jet

Interface JetInstance

public interface JetInstance

Represents either an instance of a Jet server node or a Jet client instance that connects to a remote cluster.

Method Summary

Modifier and Type	Method and Description
<K,V> IStreamCache<K,V>	getCache(String name) Returns the distributed cache instance with the specified name.
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.
<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 an executable job based on a given DAG.
Job	newJob(DAG dag, JobConfig config) Creates and returns an executable Job based on the supplied DAG and job configuration.
void	shutdown() Shutdowns the current instance.

Method Detail

getName

String getName()

Returns the name of the Jet instance.

getHazelcastInstance

com.hazelcast.core.HazelcastInstance getHazelcastInstance()

Returns the underlying Hazelcast IMDG instance used by Jet. It will be either a server node or a client, depending on the type of this JetInstance.

getCluster

com.hazelcast.core.Cluster getCluster()

Returns information about the cluster this Jet instance is part of.

getConfig

JetConfig getConfig()

Returns the configuration for this Jet member. This method is not available on client instances.

newJob

Job newJob(DAG dag)

Creates and returns an executable job based on a given DAG.

Parameters:

dag - The DAG that will be used to for the execution of the job

Returns:

a new Job instance

newJob

Job newJob(DAG dag,
           JobConfig config)

Creates and returns an executable Job based on the supplied DAG and job configuration.

Returns:

a new Job instance

getMap

<K,V> IStreamMap<K,V> getMap(String name)

Returns the distributed map instance with the specified name.

Parameters:

name - name of the distributed map

Returns:

distributed map instance with the specified name

getCache

<K,V> IStreamCache<K,V> getCache(String name)

Returns the distributed cache instance with the specified name.

Parameters:

name - name of the distributed cache

Returns:

distributed cache instance with the specified name

getList

<E> IStreamList<E> getList(String name)

Returns the distributed list instance with the specified name. Index-based operations on the list are not supported.

Parameters:

name - name of the distributed list

Returns:

distributed list instance with the specified name

shutdown

void shutdown()

Shutdowns the current instance.