Uses of Class
com.hazelcast.client.config.ClientConfig
Package
Description
Contains classes/interfaces related to Client
Contains classes related to config for com.hazelcast.client
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
Contains source/sink connectors that deal with Change Data Capture (CDC)
events from various databases as well as a generic connector for Debezium
CDC sources.
Contains static utility classes with factories of Jet processors.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
Contains config factory classes.
-
Uses of ClientConfig in com.hazelcast.client
Modifier and TypeMethodDescriptionstatic HazelcastInstance
HazelcastClient.getOrCreateHazelcastClient
(ClientConfig config) Gets or creates a new HazelcastInstance (a new client in a cluster) with a certain name.void
LoadBalancer.init
(Cluster cluster, ClientConfig config) Initializes the LoadBalancer.static HazelcastInstance
HazelcastClient.newHazelcastClient
(ClientConfig config) Creates a new HazelcastInstance (a new client in a cluster). -
Uses of ClientConfig in com.hazelcast.client.config
Modifier and TypeClassDescriptionclass
AClientConfig
which is initialized by loading an XML configuration file from the classpath.class
AClientConfig
which is initialized by loading an YAML configuration file from the classpath.Modifier and TypeMethodDescriptionClientConfig.addFlakeIdGeneratorConfig
(ClientFlakeIdGeneratorConfig config) Adds a flake ID generator configuration.Adds a label for this clientClient
availableClientConfig.addListenerConfig
(ListenerConfig listenerConfig) Helper method to add a new ListenerConfigClientConfig.addNearCacheConfig
(NearCacheConfig nearCacheConfig) Helper method to add a new NearCacheConfigClientConfig.addProxyFactoryConfig
(ProxyFactoryConfig proxyFactoryConfig) Helper method to add a newProxyFactoryConfig
ClientConfig.addQueryCacheConfig
(String mapName, QueryCacheConfig queryCacheConfig) ClientConfig.addReliableTopicConfig
(ClientReliableTopicConfig reliableTopicConfig) Adds a ClientReliableTopicConfig.XmlClientConfigBuilder.build()
XmlClientConfigBuilder.build
(ClassLoader classLoader) YamlClientConfigBuilder.build()
YamlClientConfigBuilder.build
(ClassLoader classLoader) static ClientConfig
ClientConfig.load()
Populates HazelcastClientConfig
object from an external configuration file.ClientConfig.setBackupAckToClientEnabled
(boolean backupAckToClientEnabled) This feature reduces number of hops and increases performance forRoutingMode.ALL_MEMBERS
routing clients.ClientConfig.setClassLoader
(ClassLoader classLoader) Sets the classLoader which is used by serialization and listener configurationClientConfig.setClusterName
(String clusterName) ClientConfig.setConfigPatternMatcher
(ConfigPatternMatcher configPatternMatcher) Sets the pattern matcher which is used to match item names to configuration objects.ClientConfig.setConnectionStrategyConfig
(ClientConnectionStrategyConfig connectionStrategyConfig) ClientConfig.setCPDirectToLeaderRoutingEnabled
(boolean cpDirectToLeaderRoutingEnabled) Sets whether CP direct-to-leader operation sending is enabled.ClientConfig.setCredentials
(Credentials credentials) Shortcut forgetSecurityConfig().setCredentials()
ClientConfig.setFlakeIdGeneratorConfigMap
(Map<String, ClientFlakeIdGeneratorConfig> map) Sets the map ofFlakeIdGenerator
configurations, mapped by config name.ClientConfig.setInstanceName
(String instanceName) ClientConfig.setInstanceTrackingConfig
(InstanceTrackingConfig instanceTrackingConfig) Returns the configuration for tracking use of this Hazelcast instance.Set labels for the client.ClientConfig.setListenerConfigs
(List<ListenerConfig> listenerConfigs) Sets allListenerConfig
'sClientConfig.setLoadBalancer
(LoadBalancer loadBalancer) Sets theLoadBalancer
.ClientConfig.setLoadBalancerClassName
(String loadBalancerClassName) Sets load balancer class name.ClientConfig.setManagedContext
(ManagedContext managedContext) SetsManagedContext
ClientConfig.setMetricsConfig
(ClientMetricsConfig metricsConfig) Sets the metrics collection config.ClientConfig.setNativeMemoryConfig
(NativeMemoryConfig nativeMemoryConfig) ClientConfig.setNearCacheConfigMap
(Map<String, NearCacheConfig> nearCacheConfigMap) Sets allNearCacheConfig
's with the provided mapClientConfig.setNetworkConfig
(ClientNetworkConfig networkConfig) SetsClientNetworkConfig
ClientConfig.setProperties
(Properties properties) sets all propertiesClientConfig.setProperty
(String name, String value) Sets the value of a named property.ClientConfig.setProxyFactoryConfigs
(List<ProxyFactoryConfig> proxyFactoryConfigs) Sets theProxyFactoryConfig
ClientConfig.setQueryCacheConfigs
(Map<String, Map<String, QueryCacheConfig>> queryCacheConfigs) ClientConfig.setReliableTopicConfigMap
(Map<String, ClientReliableTopicConfig> map) Sets the map ofClientReliableTopicConfig
, mapped by config name.ClientConfig.setSecurityConfig
(ClientSecurityConfig securityConfig) SetsClientSecurityConfig
objectClientConfig.setSerializationConfig
(SerializationConfig serializationConfig) SetsSerializationConfig
ClientConfig.setSqlConfig
(ClientSqlConfig sqlConfig) Sets the configuration for the SQL feature.ClientConfig.setTpcConfig
(ClientTpcConfig tpcConfig) Sets the TpcConfigClientConfig.setUserCodeDeploymentConfig
(ClientUserCodeDeploymentConfig userCodeDeploymentConfig) Set User Code Deployment configurationClientConfig.setUserContext
(ConcurrentMap<String, Object> userContext) Modifier and TypeMethodDescriptionClientFailoverConfig.getClientConfigs()
Gets the configured list of alternative client configurations.Modifier and TypeMethodDescriptionClientFailoverConfig.addClientConfig
(ClientConfig clientConfig) Adds the client config to the end of the alternative client configurations list.static String
ClientConfigXmlGenerator.generate
(ClientConfig clientConfig) Convenience forClientConfigXmlGenerator.generate(ClientConfig, int)
, which generates the xml without any formatting.static String
ClientConfigXmlGenerator.generate
(ClientConfig clientConfig, int indent) Transforms the givenClientConfig
to xml string formatting the output with givenindent
, -1 means no formatting.Modifier and TypeMethodDescriptionClientFailoverConfig.setClientConfigs
(List<ClientConfig> clientConfigs) Sets the configured list of alternative client configurations. -
Uses of ClientConfig in com.hazelcast.jet
Modifier and TypeMethodDescriptionstatic JetInstance
Jet.newJetClient
(ClientConfig config) Deprecated. -
Uses of ClientConfig in com.hazelcast.jet.cdc
Modifier and TypeMethodDescriptionstatic <K,
V> Sink<ChangeRecord> CdcSinks.remoteMap
(String mapName, ClientConfig clientConfig, FunctionEx<? super ChangeRecord, ? extends K> keyFn, FunctionEx<? super ChangeRecord, ? extends V> valueFn) Returns a sink equivalent toCdcSinks.map(java.lang.String, com.hazelcast.function.FunctionEx<? super com.hazelcast.jet.cdc.ChangeRecord, ? extends K>, com.hazelcast.function.FunctionEx<? super com.hazelcast.jet.cdc.ChangeRecord, ? extends V>)
, but for a map in a remote Hazelcast cluster identified by the suppliedClientConfig
. -
Uses of ClientConfig in com.hazelcast.jet.core.processor
Modifier and TypeMethodDescriptionstatic <T,
K, V> ProcessorMetaSupplier SinkProcessors.mergeRemoteMapP
(String mapName, ClientConfig clientConfig, FunctionEx<? super T, ? extends K> toKeyFn, FunctionEx<? super T, ? extends V> toValueFn, BinaryOperatorEx<V> mergeFn) Returns a supplier of processors forSinks.remoteMapWithMerging(String, ClientConfig, FunctionEx, FunctionEx, BinaryOperatorEx)
.static ProcessorSupplier
SourceProcessors.readRemoteCacheP
(String cacheName, ClientConfig clientConfig) Returns a supplier of processors forSources.remoteCache(String, ClientConfig)
.static ProcessorMetaSupplier
SourceProcessors.readRemoteListP
(String listName, ClientConfig clientConfig) Returns a supplier of processors forSources.remoteList(String, ClientConfig)
.static <T,
K, V> ProcessorMetaSupplier SourceProcessors.streamRemoteCacheP
(String cacheName, ClientConfig clientConfig, PredicateEx<? super EventJournalCacheEvent<K, V>> predicateFn, FunctionEx<? super EventJournalCacheEvent<K, V>, ? extends T> projectionFn, JournalInitialPosition initialPos, EventTimePolicy<? super T> eventTimePolicy) Returns a supplier of processors forSources.remoteCacheJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx)
.static <K,
V> ProcessorMetaSupplier SourceProcessors.streamRemoteCacheP
(String cacheName, ClientConfig clientConfig, JournalInitialPosition initialPos, EventTimePolicy<? super Map.Entry<K, V>> eventTimePolicy) Returns a supplier of processors forSources.remoteCacheJournal(String, ClientConfig, JournalInitialPosition)
.static <T,
K, V> ProcessorMetaSupplier SourceProcessors.streamRemoteMapP
(String mapName, ClientConfig clientConfig, PredicateEx<? super EventJournalMapEvent<K, V>> predicateFn, FunctionEx<? super EventJournalMapEvent<K, V>, ? extends T> projectionFn, JournalInitialPosition initialPos, EventTimePolicy<? super T> eventTimePolicy) Returns a supplier of processors forSources.remoteMapJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx)
.static <K,
V> ProcessorMetaSupplier SourceProcessors.streamRemoteMapP
(String mapName, ClientConfig clientConfig, JournalInitialPosition initialPos, EventTimePolicy<? super Map.Entry<K, V>> eventTimePolicy) Returns a supplier of processors forSources.remoteMapJournal(String, ClientConfig, JournalInitialPosition)
.static <T,
K, V> ProcessorMetaSupplier SinkProcessors.updateRemoteMapP
(String mapName, ClientConfig clientConfig, FunctionEx<? super T, ? extends K> toKeyFn, BiFunctionEx<? super V, ? super T, ? extends V> updateFn) Returns a supplier of processors forSinks.remoteMapWithUpdating(String, ClientConfig, FunctionEx, BiFunctionEx)
.static <T,
K, V, R> ProcessorMetaSupplier SinkProcessors.updateRemoteMapP
(String mapName, ClientConfig clientConfig, FunctionEx<? super T, ? extends K> toKeyFn, FunctionEx<? super T, ? extends EntryProcessor<K, V, R>> toEntryProcessorFn) Returns a supplier of processors forSinks.remoteMapWithEntryProcessor(String, ClientConfig, FunctionEx, FunctionEx)
.static ProcessorMetaSupplier
SinkProcessors.writeRemoteCacheP
(String cacheName, ClientConfig clientConfig) Returns a supplier of processors forSinks.remoteCache(String, ClientConfig)
.static ProcessorMetaSupplier
SinkProcessors.writeRemoteListP
(String listName, ClientConfig clientConfig) Returns a supplier of processors forSinks.remoteList(String, ClientConfig)
.static ProcessorMetaSupplier
SinkProcessors.writeRemoteMapP
(String mapName, ClientConfig clientConfig) Returns a supplier of processors forSinks.remoteMap(String, ClientConfig)
.static <T,
K, V> ProcessorMetaSupplier SinkProcessors.writeRemoteMapP
(String mapName, ClientConfig clientConfig, FunctionEx<? super T, ? extends K> toKeyFn, FunctionEx<? super T, ? extends V> toValueFn) Returns a supplier of processors forSinks.remoteMap(String, ClientConfig, FunctionEx, FunctionEx)
. -
Uses of ClientConfig in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionMapSinkBuilder.clientConfig
(ClientConfig clientConfig) Sets theClientConfig
with configuration for a Hazelcast client to use for remote Map sink.MapSinkEntryProcessorBuilder.clientConfig
(ClientConfig clientConfig) RemoteMapSourceBuilder.clientConfig
(ClientConfig clientConfig) Set the client configuration to use to connect to the remote cluster.Sinks.remoteCache
(String cacheName, ClientConfig clientConfig) Returns a sink that putsMap.Entry
s it receives into a HazelcastICache
with the specified name in a remote cluster identified by the suppliedClientConfig
.static <K,
V> BatchSource<Map.Entry<K, V>> Sources.remoteCache
(String cacheName, ClientConfig clientConfig) Returns a source that fetches entries from the HazelcastICache
with the specified name in a remote cluster identified by the suppliedClientConfig
and emits them asMap.Entry
.static <K,
V> StreamSource<Map.Entry<K, V>> Sources.remoteCacheJournal
(String cacheName, ClientConfig clientConfig, JournalInitialPosition initialPos) Convenience forSources.remoteCacheJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx)
which will pass onlyCREATED
andUPDATED
events and will project the event's key and new value into aMap.Entry
.static <T,
K, V> StreamSource<T> Sources.remoteCacheJournal
(String cacheName, ClientConfig clientConfig, JournalInitialPosition initialPos, FunctionEx<? super EventJournalCacheEvent<K, V>, ? extends T> projectionFn, PredicateEx<? super EventJournalCacheEvent<K, V>> predicateFn) Returns a source that will stream theEventJournalCacheEvent
events of the HazelcastICache
with the specified name from a remote cluster.static <T> Sink<T>
Sinks.remoteList
(String listName, ClientConfig clientConfig) Returns a sink that adds the items it receives to a HazelcastIList
with the specified name in a remote cluster identified by the suppliedClientConfig
.static <T> BatchSource<T>
Sources.remoteList
(String listName, ClientConfig clientConfig) Returns a source that emits items retrieved from a HazelcastIList
in a remote cluster identified by the suppliedClientConfig
.Sinks.remoteMap
(String mapName, ClientConfig clientConfig) Returns a sink that putsMap.Entry
s it receives into a HazelcastIMap
with the specified name in a remote cluster identified by the suppliedClientConfig
.static <T,
K, V> Sink<T> Sinks.remoteMap
(String mapName, ClientConfig clientConfig, FunctionEx<? super T, ? extends K> toKeyFn, FunctionEx<? super T, ? extends V> toValueFn) Returns a sink that uses the supplied functions to extract the key and value with which to put to a HazelcastIMap
in a remote cluster identified by the suppliedClientConfig
.static <K,
V> BatchSource<Map.Entry<K, V>> Sources.remoteMap
(String mapName, ClientConfig clientConfig) Returns a source that fetches entries from the HazelcastIMap
with the specified name in a remote cluster identified by the suppliedClientConfig
and emits them asMap.Entry
.static <T,
K, V> BatchSource<T> Sources.remoteMap
(String mapName, ClientConfig clientConfig, Predicate<K, V> predicate, Projection<? super Map.Entry<K, V>, ? extends T> projection) Returns a source that fetches entries from a remote HazelcastIMap
with the specified name in a remote cluster identified by the suppliedClientConfig
.static <K,
V> StreamSource<Map.Entry<K, V>> Sources.remoteMapJournal
(String mapName, ClientConfig clientConfig, JournalInitialPosition initialPos) Convenience forSources.remoteMapJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx)
which will pass onlyADDED
andUPDATED
events and will project the event's key and new value into aMap.Entry
.static <T,
K, V> StreamSource<T> Sources.remoteMapJournal
(String mapName, ClientConfig clientConfig, JournalInitialPosition initialPos, FunctionEx<? super EventJournalMapEvent<K, V>, ? extends T> projectionFn, PredicateEx<? super EventJournalMapEvent<K, V>> predicateFn) Returns a source that will stream theEventJournalMapEvent
events of the HazelcastIMap
with the specified name from a remote cluster.static <E,
K, V, R> Sink<E> Sinks.remoteMapWithEntryProcessor
(String mapName, ClientConfig clientConfig, FunctionEx<? super E, ? extends K> toKeyFn, FunctionEx<? super E, ? extends EntryProcessor<K, V, R>> toEntryProcessorFn) Returns a sink equivalent toSinks.mapWithEntryProcessor(java.lang.String, com.hazelcast.function.FunctionEx<? super E, ? extends K>, com.hazelcast.function.FunctionEx<? super E, ? extends com.hazelcast.map.EntryProcessor<K, V, R>>)
, but for a map in a remote Hazelcast cluster identified by the suppliedClientConfig
.Sinks.remoteMapWithMerging
(String mapName, ClientConfig clientConfig, BinaryOperatorEx<V> mergeFn) Convenience forSinks.remoteMapWithMerging(java.lang.String, com.hazelcast.client.config.ClientConfig, com.hazelcast.function.BinaryOperatorEx<V>)
withMap.Entry
as input item.static <T,
K, V> Sink<T> Sinks.remoteMapWithMerging
(String mapName, ClientConfig clientConfig, FunctionEx<? super T, ? extends K> toKeyFn, FunctionEx<? super T, ? extends V> toValueFn, BinaryOperatorEx<V> mergeFn) Returns a sink equivalent toSinks.mapWithMerging(String, BinaryOperatorEx)
, but for a map in a remote Hazelcast cluster identified by the suppliedClientConfig
.Sinks.remoteMapWithUpdating
(String mapName, ClientConfig clientConfig, BiFunctionEx<? super V, ? super E, ? extends V> updateFn) static <T,
K, V> Sink<T> Sinks.remoteMapWithUpdating
(String mapName, ClientConfig clientConfig, FunctionEx<? super T, ? extends K> toKeyFn, BiFunctionEx<? super V, ? super T, ? extends V> updateFn) Returns a sink equivalent toSinks.mapWithUpdating(java.lang.String, com.hazelcast.function.FunctionEx<? super T, ? extends K>, com.hazelcast.function.BiFunctionEx<? super V, ? super T, ? extends V>)
, but for a map in a remote Hazelcast cluster identified by the suppliedClientConfig
.static <T> Sink<T>
Sinks.remoteReliableTopic
(String reliableTopicName, ClientConfig clientConfig) Returns a sink which publishes the items it receives to a distributed reliable topic with the provided name in a remote cluster identified by the suppliedClientConfig
. -
Uses of ClientConfig in com.hazelcast.spring.config
HazelcastClient.newHazelcastClient(ClientConfig)
and then getJetService
from the createdHazelcastInstance
client by usingHazelcastInstance.getJet()
}.