| Package | Description |
|---|---|
| com.hazelcast.client.config |
Contains classes related to config for com.hazelcast.client
|
| com.hazelcast.config |
Provides classes for configuring HazelcastInstance.
|
| com.hazelcast.config.tpc |
This package contains configuration classes for TPC.
|
| com.hazelcast.core |
Provides core API interfaces/classes.
|
| com.hazelcast.dataconnection |
This package contains code handling data connections.
|
| 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 |
Jet's Core API.
|
| 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
|
| Package | Description |
|---|---|
| com.hazelcast.dataconnection |
This package contains code handling data connections.
|
| Modifier and Type | Class and Description |
|---|---|
class |
ClientTpcConfig
Contains client configurations for TPC.
|
| Modifier and Type | Method and Description |
|---|---|
ClientTpcConfig |
ClientConfig.getTpcConfig()
Returns the ClientTpcConfig
|
ClientConfig |
ClientConfig.setTpcConfig(ClientTpcConfig tpcConfig)
Sets the TpcConfig
|
| 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 |
DataConnectionConfig
|
| Modifier and Type | Method and Description |
|---|---|
Config |
Config.addDataConnectionConfig(DataConnectionConfig dataConnectionConfig)
Adds a data connection configuration.
|
DataConnectionConfig |
Config.findDataConnectionConfig(String name)
Returns a read-only
DataConnectionConfig
configuration for the given name. |
DataConnectionConfig |
Config.getDataConnectionConfig(String name)
Returns the data connection configuration for the given name, creating one
if necessary and adding it to the collection of known configurations.
|
Map<String,DataConnectionConfig> |
Config.getDataConnectionConfigs()
Returns the map of data connection configurations, mapped by config name.
|
TpcConfig |
Config.getTpcConfig()
Gets the TpcConfig.
|
TpcSocketConfig |
EndpointConfig.getTpcSocketConfig()
Gets the TpcSocketConfig.
|
TpcSocketConfig |
NetworkConfig.getTpcSocketConfig()
Gets the TpcSocketConfig.
|
Config |
Config.setDataConnectionConfigs(Map<String,DataConnectionConfig> dataConnectionConfigs)
Sets the map of data connection configurations, mapped by config name.
|
Config |
Config.setTpcConfig(TpcConfig tpcConfig)
Sets the TpcConfig.
|
EndpointConfig |
EndpointConfig.setTpcSocketConfig(TpcSocketConfig tpcSocketConfig)
Sets the TpcSocketConfig.
|
NetworkConfig |
NetworkConfig.setTpcSocketConfig(TpcSocketConfig tpcSocketConfig)
Sets the TpcSocketConfig
|
RestServerEndpointConfig |
RestServerEndpointConfig.setTpcSocketConfig(TpcSocketConfig tpcSocketConfig) |
ServerSocketEndpointConfig |
ServerSocketEndpointConfig.setTpcSocketConfig(TpcSocketConfig tpcSocketConfig) |
| Modifier and Type | Class and Description |
|---|---|
class |
TpcConfig
Hazelcast TPC is the next generation of Hazelcast built with thread
per core architecture.
|
class |
TpcSocketConfig
Socket configuration for TPC.
|
| 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 |
DataConnection
DataConnection is a reference to a single external system.
|
class |
DataConnectionBase
Base class for
DataConnection implementations. |
interface |
DataConnectionRegistration
Registration for a
DataConnection. |
class |
DataConnectionResource
DataConnection Resource is an object for which a mapping can be created.
|
class |
HazelcastDataConnection
Creates a HazelcastInstance that is shared to connect to a remote cluster.
|
| 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 ProcessorMetaSupplier |
ProcessorMetaSupplier.randomMember(ProcessorSupplier supplier)
Wraps the provided
ProcessorSupplier into a meta-supplier that
will only use the given ProcessorSupplier on a random node |
| Modifier and Type | Method and Description |
|---|---|
static <T> ProcessorMetaSupplier |
SinkProcessors.writeJdbcP(String updateQuery,
DataConnectionRef dataConnectionRef,
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 |
DataConnectionRef
Represents a reference to the data connection, used with
Sources.jdbc(DataConnectionRef, ToResultSetFunction, FunctionEx). |
| Modifier and Type | Method and Description |
|---|---|
JdbcSinkBuilder<T> |
JdbcSinkBuilder.dataConnectionRef(DataConnectionRef dataConnectionRef)
Sets the reference to the configured data connection of
DataConnectionRef from which
the instance of the DataSource will be retrieved. |
static <T> BatchSource<T> |
Sources.jdbc(DataConnectionRef dataConnectionRef,
ToResultSetFunction resultSetFn,
FunctionEx<? super ResultSet,? extends T> createOutputFn)
Returns a source which connects to the specified database using the given
dataConnectionRef, queries the database and creates a result set
using the given resultSetFn. |
static <T> Sink<T> |
Sinks.jdbc(String updateQuery,
DataConnectionRef dataConnectionRef,
BiConsumerEx<PreparedStatement,T> bindFn)
A shortcut for:
|
static <K,V> StreamSource<Map.Entry<K,V>> |
Sources.remoteMapJournal(String mapName,
DataConnectionRef dataConnectionRef,
JournalInitialPosition initialPos)
Convenience for
Sources.remoteMapJournal(String, DataConnectionRef, JournalInitialPosition, FunctionEx, PredicateEx)
which will pass only ADDED
and UPDATED events and will
project the event's key and new value into a Map.Entry. |
static <T,K,V> StreamSource<T> |
Sources.remoteMapJournal(String mapName,
DataConnectionRef dataConnectionRef,
JournalInitialPosition initialPos,
FunctionEx<? super EventJournalMapEvent<K,V>,? extends T> projectionFn,
PredicateEx<? super EventJournalMapEvent<K,V>> predicateFn)
The same as the
Sources.remoteMapJournal(String, ClientConfig, JournalInitialPosition, FunctionEx, PredicateEx)
method. |
| 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 © 2024 Hazelcast, Inc.. All rights reserved.