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.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.nio.serialization |
Contains interfaces/classes related to serialization,
such as serializer interfaces, input/output streams.
|
com.hazelcast.nio.serialization.compact |
Package contains API for Compact Serializer
|
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 |
CompactSerializationConfig
In 5.0, this feature is disabled by default and has to be enabled via configuration
|
class |
CompactSerializationConfigAccessor
An accessor for the package-private fields of the
CompactSerializationConfig . |
Modifier and Type | Method and Description |
---|---|
CompactSerializationConfig |
SerializationConfig.getCompactSerializationConfig() |
SerializationConfig |
SerializationConfig.setCompactSerializationConfig(CompactSerializationConfig compactSerializationConfig) |
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 | Method and Description |
---|---|
SqlService |
HazelcastInstance.getSql()
Returns a service to execute distributed SQL queries.
|
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 | Interface and Description |
---|---|
interface |
GenericRecord
|
interface |
GenericRecordBuilder
Interface for creating
GenericRecord instances. |
Modifier and Type | Method and Description |
---|---|
static GenericRecordBuilder |
GenericRecordBuilder.compact(String className) |
Modifier and Type | Interface and Description |
---|---|
interface |
CompactReader
Provides means of reading compact serialized fields from the binary data.
|
interface |
CompactSerializer<T>
Defines the contract of the serializers used for Compact
serialization.
|
interface |
CompactWriter
Provides means of writing compact serialized fields to the binary data.
|
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 © 2021 Hazelcast, Inc.. All rights reserved.