Uses of Class
com.hazelcast.client.config.ClientConfig
Packages that use 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
Methods in com.hazelcast.client with parameters of type ClientConfigModifier and TypeMethodDescriptionstatic HazelcastInstanceHazelcastClient.getOrCreateHazelcastClient(ClientConfig config) Gets or creates a new HazelcastInstance (a new client in a cluster) with a certain name.voidLoadBalancer.init(Cluster cluster, ClientConfig config) Initializes the LoadBalancer.static HazelcastInstanceHazelcastClient.newHazelcastClient(ClientConfig config) Creates a new HazelcastInstance (a new client in a cluster). -
Uses of ClientConfig in com.hazelcast.client.config
Subclasses of ClientConfig in com.hazelcast.client.configModifier and TypeClassDescriptionclassAClientConfigwhich is initialized by loading an XML configuration file from the classpath.classAClientConfigwhich is initialized by loading an YAML configuration file from the classpath.Methods in com.hazelcast.client.config that return ClientConfigModifier and TypeMethodDescriptionClientConfig.addFlakeIdGeneratorConfig(ClientFlakeIdGeneratorConfig config) Adds a flake ID generator configuration.Adds a label for this clientClientavailableClientConfig.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 newProxyFactoryConfigClientConfig.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 ClientConfigClientConfig.load()Populates HazelcastClientConfigobject from an external configuration file.ClientConfig.setBackupAckToClientEnabled(boolean backupAckToClientEnabled) This feature reduces number of hops and increases performance forRoutingMode.ALL_MEMBERSrouting 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 ofFlakeIdGeneratorconfigurations, 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) SetsManagedContextClientConfig.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) SetsClientNetworkConfigClientConfig.setProperties(Properties properties) sets all propertiesClientConfig.setProperty(String name, String value) Sets the value of a named property.ClientConfig.setProxyFactoryConfigs(List<ProxyFactoryConfig> proxyFactoryConfigs) Sets theProxyFactoryConfigClientConfig.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) SetsClientSecurityConfigobjectClientConfig.setSerializationConfig(SerializationConfig serializationConfig) SetsSerializationConfigClientConfig.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) Methods in com.hazelcast.client.config that return types with arguments of type ClientConfigModifier and TypeMethodDescriptionClientFailoverConfig.getClientConfigs()Gets the configured list of alternative client configurations.Methods in com.hazelcast.client.config with parameters of type ClientConfigModifier and TypeMethodDescriptionClientFailoverConfig.addClientConfig(ClientConfig clientConfig) Adds the client config to the end of the alternative client configurations list.static StringClientConfigXmlGenerator.generate(ClientConfig clientConfig) Convenience forClientConfigXmlGenerator.generate(ClientConfig, int), which generates the xml without any formatting.static StringClientConfigXmlGenerator.generate(ClientConfig clientConfig, int indent) Transforms the givenClientConfigto xml string formatting the output with givenindent, -1 means no formatting.Method parameters in com.hazelcast.client.config with type arguments of type ClientConfigModifier and TypeMethodDescriptionClientFailoverConfig.setClientConfigs(List<ClientConfig> clientConfigs) Sets the configured list of alternative client configurations.Constructors in com.hazelcast.client.config with parameters of type ClientConfig -
Uses of ClientConfig in com.hazelcast.jet
Methods in com.hazelcast.jet with parameters of type ClientConfigModifier and TypeMethodDescriptionstatic JetInstanceJet.newJetClient(ClientConfig config) Deprecated. -
Uses of ClientConfig in com.hazelcast.jet.cdc
Methods in com.hazelcast.jet.cdc with parameters of type ClientConfigModifier 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
Methods in com.hazelcast.jet.core.processor with parameters of type ClientConfigModifier 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 ProcessorSupplierSourceProcessors.readRemoteCacheP(String cacheName, ClientConfig clientConfig) Returns a supplier of processors forSources.remoteCache(String, ClientConfig).static ProcessorMetaSupplierSourceProcessors.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 ProcessorMetaSupplierSinkProcessors.writeRemoteCacheP(String cacheName, ClientConfig clientConfig) Returns a supplier of processors forSinks.remoteCache(String, ClientConfig).static ProcessorMetaSupplierSinkProcessors.writeRemoteListP(String listName, ClientConfig clientConfig) Returns a supplier of processors forSinks.remoteList(String, ClientConfig).static ProcessorMetaSupplierSinkProcessors.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
Methods in com.hazelcast.jet.pipeline with parameters of type ClientConfigModifier and TypeMethodDescriptionMapSinkBuilder.clientConfig(ClientConfig clientConfig) Sets theClientConfigwith 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.Entrys it receives into a HazelcastICachewith 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 HazelcastICachewith the specified name in a remote cluster identified by the suppliedClientConfigand 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 onlyCREATEDandUPDATEDevents 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 theEventJournalCacheEventevents of the HazelcastICachewith 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 HazelcastIListwith 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 HazelcastIListin a remote cluster identified by the suppliedClientConfig.Sinks.remoteMap(String mapName, ClientConfig clientConfig) Returns a sink that putsMap.Entrys it receives into a HazelcastIMapwith 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 HazelcastIMapin 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 HazelcastIMapwith the specified name in a remote cluster identified by the suppliedClientConfigand 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 HazelcastIMapwith 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 onlyADDEDandUPDATEDevents 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 theEventJournalMapEventevents of the HazelcastIMapwith 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.Entryas 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
Methods in com.hazelcast.spring.config that return ClientConfig
HazelcastClient.newHazelcastClient(ClientConfig)and then getJetServicefrom the createdHazelcastInstanceclient by usingHazelcastInstance.getJet()}.