Package | Description |
---|---|
com.hazelcast.client |
This package contains the serverside client functionality
|
com.hazelcast.client.config |
Contains classes related to config for com.hazelcast.client
|
com.hazelcast.client.spi |
Contains classes/interfaces related to the Hazelcast client Service Provider Interface.
|
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.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.
|
Modifier and Type | Interface and Description |
---|---|
interface |
HazelcastClientFactory<T extends com.hazelcast.client.impl.HazelcastClientInstanceImpl,V extends com.hazelcast.client.impl.HazelcastClientProxy,C extends ClientConfig>
Provides the capability for the customization of Hazelcast client factories.
|
Modifier and Type | Method and Description |
---|---|
void |
LoadBalancer.init(Cluster cluster,
ClientConfig config)
Initializes the LoadBalancer.
|
static HazelcastInstance |
HazelcastClient.newHazelcastClient(ClientConfig config) |
static HazelcastInstance |
HazelcastClientManager.newHazelcastClient(ClientConfig config,
HazelcastClientFactory hazelcastClientFactory) |
Modifier and Type | Class and Description |
---|---|
class |
ClientClasspathXmlConfig
A
ClientConfig which is initialized by loading an XML configuration file from the classpath. |
Modifier and Type | Method and Description |
---|---|
ClientConfig |
ClientConfig.addAddress(String... addresses)
Deprecated.
|
ClientConfig |
ClientConfig.addFlakeIdGeneratorConfig(ClientFlakeIdGeneratorConfig config)
Adds a flake ID generator configuration.
|
ClientConfig |
ClientConfig.addListenerConfig(ListenerConfig listenerConfig)
Helper method to add a new ListenerConfig
|
ClientConfig |
ClientConfig.addNearCacheConfig(NearCacheConfig nearCacheConfig)
Helper method to add a new NearCacheConfig
|
ClientConfig |
ClientConfig.addNearCacheConfig(String name,
NearCacheConfig nearCacheConfig)
Deprecated.
|
ClientConfig |
ClientConfig.addProxyFactoryConfig(ProxyFactoryConfig proxyFactoryConfig)
Helper method to add a new
ProxyFactoryConfig |
ClientConfig |
ClientConfig.addQueryCacheConfig(String mapName,
QueryCacheConfig queryCacheConfig) |
ClientConfig |
ClientConfig.addReliableTopicConfig(ClientReliableTopicConfig reliableTopicConfig)
Adds a ClientReliableTopicConfig.
|
ClientConfig |
XmlClientConfigBuilder.build() |
ClientConfig |
XmlClientConfigBuilder.build(ClassLoader classLoader) |
ClientConfig |
ClientConfig.setAddresses(List<String> addresses)
Deprecated.
|
ClientConfig |
ClientConfig.setClassLoader(ClassLoader classLoader)
Sets the classLoader which is used by serialization and listener configuration
|
ClientConfig |
ClientConfig.setConnectionAttemptLimit(int connectionAttemptLimit)
Deprecated.
|
ClientConfig |
ClientConfig.setConnectionAttemptPeriod(int connectionAttemptPeriod)
Deprecated.
|
ClientConfig |
ClientConfig.setConnectionStrategyConfig(ClientConnectionStrategyConfig connectionStrategyConfig) |
ClientConfig |
ClientConfig.setConnectionTimeout(int connectionTimeout)
Deprecated.
|
ClientConfig |
ClientConfig.setCredentials(Credentials credentials)
Sets
Credentials |
ClientConfig |
ClientConfig.setExecutorPoolSize(int executorPoolSize)
Sets Client side Executor pool size.
|
ClientConfig |
ClientConfig.setFlakeIdGeneratorConfigMap(Map<String,ClientFlakeIdGeneratorConfig> map)
Sets the map of
FlakeIdGenerator configurations,
mapped by config name. |
ClientConfig |
ClientConfig.setGroupConfig(GroupConfig groupConfig)
Sets
GroupConfig |
ClientConfig |
ClientConfig.setLicenseKey(String licenseKey) |
ClientConfig |
ClientConfig.setListenerConfigs(List<ListenerConfig> listenerConfigs)
Sets all
ListenerConfig 's |
ClientConfig |
ClientConfig.setLoadBalancer(LoadBalancer loadBalancer)
Sets the
LoadBalancer |
ClientConfig |
ClientConfig.setManagedContext(ManagedContext managedContext)
Sets
ManagedContext |
ClientConfig |
ClientConfig.setNativeMemoryConfig(NativeMemoryConfig nativeMemoryConfig) |
ClientConfig |
ClientConfig.setNearCacheConfigMap(Map<String,NearCacheConfig> nearCacheConfigMap)
Sets all
NearCacheConfig 's with the provided map |
ClientConfig |
ClientConfig.setNetworkConfig(ClientNetworkConfig networkConfig)
Sets
ClientNetworkConfig |
ClientConfig |
ClientConfig.setProperties(Properties properties)
sets all properties
|
ClientConfig |
ClientConfig.setProperty(String name,
String value)
Sets the value of a named property.
|
ClientConfig |
ClientConfig.setProxyFactoryConfigs(List<ProxyFactoryConfig> proxyFactoryConfigs)
Sets the
ProxyFactoryConfig |
ClientConfig |
ClientConfig.setRedoOperation(boolean redoOperation)
Deprecated.
|
ClientConfig |
ClientConfig.setSecurityConfig(ClientSecurityConfig securityConfig)
Sets
ClientSecurityConfig object |
ClientConfig |
ClientConfig.setSerializationConfig(SerializationConfig serializationConfig)
Sets
SerializationConfig |
ClientConfig |
ClientConfig.setSmartRouting(boolean smartRouting)
Deprecated.
|
ClientConfig |
ClientConfig.setSocketInterceptorConfig(SocketInterceptorConfig socketInterceptorConfig)
Deprecated.
|
ClientConfig |
ClientConfig.setSocketOptions(SocketOptions socketOptions)
Deprecated.
|
ClientConfig |
ClientConfig.setUserCodeDeploymentConfig(ClientUserCodeDeploymentConfig userCodeDeploymentConfig)
Set User Code Deployment configuration
|
Modifier and Type | Method and Description |
---|---|
ClientConfig |
ClientContext.getClientConfig() |
Modifier and Type | Method and Description |
---|---|
void |
ProxyManager.init(ClientConfig config,
ClientContext clientContext) |
Modifier and Type | Method and Description |
---|---|
void |
StaticLB.init(Cluster cluster,
ClientConfig config) |
void |
AbstractLoadBalancer.init(Cluster cluster,
ClientConfig config) |
Constructor and Description |
---|
ClientStateListener(ClientConfig clientConfig)
Registers this instance with the provided client configuration
|
Modifier and Type | Method and Description |
---|---|
static JetInstance |
Jet.newJetClient(ClientConfig config)
Creates a Jet client with the given Hazelcast client configuration.
|
Modifier and Type | Method and Description |
---|---|
static <K,V> BatchSource<Map.Entry<K,V>> |
Sources.remoteCache(String cacheName,
ClientConfig clientConfig)
Returns a source that fetches entries from the Hazelcast
ICache
with the specified name in a remote cluster identified by the supplied
ClientConfig and emits them as Map.Entry . |
static <T extends Map.Entry> |
Sinks.remoteCache(String cacheName,
ClientConfig clientConfig)
Returns a sink that puts
Map.Entry s it receives into a Hazelcast
ICache with the specified name in a remote cluster identified by
the supplied ClientConfig . |
static <T,K,V> StreamSource<T> |
Sources.remoteCacheJournal(String cacheName,
ClientConfig clientConfig,
DistributedPredicate<EventJournalCacheEvent<K,V>> predicateFn,
DistributedFunction<EventJournalCacheEvent<K,V>,T> projectionFn,
JournalInitialPosition initialPos)
Returns a source that will stream the
EventJournalCacheEvent
events of the Hazelcast ICache with the specified name from a
remote cluster. |
static <K,V> StreamSource<Map.Entry<K,V>> |
Sources.remoteCacheJournal(String cacheName,
ClientConfig clientConfig,
JournalInitialPosition initialPos)
Convenience for
Sources.remoteCacheJournal(String, ClientConfig,
DistributedPredicate, DistributedFunction, JournalInitialPosition)
which will pass only
CREATED
and UPDATED
events and will project the event's key and new value
into a Map.Entry . |
static <T> BatchSource<T> |
Sources.remoteList(String listName,
ClientConfig clientConfig)
Returns a source that emits items retrieved from a Hazelcast
IList in a remote cluster identified by the supplied ClientConfig . |
static <T> Sink<T> |
Sinks.remoteList(String listName,
ClientConfig clientConfig)
Returns a sink that adds the items it receives to a Hazelcast
IList with the specified name in a remote cluster identified by the
supplied ClientConfig . |
static <K,V> BatchSource<Map.Entry<K,V>> |
Sources.remoteMap(String mapName,
ClientConfig clientConfig)
Returns a source that fetches entries from the Hazelcast
IMap
with the specified name in a remote cluster identified by the supplied
ClientConfig and emits them as Map.Entry . |
static <T extends Map.Entry> |
Sinks.remoteMap(String mapName,
ClientConfig clientConfig)
Returns a sink that puts
Map.Entry s it receives into a Hazelcast
IMap with the specified name in a remote cluster identified by
the supplied ClientConfig . |
static <T,K,V> BatchSource<T> |
Sources.remoteMap(String mapName,
ClientConfig clientConfig,
Predicate<K,V> predicate,
DistributedFunction<Map.Entry<K,V>,T> projectionFn)
Convenience for
Sources.remoteMap(String, ClientConfig, Predicate, Projection)
which use a DistributedFunction as the projection function. |
static <T,K,V> BatchSource<T> |
Sources.remoteMap(String mapName,
ClientConfig clientConfig,
Predicate<K,V> predicate,
Projection<Map.Entry<K,V>,T> projection)
Returns a source that fetches entries from a remote Hazelcast
IMap with the specified name in a remote cluster identified by the
supplied ClientConfig . |
static <T,K,V> StreamSource<T> |
Sources.remoteMapJournal(String mapName,
ClientConfig clientConfig,
DistributedPredicate<EventJournalMapEvent<K,V>> predicateFn,
DistributedFunction<EventJournalMapEvent<K,V>,T> projectionFn,
JournalInitialPosition initialPos)
Returns a source that will stream the
EventJournalMapEvent
events of the Hazelcast IMap with the specified name from a
remote cluster. |
static <K,V> StreamSource<Map.Entry<K,V>> |
Sources.remoteMapJournal(String mapName,
ClientConfig clientConfig,
JournalInitialPosition initialPos)
Convenience for
Sources.remoteMapJournal(String, ClientConfig,
DistributedPredicate, DistributedFunction, JournalInitialPosition)
which will pass only ADDED
and UPDATED events and will
project the event's key and new value into a Map.Entry . |
static <E,K,V> Sink<E> |
Sinks.remoteMapWithEntryProcessor(String mapName,
ClientConfig clientConfig,
DistributedFunction<E,K> toKeyFn,
DistributedFunction<E,EntryProcessor<K,V>> toEntryProcessorFn)
Returns a sink equivalent to
Sinks.mapWithEntryProcessor(java.lang.String, com.hazelcast.jet.function.DistributedFunction<E, K>, com.hazelcast.jet.function.DistributedFunction<E, com.hazelcast.map.EntryProcessor<K, V>>) , but for a map
in a remote Hazelcast cluster identified by the supplied ClientConfig . |
static <E extends Map.Entry,V> |
Sinks.remoteMapWithMerging(String mapName,
ClientConfig clientConfig,
DistributedBinaryOperator<V> mergeFn)
|
static <E,K,V> Sink<E> |
Sinks.remoteMapWithMerging(String mapName,
ClientConfig clientConfig,
DistributedFunction<E,K> toKeyFn,
DistributedFunction<E,V> toValueFn,
DistributedBinaryOperator<V> mergeFn)
Returns a sink equivalent to
Sinks.mapWithMerging(java.lang.String, com.hazelcast.jet.function.DistributedFunction<E, K>, com.hazelcast.jet.function.DistributedFunction<E, V>, com.hazelcast.jet.function.DistributedBinaryOperator<V>) , but for a map
in a remote Hazelcast cluster identified by the supplied ClientConfig . |
static <E extends Map.Entry,V> |
Sinks.remoteMapWithUpdating(String mapName,
ClientConfig clientConfig,
DistributedBiFunction<V,E,V> updateFn)
|
static <E,K,V> Sink<E> |
Sinks.remoteMapWithUpdating(String mapName,
ClientConfig clientConfig,
DistributedFunction<E,K> toKeyFn,
DistributedBiFunction<V,E,V> updateFn)
Returns a sink equivalent to
Sinks.mapWithUpdating(java.lang.String, com.hazelcast.jet.function.DistributedFunction<E, K>, com.hazelcast.jet.function.DistributedBiFunction<V, E, V>) , but for a map
in a remote Hazelcast cluster identified by the supplied ClientConfig . |
Copyright © 2018 Hazelcast, Inc.. All rights reserved.