Uses of Class
com.hazelcast.spi.annotation.Beta

Packages that use Beta

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.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.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.kafka	Apache Kafka reader/writer support for Hazelcast Jet.
com.hazelcast.jet.kafka.connect	Contains a generic Kafka Connect source provides ability to plug any Kafka Connect source for data ingestion to Jet pipelines.
com.hazelcast.jet.mongodb	Contains sources and sinks for MongoDB.
com.hazelcast.jet.mongodb.dataconnection	Contains classes related to Mongo DB Data Connection.
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

Packages with annotations of type Beta

Package	Description
com.hazelcast.dataconnection	This package contains code handling data connections.

Uses of Beta in com.hazelcast.client.config

Classes in com.hazelcast.client.config with annotations of type Beta

Modifier and Type	Class and Description
class	ClientTpcConfig Contains client configurations for TPC.

Methods in com.hazelcast.client.config with annotations of type Beta

Modifier and Type	Method and Description
ClientTpcConfig	ClientConfig.getTpcConfig() Returns the ClientTpcConfig
ClientConfig	ClientConfig.setTpcConfig(ClientTpcConfig tpcConfig) Sets the TpcConfig

Uses of Beta in com.hazelcast.config

Classes in com.hazelcast.config with annotations of type Beta

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 A configuration of a data connection that can be used: to create a source or sink in a Jet Pipeline, as a data connection for MapStore and MapLoader, to create an SQL mapping.

Methods in com.hazelcast.config with annotations of type Beta

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	NetworkConfig.getTpcSocketConfig() Gets the TpcSocketConfig.
TpcSocketConfig	EndpointConfig.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.
NetworkConfig	NetworkConfig.setTpcSocketConfig(TpcSocketConfig tpcSocketConfig) Sets the TpcSocketConfig
ServerSocketEndpointConfig	ServerSocketEndpointConfig.setTpcSocketConfig(TpcSocketConfig tpcSocketConfig)
RestServerEndpointConfig	RestServerEndpointConfig.setTpcSocketConfig(TpcSocketConfig tpcSocketConfig)
EndpointConfig	EndpointConfig.setTpcSocketConfig(TpcSocketConfig tpcSocketConfig) Sets the TpcSocketConfig.

Uses of Beta in com.hazelcast.config.tpc

Classes in com.hazelcast.config.tpc with annotations of type Beta

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.

Uses of Beta in com.hazelcast.connector

Classes in com.hazelcast.connector with annotations of type Beta

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.

Methods in com.hazelcast.connector with annotations of type Beta

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.

Uses of Beta in com.hazelcast.core

Classes in com.hazelcast.core with annotations of type Beta

Modifier and Type	Class and Description
class	Pipelining<E> The Pipelining can be used to speed up requests.

Uses of Beta in com.hazelcast.dataconnection

Classes in com.hazelcast.dataconnection with annotations of type Beta

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.

Uses of Beta in com.hazelcast.jet

Methods in com.hazelcast.jet with annotations of type Beta

Modifier and Type	Method and Description
SqlService	JetInstance.getSql() Deprecated. since 5.0 Use HazelcastInstance.getSql() instead.

Uses of Beta in com.hazelcast.jet.config

Methods in com.hazelcast.jet.config with annotations of type Beta

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.

Uses of Beta in com.hazelcast.jet.core

Methods in com.hazelcast.jet.core with annotations of type Beta

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

Uses of Beta in com.hazelcast.jet.core.processor

Methods in com.hazelcast.jet.core.processor with annotations of type Beta

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().

Uses of Beta in com.hazelcast.jet.kafka

Classes in com.hazelcast.jet.kafka with annotations of type Beta

Modifier and Type	Class and Description
class	KafkaDataConnection DataConnection implementation for Kafka.

Methods in com.hazelcast.jet.kafka with annotations of type Beta

Modifier and Type	Method and Description
static <E> KafkaSinks.Builder<E>	KafkaSinks.kafka(DataConnectionRef dataConnectionRef) Returns a builder object that you can use to create an Apache Kafka pipeline sink.
static <E,K,V> Sink<E>	KafkaSinks.kafka(DataConnectionRef dataConnectionRef, FunctionEx<? super E,org.apache.kafka.clients.producer.ProducerRecord<K,V>> toRecordFn) Returns a sink that publishes messages to Apache Kafka topic(s).
static <K,V,T> StreamSource<T>	KafkaSources.kafka(DataConnectionRef dataConnectionRef, FunctionEx<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,T> projectionFn, String... topics) Returns a source that consumes one or more Apache Kafka topics and emits items from them as Map.Entry instances.
static <E,K,V> Sink<E>	KafkaSinks.kafka(DataConnectionRef dataConnectionRef, Properties properties, String topic, FunctionEx<? super E,K> extractKeyFn, FunctionEx<? super E,V> extractValueFn) Convenience for KafkaSinks.kafka(Properties, FunctionEx) which creates a ProducerRecord using the given topic and the given key and value mapping functions with additional properties available
static <K,V> StreamSource<Map.Entry<K,V>>	KafkaSources.kafka(DataConnectionRef dataConnectionRef, String... topics) Convenience for KafkaSources.kafka(DataConnectionRef, FunctionEx, String...) wrapping the output in Map.Entry.
static <K,V> Sink<Map.Entry<K,V>>	KafkaSinks.kafka(DataConnectionRef dataConnectionRef, String topic) Convenience for KafkaSinks.kafka(DataConnectionRef, String, FunctionEx, FunctionEx) which expects Map.Entry<K, V> as input and extracts its key and value parts to be published to Kafka.
static <E,K,V> Sink<E>	KafkaSinks.kafka(DataConnectionRef dataConnectionRef, String topic, FunctionEx<? super E,K> extractKeyFn, FunctionEx<? super E,V> extractValueFn) Convenience for KafkaSinks.kafka(Properties, FunctionEx) which creates a ProducerRecord using the given topic and the given key and value mapping functions

