Uses of Annotation Interface
com.hazelcast.spi.annotation.Beta
Package
Description
Contains classes related to config for com.hazelcast.client
Provides classes for configuring HazelcastInstance.
This package contains the REST API configuration classes.
This package contains configuration classes for TPC.
Provides core API interfaces/classes.
Contains public APIs of CP Subsystem
Hazelcast Jet is a distributed computation engine running on top of
Hazelcast IMDG technology.
Jet's configuration data objects.
Jet's Core API.
Contains static utility classes with factories of Jet processors.
Apache Kafka reader/writer support for Hazelcast Jet.
The Pipeline API is Jet's high-level API to build and execute
distributed computation jobs.
Contains the Hazelcast properties implementation.
Classes for tenant control
-
Uses of Beta in com.hazelcast.client.config
Modifier and TypeClassDescriptionfinal class
Contains client configurations for TPC.Modifier and TypeMethodDescriptionClientConfig.getTpcConfig()
Returns the ClientTpcConfigClientConfig.setTpcConfig
(ClientTpcConfig tpcConfig) Sets the TpcConfig -
Uses of Beta in com.hazelcast.config
Modifier and TypeClassDescriptionclass
Similar toNetworkConfig
with the additional ability to define multiple endpoints, each with its own separate protocol/security and/or socket properties.class
Modifier and TypeMethodDescriptionConfig.addDataConnectionConfig
(DataConnectionConfig dataConnectionConfig) Adds a data connection configuration.Config.findDataConnectionConfig
(String name) Returns a read-onlyDataConnectionConfig
configuration for the given name.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.Config.getDataConnectionConfigs()
Returns the map of data connection configurations, mapped by config name.Config.getRestConfig()
Gets the configuration for the REST API server.Config.getTpcConfig()
Gets the TpcConfig.EndpointConfig.getTpcSocketConfig()
Gets the TpcSocketConfig.NetworkConfig.getTpcSocketConfig()
Gets the TpcSocketConfig.Config.setDataConnectionConfigs
(Map<String, DataConnectionConfig> dataConnectionConfigs) Sets the map of data connection configurations, mapped by config name.Config.setRestConfig
(RestConfig restConfig) Sets the configuration for the REST API server.Config.setTpcConfig
(TpcConfig tpcConfig) Sets the TpcConfig.EndpointConfig.setTpcSocketConfig
(TpcSocketConfig tpcSocketConfig) Sets the TpcSocketConfig.NetworkConfig.setTpcSocketConfig
(TpcSocketConfig tpcSocketConfig) Sets the TpcSocketConfigRestServerEndpointConfig.setTpcSocketConfig
(TpcSocketConfig tpcSocketConfig) ServerSocketEndpointConfig.setTpcSocketConfig
(TpcSocketConfig tpcSocketConfig) -
Uses of Beta in com.hazelcast.config.rest
Modifier and TypeClassDescriptionclass
This class allows controlling the Hazelcast REST API feature. -
Uses of Beta in com.hazelcast.config.tpc
Modifier and TypeClassDescriptionclass
Hazelcast TPC is the next generation of Hazelcast built with thread per core architecture.class
Socket configuration for TPC. -
Uses of Beta in com.hazelcast.core
Modifier and TypeClassDescriptionclass
Pipelining<E>
The Pipelining can be used to speed up requests. -
Uses of Beta in com.hazelcast.cp
Modifier and TypeMethodDescriptionCPSubsystem.getCPGroupIds()
Returns all active CP group ids.CPSubsystem.getObjectInfos
(CPGroupId groupId, String serviceName) Returns info about all objects of given type within the given groupCPSubsystem.getTombstoneInfos
(CPGroupId groupId, String serviceName) Returns info about all tombstones of given type within the given group -
Uses of Beta in com.hazelcast.jet
-
Uses of Beta in com.hazelcast.jet.config
Modifier and TypeMethodDescriptionJobConfig.addCustomClasspath
(String name, String path) Adds custom classpath element to a stage with the given name.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
Modifier and TypeMethodDescriptionstatic ProcessorMetaSupplier
ProcessorMetaSupplier.randomMember
(ProcessorSupplier supplier) Wraps the providedProcessorSupplier
into a meta-supplier that will only use the givenProcessorSupplier
on a random node -
Uses of Beta in com.hazelcast.jet.core.processor
Modifier and TypeMethodDescriptionstatic <T> ProcessorMetaSupplier
SinkProcessors.writeJdbcP
(String updateQuery, DataConnectionRef dataConnectionRef, BiConsumerEx<? super PreparedStatement, ? super T> bindFn, boolean exactlyOnce, int batchLimit) Returns a supplier of processors forSinks.jdbcBuilder()
. -
Uses of Beta in com.hazelcast.jet.kafka
Modifier and TypeMethodDescriptionstatic <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).KafkaSinks.kafka
(DataConnectionRef dataConnectionRef, String topic) Convenience forKafkaSinks.kafka(DataConnectionRef, String, FunctionEx, FunctionEx)
which expectsMap.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 forKafkaSinks.kafka(Properties, FunctionEx)
which creates aProducerRecord
using the given topic and the given key and value mapping functionsstatic <E,
K, V> Sink<E> KafkaSinks.kafka
(DataConnectionRef dataConnectionRef, Properties properties, String topic, FunctionEx<? super E, K> extractKeyFn, FunctionEx<? super E, V> extractValueFn) Convenience forKafkaSinks.kafka(Properties, FunctionEx)
which creates aProducerRecord
using the given topic and the given key and value mapping functions with additional properties availablestatic <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 asMap.Entry
instances.static <K,
V> StreamSource<Map.Entry<K, V>> KafkaSources.kafka
(DataConnectionRef dataConnectionRef, String... topics) Convenience forKafkaSources.kafka(DataConnectionRef, FunctionEx, String...)
wrapping the output inMap.Entry
. -
Uses of Beta in com.hazelcast.jet.pipeline
Modifier and TypeMethodDescriptionJdbcSinkBuilder.dataConnectionRef
(DataConnectionRef dataConnectionRef) Sets the reference to the configured data connection ofDataConnectionRef
from which the instance of theDataSource
will be retrieved.static <T> Sink<T>
Sinks.jdbc
(String updateQuery, DataConnectionRef dataConnectionRef, BiConsumerEx<PreparedStatement, T> bindFn) A shortcut for: -
Uses of Beta in com.hazelcast.spi.properties
Modifier and TypeFieldDescriptionstatic final HazelcastProperty
ClusterProperty.SQL_CUSTOM_CYCLIC_TYPES_ENABLED
Enable experimental support for accessing cyclic nested fields by using custom types in SQL.static final HazelcastProperty
ClusterProperty.SQL_TSTORE_ENABLED
Enable experimental support for querying Tiered Storage IMaps via SQL. -
Uses of Beta in com.hazelcast.spi.tenantcontrol
Modifier and TypeInterfaceDescriptioninterface
Hook to decouple Hazelcast object from the tenantinterface
Interface to be implemented by classes which can be queried for requirement of a tenant context.interface
Hooks for multi-tenancy for application servers.interface
ATenantControlFactory
suppliesTenantControl
objects when Hazelcast service attaches the tenant control to a distributed object.
HazelcastInstance.getSql()
instead.