Package com.hazelcast.dataconnection
Interface DataConnectionService
public interface DataConnectionService
The interface provides access to
DataConnection
s for Jet processors. A Jet
processor can obtain a reference to the service via ProcessorMetaSupplier.Context.dataConnectionService()
.
Data connections can be created via one of the following ways:
- statically in the configuration
- dynamically via
Config.addDataConnectionConfig(DataConnectionConfig)
- via SQL
CREATE DATA CONNECTION ...
command
- Since:
- 5.3
-
Method Summary
Modifier and TypeMethodDescription<T extends DataConnection>
TgetAndRetainDataConnection
(String name, Class<T> clazz) ReturnsDataConnection
with the given name and `retain` it (callsDataConnection.retain()
).
-
Method Details
-
getAndRetainDataConnection
ReturnsDataConnection
with the given name and `retain` it (callsDataConnection.retain()
). The caller is responsible for callingDataConnection.release()
after it is done with the DataConnection.Type is checked against the provided `clazz` argument.
- Parameters:
name
- name of the DataConnectionclazz
- expected type of the DataConnection- Throws:
HazelcastException
- if the requested DataConnection doesn't exist, or has a different type than `clazz`
-