Uses of Class
com.hazelcast.client.config.ClientConfig
Package | Description |
---|---|
com.hazelcast.client |
Contains classes/interfaces related to Client
|
com.hazelcast.client.config |
Contains classes related to config for com.hazelcast.client
|
com.hazelcast.client.util |
This package contains some utility classes and the base implementations of the
loadbalancer implementations
|
com.hazelcast.jet |
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
|
com.hazelcast.jet.cdc |
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.
|
com.hazelcast.jet.config |
Jet's configuration data objects.
|
com.hazelcast.jet.core.processor |
Contains static utility classes with factories of Jet processors.
|
com.hazelcast.jet.pipeline |
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
|
com.hazelcast.jet.server |
Contains Java program entry points that will start a Jet server
instance, submit jobs to a Jet cluster, etc.
|
-
Uses of ClientConfig in com.hazelcast.client
Methods in com.hazelcast.client with parameters of type ClientConfig Modifier and Type Method Description static 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
Subclasses of ClientConfig in com.hazelcast.client.config Modifier and Type Class Description class
ClientClasspathXmlConfig
AClientConfig
which is initialized by loading an XML configuration file from the classpath.class
ClientClasspathYamlConfig
AClientConfig
which is initialized by loading an YAML configuration file from the classpath.Methods in com.hazelcast.client.config that return ClientConfig Modifier and Type Method Description ClientConfig
ClientConfig. addFlakeIdGeneratorConfig(ClientFlakeIdGeneratorConfig config)
Adds a flake ID generator configuration.ClientConfig
ClientConfig. addLabel(String label)
Adds a label for this clientClient
availableClientConfig
ClientConfig. addListenerConfig(ListenerConfig listenerConfig)
Helper method to add a new ListenerConfigClientConfig
ClientConfig. addNearCacheConfig(NearCacheConfig nearCacheConfig)
Helper method to add a new NearCacheConfigClientConfig
ClientConfig. addProxyFactoryConfig(ProxyFactoryConfig proxyFactoryConfig)
Helper method to add a newProxyFactoryConfig
ClientConfig
ClientConfig. addQueryCacheConfig(String mapName, QueryCacheConfig queryCacheConfig)
ClientConfig
ClientConfig. addReliableTopicConfig(ClientReliableTopicConfig reliableTopicConfig)
Adds a ClientReliableTopicConfig.ClientConfig
XmlClientConfigBuilder. build()
ClientConfig
XmlClientConfigBuilder. build(ClassLoader classLoader)
ClientConfig
YamlClientConfigBuilder. build()
ClientConfig
YamlClientConfigBuilder. build(ClassLoader classLoader)
static ClientConfig
ClientConfig. load()
Populates HazelcastClientConfig
object from an external configuration file.ClientConfig
ClientConfig. setBackupAckToClientEnabled(boolean backupAckToClientEnabled)
This feature reduces number of hops and increase performance for smart clients.ClientConfig
ClientConfig. setClassLoader(ClassLoader classLoader)
Sets the classLoader which is used by serialization and listener configurationClientConfig
ClientConfig. setClusterName(String clusterName)
ClientConfig
ClientConfig. setConfigPatternMatcher(ConfigPatternMatcher configPatternMatcher)
Sets the pattern matcher which is used to match item names to configuration objects.ClientConfig
ClientConfig. setConnectionStrategyConfig(ClientConnectionStrategyConfig connectionStrategyConfig)
ClientConfig
ClientConfig. setCredentials(Credentials credentials)
Shortcut forgetSecurityConfig().setCredentials()
ClientConfig
ClientConfig. setFlakeIdGeneratorConfigMap(Map<String,ClientFlakeIdGeneratorConfig> map)
Sets the map ofFlakeIdGenerator
configurations, mapped by config name.ClientConfig
ClientConfig. setInstanceName(String instanceName)
ClientConfig
ClientConfig. setLabels(Set<String> labels)
Set labels for the client.ClientConfig
ClientConfig. setListenerConfigs(List<ListenerConfig> listenerConfigs)
Sets allListenerConfig
'sClientConfig
ClientConfig. setLoadBalancer(LoadBalancer loadBalancer)
Sets theLoadBalancer
.ClientConfig
ClientConfig. setLoadBalancerClassName(String loadBalancerClassName)
Sets load balancer class name.ClientConfig
ClientConfig. setManagedContext(ManagedContext managedContext)
SetsManagedContext
ClientConfig
ClientConfig. setMetricsConfig(ClientMetricsConfig metricsConfig)
Sets the metrics collection config.ClientConfig
ClientConfig. setNativeMemoryConfig(NativeMemoryConfig nativeMemoryConfig)
ClientConfig
ClientConfig. setNearCacheConfigMap(Map<String,NearCacheConfig> nearCacheConfigMap)
Sets allNearCacheConfig
's with the provided mapClientConfig
ClientConfig. setNetworkConfig(ClientNetworkConfig networkConfig)
SetsClientNetworkConfig
ClientConfig
ClientConfig. setProperties(Properties properties)
sets all propertiesClientConfig
ClientConfig. setProperty(String name, String value)
Sets the value of a named property.ClientConfig
ClientConfig. setProxyFactoryConfigs(List<ProxyFactoryConfig> proxyFactoryConfigs)
Sets theProxyFactoryConfig
ClientConfig
ClientConfig. setQueryCacheConfigs(Map<String,Map<String,QueryCacheConfig>> queryCacheConfigs)
ClientConfig
ClientConfig. setReliableTopicConfigMap(Map<String,ClientReliableTopicConfig> map)
Sets the map ofClientReliableTopicConfig
, mapped by config name.ClientConfig
ClientConfig. setSecurityConfig(ClientSecurityConfig securityConfig)
SetsClientSecurityConfig
objectClientConfig
ClientConfig. setSerializationConfig(SerializationConfig serializationConfig)
SetsSerializationConfig
ClientConfig
ClientConfig. setUserCodeDeploymentConfig(ClientUserCodeDeploymentConfig userCodeDeploymentConfig)
Set User Code Deployment configurationClientConfig
ClientConfig. setUserContext(ConcurrentMap<String,Object> userContext)
Methods in com.hazelcast.client.config that return types with arguments of type ClientConfig Modifier and Type Method Description List<ClientConfig>
ClientFailoverConfig. getClientConfigs()
Methods in com.hazelcast.client.config with parameters of type ClientConfig Modifier and Type Method Description ClientFailoverConfig
ClientFailoverConfig. addClientConfig(ClientConfig clientConfig)
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.Method parameters in com.hazelcast.client.config with type arguments of type ClientConfig Modifier and Type Method Description ClientFailoverConfig
ClientFailoverConfig. setClientConfigs(List<ClientConfig> clientConfigs)
Constructors in com.hazelcast.client.config with parameters of type ClientConfig Constructor Description ClientConfig(ClientConfig config)
-
Uses of ClientConfig in com.hazelcast.client.util
Methods in com.hazelcast.client.util with parameters of type ClientConfig Modifier and Type Method Description void
AbstractLoadBalancer. init(Cluster cluster, ClientConfig config)
void
StaticLB. init(Cluster cluster, ClientConfig config)
Constructors in com.hazelcast.client.util with parameters of type ClientConfig Constructor Description ClientStateListener(ClientConfig clientConfig)
Registers this instance with the provided client configuration -
Uses of ClientConfig in com.hazelcast.jet
Methods in com.hazelcast.jet with parameters of type ClientConfig Modifier and Type Method Description static JetInstance
Jet. newJetClient(ClientConfig config)
Creates a Jet client with the given Hazelcast client configuration. -
Uses of ClientConfig in com.hazelcast.jet.cdc
Methods in com.hazelcast.jet.cdc with parameters of type ClientConfig Modifier and Type Method Description static <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.config
Subclasses of ClientConfig in com.hazelcast.jet.config Modifier and Type Class Description class
JetClientConfig
A config object which is used for configuring the Jet client to connect to the Jet cluster. -
Uses of ClientConfig in com.hazelcast.jet.core.processor
Methods in com.hazelcast.jet.core.processor with parameters of type ClientConfig Modifier and Type Method Description static <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 ProcessorSupplier
SourceProcessors. readRemoteMapP(String mapName, ClientConfig clientConfig)
Returns a supplier of processors forSources.remoteMap(String, ClientConfig)
.static <T, K, V> ProcessorSupplier
SourceProcessors. readRemoteMapP(String mapName, ClientConfig clientConfig, Predicate<K,V> predicate, Projection<? super Map.Entry<K,V>,? extends T> projection)
Returns a supplier of processors forSources.remoteMap(String, ClientConfig, Predicate, Projection)
.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
Methods in com.hazelcast.jet.pipeline with parameters of type ClientConfig Modifier and Type Method Description static <T extends Map.Entry>
Sink<T>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
.static <K, V> Sink<Map.Entry<K,V>>
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
.static <K, V> Sink<Map.Entry<K,V>>
Sinks. remoteMapWithMerging(String mapName, ClientConfig clientConfig, BinaryOperatorEx<V> mergeFn)
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
.static <K, V, E extends Map.Entry<K, V>>
Sink<E>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.jet.server
Constructor parameters in com.hazelcast.jet.server with type arguments of type ClientConfig Constructor Description JetCommandLine(Function<ClientConfig,JetInstance> jetClientFn, PrintStream out, PrintStream err)