| Package | Description | 
|---|---|
| com.hazelcast.config | 
 Provides classes for configuring HazelcastInstance. 
 | 
| com.hazelcast.connector | 
 Hazelcast 3 connector provides sources, sinks and enrichment using data
 in Hazelcast 3 remote cluster 
 | 
| com.hazelcast.core | 
 Provides core API interfaces/classes. 
 | 
| com.hazelcast.datastore | 
 This package contains code handling external data stores. 
 | 
| com.hazelcast.jet | 
 Hazelcast Jet is a distributed computation engine running on top of
 Hazelcast IMDG technology. 
 | 
| 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.spi.properties | 
 Contains the Hazelcast properties implementation. 
 | 
| com.hazelcast.spi.tenantcontrol | 
 Classes for tenant control 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
AdvancedNetworkConfig
Similar to  
NetworkConfig with the additional ability to define multiple
 endpoints, each with its own separate protocol/security and/or socket properties. | 
class  | 
ExternalDataStoreConfig
Contains configuration of an external data store that can be used as a
 
  
BatchSource and Sink in Jet JDBC connector.
 Datastore for MapStore and MapLoader 
  | 
| Modifier and Type | Method and Description | 
|---|---|
Config | 
Config.addExternalDataStoreConfig(ExternalDataStoreConfig externalDataStoreConfig)
Adds an external data store configuration. 
 | 
ExternalDataStoreConfig | 
Config.findExternalDataStoreConfig(String name)
Returns a read-only  
ExternalDataStoreConfig
 configuration for the given name. | 
ExternalDataStoreConfig | 
Config.getExternalDataStoreConfig(String name)
Returns the external data store configuration for the given name, creating one
 if necessary and adding it to the collection of known configurations. 
 | 
Map<String,ExternalDataStoreConfig> | 
Config.getExternalDataStoreConfigs()
Returns the map of external data store configurations, mapped by config name. 
 | 
Config | 
Config.setExternalDataStoreConfigs(Map<String,ExternalDataStoreConfig> externalDataStoreConfigs)
Sets the map of external data store configurations, mapped by config name. 
 | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
Hz3Enrichment
Provides a way to perform enrichment using a Map or ReplicatedMap from
 Hazelcast 3 cluster. 
 | 
class  | 
Hz3Sinks
Provides sinks to write to Hazelcast 3 cluster. 
 | 
class  | 
Hz3Sources
Provides sources to read from Hazelcast 3 cluster. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static <K,V> ServiceFactory<Hz3MapAdapter,AsyncMap<K,V>> | 
Hz3Enrichment.hz3MapServiceFactory(String mapName,
                    String clientXML)
Create a service factory for enrichment using Hazelcast 3 remote map. 
 | 
static <K,V> ServiceFactory<Hz3MapAdapter,Map<K,V>> | 
Hz3Enrichment.hz3ReplicatedMapServiceFactory(String mapName,
                              String clientXML)
Create a service factory for enrichment using Hazelcast 3 remote replicated map. 
 | 
static <K,V,T,R> BiFunctionEx<? super Map<K,V>,? super T,R> | 
Hz3Enrichment.mapUsingIMap(FunctionEx<? super T,? extends K> lookupKeyFn,
            BiFunctionEx<? super T,? super V,? extends R> mapFn)
Helper function to convert simple lookupKeyFn and mapFn to mapAsyncFn required by
  
GeneralStage.mapUsingServiceAsync(ServiceFactory, BiFunctionEx) | 
static <K,V,T,R> BiFunctionEx<? super AsyncMap<K,V>,? super T,CompletableFuture<R>> | 
Hz3Enrichment.mapUsingIMapAsync(FunctionEx<? super T,? extends K> lookupKeyFn,
                 BiFunctionEx<? super T,? super V,? extends R> mapFn)
Helper function to convert simple lookupKeyFn and mapFn to mapAsyncFn required by
  
GeneralStage.mapUsingServiceAsync(ServiceFactory, BiFunctionEx) | 
static ProcessorSupplier | 
Hz3Sources.readRemoteMapP(String mapName,
              String clientXml)
Returns a supplier of processors for
  
