com.hazelcast.datalink

Interface DataLinkService

public interface DataLinkService

The interface provides access to DataLinks for Jet processors. A Jet processor can obtain a reference to the service via ProcessorMetaSupplier.Context#dataLinkService().

DataLinks can be created via one of the following ways:

• statically in the configuration
• dynamically via Config.addDataLinkConfig(DataLinkConfig)
• via SQL CREATE DATA LINK ... command

Since:

5.3

Method Summary

Modifier and Type	Method and Description
<T extends DataLink> T	getAndRetainDataLink(String name, Class<T> clazz) Returns DataLink with the given name and `retain` it (calls DataLink.retain()).

Method Detail

getAndRetainDataLink

<T extends DataLink> T getAndRetainDataLink(String name,
                                            Class<T> clazz)

Returns DataLink with the given name and `retain` it (calls DataLink.retain()). The caller is responsible for calling DataLink.release() after it is done with the DataLink.

Type is checked against the provided `clazz` argument.

Parameters:

name - name of the DataLink

clazz - expected type of the DataLink

Throws:

HazelcastException - if the requested DataLink doesn't exist, or has a different type than `clazz`