Uses of Beta in com.hazelcast.jet.kafka.connect

Classes in com.hazelcast.jet.kafka.connect with annotations of type Beta

Modifier and Type	Class and Description
class	KafkaConnectSources Contains factory methods to create a Kafka Connect source.

Methods in com.hazelcast.jet.kafka.connect with annotations of type Beta

Modifier and Type	Method and Description
static StreamSource<org.apache.kafka.connect.source.SourceRecord>	KafkaConnectSources.connect(Properties properties) A generic Kafka Connect source provides ability to plug any Kafka Connect source for data ingestion to Jet pipelines.
static <T> StreamSource<T>	KafkaConnectSources.connect(Properties properties, FunctionEx<org.apache.kafka.connect.source.SourceRecord,T> projectionFn) A generic Kafka Connect source provides ability to plug any Kafka Connect source for data ingestion to Jet pipelines.

Uses of Beta in com.hazelcast.jet.mongodb

Classes in com.hazelcast.jet.mongodb with annotations of type Beta

Modifier and Type	Class and Description
class	MongoSinkBuilder<T> See MongoSinks.builder(java.lang.Class<T>, com.hazelcast.function.SupplierEx<com.mongodb.client.MongoClient>)
class	MongoSinks Contains factory methods for MongoDB sinks.
class	MongoSourceBuilder Top-level class for MongoDB custom source builders.
class	WriteMode Defines allowed operations.

Methods in com.hazelcast.jet.mongodb with annotations of type Beta

Modifier and Type	Method and Description
static MongoSourceBuilder.Batch<org.bson.Document>	MongoSources.batch(DataConnectionRef dataConnectionRef) Creates as builder for new batch mongo source.
static BatchSource<org.bson.Document>	MongoSources.batch(DataConnectionRef dataConnectionRef, String database, String collection, org.bson.conversions.Bson filter, org.bson.conversions.Bson projection) Returns a MongoDB batch source which queries the collection using given filter and applies the given projection on the documents.
static BatchSource<org.bson.Document>	MongoSources.batch(String connectionString, String database, String collection, org.bson.conversions.Bson filter, org.bson.conversions.Bson projection) Returns a MongoDB batch source which queries the collection using given filter and applies the given projection on the documents.
static MongoSourceBuilder.Batch<org.bson.Document>	MongoSources.batch(SupplierEx<? extends com.mongodb.client.MongoClient> clientSupplier) Creates as builder for new batch mongo source.
static <T> MongoSinkBuilder<T>	MongoSinks.builder(Class<T> itemClass, DataConnectionRef dataConnectionRef) Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB Sink for the Pipeline API.
static <T> MongoSinkBuilder<T>	MongoSinks.builder(Class<T> itemClass, SupplierEx<com.mongodb.client.MongoClient> clientSupplier) Returns a builder object that offers a step-by-step fluent API to build a custom MongoDB Sink for the Pipeline API.
static Sink<org.bson.Document>	MongoSinks.mongodb(DataConnectionRef dataConnectionRef, String database, String collection) Convenience for MongoSinks.builder(java.lang.Class<T>, com.hazelcast.function.SupplierEx<com.mongodb.client.MongoClient>).
static Sink<org.bson.Document>	MongoSinks.mongodb(String connectionString, String database, String collection) Convenience for MongoSinks.builder(java.lang.Class<T>, com.hazelcast.function.SupplierEx<com.mongodb.client.MongoClient>).
static StreamSource<? extends org.bson.Document>	MongoSources.stream(String connectionString, String database, String collection, org.bson.Document filter, org.bson.Document projection) Returns a MongoDB stream source which watches the changes on the collection.
static MongoSourceBuilder.Stream<org.bson.Document>	MongoSources.stream(SupplierEx<? extends com.mongodb.client.MongoClient> clientSupplier) Creates as builder for new stream mongo source.

Uses of Beta in com.hazelcast.jet.mongodb.dataconnection

Classes in com.hazelcast.jet.mongodb.dataconnection with annotations of type Beta

Modifier and Type	Class and Description
class	MongoDataConnection Creates a MongoDB DataConnection.

Uses of Beta in com.hazelcast.jet.pipeline

Classes in com.hazelcast.jet.pipeline with annotations of type Beta

Modifier and Type	Class and Description
class	DataConnectionRef Represents a reference to the data connection, used with Sources.jdbc(DataConnectionRef, ToResultSetFunction, FunctionEx).

Methods in com.hazelcast.jet.pipeline with annotations of type Beta

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.

Uses of Beta in com.hazelcast.spi.properties

Fields in com.hazelcast.spi.properties with annotations of type Beta

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.

Uses of Beta in com.hazelcast.spi.tenantcontrol

Classes in com.hazelcast.spi.tenantcontrol with annotations of type Beta

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.