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.Entry s 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.