Sources.remoteMap(String, ClientConfig). | 
static <T,K,V> Sink<T> | 
Hz3Sinks.remoteMap(String mapName,
         FunctionEx<? super T,? extends K> toKeyFn,
         FunctionEx<? super T,? extends V> toValueFn,
         String clientXml)
Returns a sink that uses the supplied functions to extract the key
 and value with which to put to a Hazelcast  
IMap with the
 specified name. | 
static <K,V> Sink<Map.Entry<K,V>> | 
Hz3Sinks.remoteMap(String mapName,
         String clientXml)
Returns a sink that puts  
Map.Entrys it receives into a Hazelcast
 IMap with the specified name. | 
static <K,V> BatchSource<Map.Entry<K,V>> | 
Hz3Sources.remoteMap(String mapName,
         String clientXml)
Returns a source that fetches entries from the Hazelcast  
IMap
 with the specified name in a remote cluster identified by the supplied
 XML configuration. | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
Pipelining<E>
The Pipelining can be used to speed up requests. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
ExternalDataStoreFactory<DS>
Creates external datastore. 
 | 
interface  | 
ExternalDataStoreService
Service for accessing external data store factories 
 | 
class  | 
JdbcDataStoreFactory
Creates a JDBC data store as a  
DataSource. | 
| Modifier and Type | Method and Description | 
|---|---|
SqlService | 
JetInstance.getSql()
Deprecated. 
 
since 5.0
 Use  
HazelcastInstance.getSql() instead. | 
| Modifier and Type | Method and Description | 
|---|---|
JobConfig | 
JobConfig.addCustomClasspath(String name,
                  String path)
Adds custom classpath element to a stage with the given name. 
 | 
JobConfig | 
JobConfig.addCustomClasspaths(String name,
                   List<String> paths)
Adds custom classpath elements to a stage with the given name. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static <T> ProcessorMetaSupplier | 
SinkProcessors.writeJdbcP(String updateQuery,
          ExternalDataStoreRef externalDataStoreRef,
          BiConsumerEx<? super PreparedStatement,? super T> bindFn,
          boolean exactlyOnce,
          int batchLimit)
Returns a supplier of processors for  
Sinks.jdbcBuilder(). | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
ExternalDataStoreRef
Represents a reference to the external datastore, used with
  
Sources.jdbc(ExternalDataStoreRef, ToResultSetFunction, FunctionEx). | 
| Modifier and Type | Method and Description | 
|---|---|
JdbcSinkBuilder<T> | 
JdbcSinkBuilder.externalDataStoreRef(ExternalDataStoreRef externalDataStoreRef)
Sets the reference to the configured external dataStore of  
ExternalDataStoreRef from which
 the instance of the DataSource will be retrieved. | 
static <T> BatchSource<T> | 
Sources.jdbc(ExternalDataStoreRef externalDataStoreRef,
    ToResultSetFunction resultSetFn,
    FunctionEx<? super ResultSet,? extends T> createOutputFn)
Returns a source which connects to the specified database using the given
  
externalDataStoreRef, queries the database and creates a result set
 using the given resultSetFn. | 
static <T> Sink<T> | 
Sinks.jdbc(String updateQuery,
    ExternalDataStoreRef externalDataStoreRef,
    BiConsumerEx<PreparedStatement,T> bindFn)
A shortcut for: 
 | 
| Modifier and Type | Field and Description | 
|---|---|
static HazelcastProperty | 
ClusterProperty.SQL_CUSTOM_TYPES_ENABLED
Enable experimental support for accessing nested fields by using custom
 types in SQL. 
 | 
| Modifier and Type | Interface and Description | 
|---|---|
interface  | 
DestroyEventContext
Hook to decouple Hazelcast object from the tenant 
 | 
interface  | 
Tenantable
Interface to be implemented by classes which can be queried for requirement
 of a tenant context. 
 | 
interface  | 
TenantControl
Hooks for multi-tenancy for application servers. 
 | 
interface  | 
TenantControlFactory
A  
TenantControlFactory supplies TenantControl objects when
 Hazelcast service attaches the tenant control to a distributed object. | 
Copyright © 2022 Hazelcast, Inc.. All rights reserved.