Index

A B C D E F G H I J K L M N O P R S T U V W X 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

abort() - Method in class com.hazelcast.security.ClusterLoginModule
 
addRole(String) - Method in class com.hazelcast.security.ClusterLoginModule
 
ALWAYS - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.DebeziumSnapshotMode
Always perform a snapshot when starting.

B

BasicLdapLoginModule - Class in com.hazelcast.security.loginimpl
JAAS login module which uses LDAP as a user population store.
BasicLdapLoginModule() - Constructor for class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
build() - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Returns the CDC source based on the properties set.
build() - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Returns the source based on the properties set so far.
build() - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Returns the source based on the properties set so far.
Builder(String, String, RecordMappingFunction<T>) - Constructor for class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
 

C

CacheWanEventFilter<K,V> - Interface in com.hazelcast.cache.wan
WAN event filtering interface for cache based WAN replication events.
callbackHandler - Variable in class com.hazelcast.security.ClusterLoginModule
 
CdcSinks - Class in com.hazelcast.enterprise.jet.cdc
Contains factory methods for change data capture specific pipeline sinks.
CertificatesCallback - Class in com.hazelcast.security
Callback for retrieving TLS certificates from the underlying connection.
CertificatesCallback() - Constructor for class com.hazelcast.security.CertificatesCallback
 
changeRecord() - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Sets the return type of the source to ChangeRecord.
changeRecord() - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Sets the return type of the source to ChangeRecord.
changeRecord() - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Sets the return type of the source to ChangeRecord.
ChangeRecord - Interface in com.hazelcast.enterprise.jet.cdc
Information pertaining to a single data change event (insert, delete or update), affecting a single database record.
clearAsync() - Method in interface com.hazelcast.vector.VectorCollection
Asynchronously clears all entries in the vector collection.
clone() - Method in class com.hazelcast.usercode.UserCodeConfig
 
ClusterEndpointPrincipal - Class in com.hazelcast.security
 
ClusterEndpointPrincipal() - Constructor for class com.hazelcast.security.ClusterEndpointPrincipal
 
ClusterEndpointPrincipal(String) - Constructor for class com.hazelcast.security.ClusterEndpointPrincipal
 
ClusterIdentityPrincipal - Class in com.hazelcast.security
 
ClusterIdentityPrincipal() - Constructor for class com.hazelcast.security.ClusterIdentityPrincipal
 
ClusterIdentityPrincipal(String) - Constructor for class com.hazelcast.security.ClusterIdentityPrincipal
 
ClusterLoginModule - Class in com.hazelcast.security
 
ClusterLoginModule() - Constructor for class com.hazelcast.security.ClusterLoginModule
 
ClusterNameCallback - Class in com.hazelcast.security
This Callback implementation is used to retrieve the cluster name of the authenticated party.
ClusterNameCallback() - Constructor for class com.hazelcast.security.ClusterNameCallback
 
ClusterRolePrincipal - Class in com.hazelcast.security
 
ClusterRolePrincipal() - Constructor for class com.hazelcast.security.ClusterRolePrincipal
 
ClusterRolePrincipal(String) - Constructor for class com.hazelcast.security.ClusterRolePrincipal
 
code() - Method in enum class com.hazelcast.enterprise.jet.cdc.Operation
Returns the Debezium operation code as String.
com.hazelcast.cache - package com.hazelcast.cache
This package contains Enterprise cache functionality.
com.hazelcast.cache.wan - package com.hazelcast.cache.wan
This package contains enterprise WAN replication functionality.
com.hazelcast.cp - package com.hazelcast.cp
Contains CP Subsystem implementation based on public API defined in OS repository
com.hazelcast.cp.event - package com.hazelcast.cp.event
Contains definitions of CP Subsystem events and listeners.
com.hazelcast.enterprise.jet.cdc - package com.hazelcast.enterprise.jet.cdc
Contains source/sink connectors that deal with Change Data Capture (CDC) events from various databases as well as a generic connector for Debezium CDC sources.
com.hazelcast.enterprise.jet.cdc.mysql - package com.hazelcast.enterprise.jet.cdc.mysql
MySQL-specific CDC API.
com.hazelcast.enterprise.jet.cdc.postgres - package com.hazelcast.enterprise.jet.cdc.postgres
PostgreSQL-specific CDC API.
com.hazelcast.enterprise.jet.pipeline - package com.hazelcast.enterprise.jet.pipeline
This package contains the enterprise jet pipeline implementations
com.hazelcast.enterprise.wan - package com.hazelcast.enterprise.wan
This package contains the enterprise WAN implementation
com.hazelcast.hotrestart - package com.hazelcast.hotrestart
Public API for the Hot Restart store.
com.hazelcast.map - package com.hazelcast.map
Contains Hazelcast map module related classes for the enterprise version.
com.hazelcast.map.wan - package com.hazelcast.map.wan
This package contains map specific enterprise WAN replication functionality.
com.hazelcast.pc - package com.hazelcast.pc
Contains Jet pipeline declarative configuration support.
com.hazelcast.pc.config - package com.hazelcast.pc.config
Contains Jet pipeline declarative configuration parser configuration objects.
com.hazelcast.pc.exceptions - package com.hazelcast.pc.exceptions
Contains exceptions thrown while parsing Jet pipeline declarative configuration.
com.hazelcast.pc.sinks - package com.hazelcast.pc.sinks
Contains the supported Jet sink types by declarative configuration.
com.hazelcast.pc.sources - package com.hazelcast.pc.sources
Contains the supported Jet source types by declarative configuration.
com.hazelcast.pc.transforms - package com.hazelcast.pc.transforms
Contains the supported transform step types by declarative configuration.
com.hazelcast.rest.access - package com.hazelcast.rest.access
Contains interfaces for access control services used by REST.
com.hazelcast.security - package com.hazelcast.security
 
com.hazelcast.security.loginimpl - package com.hazelcast.security.loginimpl
This package contains Hazelcast internal LoginModule implementations.
com.hazelcast.usercode - package com.hazelcast.usercode
Usercode feature configuration.
com.hazelcast.usercode.jet - package com.hazelcast.usercode.jet
Jet support for Usercode feature.
com.hazelcast.vector - package com.hazelcast.vector
Vector capability
com.hazelcast.vector.jet - package com.hazelcast.vector.jet
Provides Jet pipeline support for vector collections.
commit() - Method in class com.hazelcast.security.ClusterLoginModule
 
commitSucceeded - Variable in class com.hazelcast.security.ClusterLoginModule
 
config - Variable in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
 
ConfigCallback - Class in com.hazelcast.security
This JAAS Callback is used to retrieve member Config.
ConfigCallback() - Constructor for class com.hazelcast.security.ConfigCallback
 
CONFIGURATION_BASED - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.DebeziumSnapshotMode
Allows control over snapshots by setting connectors properties prefixed with 'snapshot.mode.configuration.based'.
ConfigurationException - Exception in com.hazelcast.pc.exceptions
 
ConfigurationException() - Constructor for exception com.hazelcast.pc.exceptions.ConfigurationException
 
ConfigurationException(String) - Constructor for exception com.hazelcast.pc.exceptions.ConfigurationException
 
ConfigurationException(String, Throwable) - Constructor for exception com.hazelcast.pc.exceptions.ConfigurationException
 
createLdapContext() - Method in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
createLdapContext() - Method in class com.hazelcast.security.loginimpl.LdapLoginModule
 
createPipeline() - Method in class com.hazelcast.pc.PipelineCreator
 
CredentialsCallback - Class in com.hazelcast.security
CredentialsCallback is used to retrieve Credentials.
CredentialsCallback() - Constructor for class com.hazelcast.security.CredentialsCallback
 
ctx - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
customMapping(RecordMappingFunction<T_NEW>) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Sets the return type of the source to user defined #T_NEW type.
customMapping(RecordMappingFunction<T_NEW>) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Sets the return type of the source to user defined #T_NEW type.
customMapping(RecordMappingFunction<T_NEW>) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Sets the return type of the source to user defined #T_NEW type.

D

database() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord
Returns the name of the database containing the record's table.
debezium(String, Class<?>) - Static method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources
Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
debezium(String, String) - Static method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources
Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
DebeziumCdcSources - Class in com.hazelcast.enterprise.jet.cdc
Contains factory methods for creating Change Data Capture (CDC) sources.
DebeziumCdcSources.Builder<T> - Class in com.hazelcast.enterprise.jet.cdc
A builder to configure a CDC source that streams the change data from a Debezium-supported database to Hazelcast Jet.
debeziumJson(String, Class<?>) - Static method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources
Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
debeziumJson(String, String) - Static method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources
Creates a CDC source that streams change data from a Debezium-supported database to a Hazelcast Jet pipeline.
DebeziumSnapshotMode - Enum Class in com.hazelcast.enterprise.jet.cdc
Possible Debezium snapshot modes, that does not require additional mandatory parameters to be set.
DEFAULT_PARSE_DN - Static variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
DEFAULT_RESOURCE_FILE_NAME - Static variable in class com.hazelcast.usercode.jet.UserCodeTransforms
The name of the resource zip file that contains the user code.
DEFAULT_ROLE_ATTRIBUTE - Static variable in class com.hazelcast.security.loginimpl.X509CertificateLoginModule
Default value for "roleAttribute" attribute.
DEFAULT_ROLE_RECURSION_MAX_DEPTH - Static variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
Role search recursion is disabled by default
DEFAULT_ROLE_SEPARATOR - Static variable in class com.hazelcast.security.loginimpl.SimplePropertiesLoginModule
 
DEFAULT_USER_FILTER - Static variable in class com.hazelcast.security.loginimpl.LdapLoginModule
Default value for the "userFilter" option.
DEFAULT_USER_NAME_ATTRIBUTE - Static variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
DefaultLoginModule - Class in com.hazelcast.security.loginimpl
The default Hazelcast Enterprise LoginModule.
DefaultLoginModule() - Constructor for class com.hazelcast.security.loginimpl.DefaultLoginModule
 
DELETE - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.Operation
Record deletion, sourced from the DB changelog.
deleteAsync(K) - Method in interface com.hazelcast.vector.VectorCollection
Removes asynchronously the association of given key to a document, if such an association existed.
deserialize(TokenCredentials) - Method in interface com.hazelcast.security.TokenDeserializer
Deserializes and returns the token value from given TokenCredentials.

E

endpoint - Variable in class com.hazelcast.security.ClusterLoginModule
 
EndpointCallback - Class in com.hazelcast.security
The EndpointCallback is used to retrieve remote endpoint address.
EndpointCallback() - Constructor for class com.hazelcast.security.EndpointCallback
 
ENFORCED - Static variable in exception com.hazelcast.security.WeakSecretException
 
engineBuilderSupplier - Variable in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
 
equals(Object) - Method in class com.hazelcast.security.HazelcastPrincipal
 

F

FileSource - Class in com.hazelcast.pc.sources
 
FileSource() - Constructor for class com.hazelcast.pc.sources.FileSource
 
filter(String, CacheEntryView<K, V>, WanFilterEventType) - Method in interface com.hazelcast.cache.wan.CacheWanEventFilter
This method decides whether this entry view is suitable to replicate over WAN.
filter(String, EntryView<K, V>, WanFilterEventType) - Method in interface com.hazelcast.map.wan.MapWanEventFilter
This method decides whether this entry view is suitable to replicate over WAN.
format() - Method in class com.hazelcast.vector.jet.FvecsFileFormat
 
format() - Method in class com.hazelcast.vector.jet.IvecsFileFormat
 
formatMessage(String, EnumSet<WeakSecretError>) - Static method in exception com.hazelcast.security.WeakSecretException
 
fromConfig(JetConfig) - Static method in class com.hazelcast.pc.PipelineCreator
 
fromConfigWithBaseDir(JetConfig, Path) - Static method in class com.hazelcast.pc.PipelineCreator
 
fromMap(Map<String, Object>) - Static method in class com.hazelcast.pc.config.StageConfig
 
fromPath(Path) - Static method in class com.hazelcast.pc.config.JetConfig
 
fromStream(InputStream) - Static method in class com.hazelcast.pc.config.JetConfig
 
fromString(String) - Static method in class com.hazelcast.pc.config.JetConfig
 
fvecs(String, String) - Static method in class com.hazelcast.vector.jet.VectorSources
Creates legacy file source in fvecs format.
FVECS_FILE_FORMAT - Static variable in class com.hazelcast.vector.jet.FvecsFileFormat
Format id for fvecs.
FvecsFileFormat - Class in com.hazelcast.vector.jet
fvecs format definition for Unified File Connector
FvecsFileFormat() - Constructor for class com.hazelcast.vector.jet.FvecsFileFormat
 
fvecsFormat() - Static method in class com.hazelcast.vector.jet.VectorSources
Returns fvecs file format definition for use with Jet Unified File Connector (FileSources).

G

get(String) - Static method in enum class com.hazelcast.enterprise.jet.cdc.Operation
Parses the string present in a CDC message into the corresponding Operation enum member.
getAsync(K) - Method in interface com.hazelcast.vector.VectorCollection
Asynchronously gets the VectorDocument associated with the given key or null if no such association exists.
getAuthenticatedName(GSSContext) - Method in class com.hazelcast.security.loginimpl.GssApiLoginModule
 
getBoolOption(String, boolean) - Method in class com.hazelcast.security.ClusterLoginModule
 
getCertificates() - Method in class com.hazelcast.security.CertificatesCallback
 
getClassId() - Method in class com.hazelcast.security.ClusterEndpointPrincipal
 
getClassId() - Method in class com.hazelcast.security.ClusterIdentityPrincipal
 
getClassId() - Method in class com.hazelcast.security.ClusterRolePrincipal
 
getClusterName() - Method in interface com.hazelcast.rest.access.RestAuthenticationContext
 
getClusterName() - Method in class com.hazelcast.security.ClusterNameCallback
 
getCollection(HazelcastInstance, VectorCollectionConfig) - Static method in interface com.hazelcast.vector.VectorCollection
 
getCollection(HazelcastInstance, String) - Static method in interface com.hazelcast.vector.VectorCollection
 
getConfig() - Method in class com.hazelcast.security.ConfigCallback
 
getCredentials() - Method in class com.hazelcast.security.CredentialsCallback
 
getEndpoint() - Method in class com.hazelcast.security.EndpointCallback
 
getFactoryId() - Method in class com.hazelcast.security.HazelcastPrincipal
Returns SecurityDataSerializerHook.F_ID.
getImageName() - Method in class com.hazelcast.usercode.UserCodeConfig
Gets name of the image that contains the user code.
getIntOption(String, int) - Method in class com.hazelcast.security.ClusterLoginModule
 
getLastIdentity() - Method in class com.hazelcast.security.ClusterLoginModule
 
getMethodName() - Method in interface com.hazelcast.rest.access.RestAuthorizationContext
 
getModuleName() - Method in class com.hazelcast.usercode.UserCodeConfig
Gets module name of the transformation function in the provided user code resource or container image.
getName() - Method in class com.hazelcast.security.ClusterLoginModule
 
getName() - Method in class com.hazelcast.security.HazelcastPrincipal
 
getName() - Method in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
getName() - Method in class com.hazelcast.security.loginimpl.DefaultLoginModule
 
getName() - Method in class com.hazelcast.security.loginimpl.GssApiLoginModule
 
getName() - Method in class com.hazelcast.security.loginimpl.SimplePropertiesLoginModule
 
getName() - Method in class com.hazelcast.security.loginimpl.X509CertificateLoginModule
 
getName() - Method in class com.hazelcast.usercode.UserCodeConfig
Gets pipeline stage name of the user code mapping.
getOptionalValue(String, Class<T>) - Method in class com.hazelcast.pc.config.StageConfig
 
getPassword() - Method in interface com.hazelcast.rest.access.RestAuthenticationContext
 
getPipeline() - Method in class com.hazelcast.pc.config.JetConfig
 
getRequiredValue(String, Class<T>) - Method in class com.hazelcast.pc.config.StageConfig
 
getResourcePath() - Method in interface com.hazelcast.rest.access.RestAuthorizationContext
 
getSearchScope(String) - Method in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
getSink() - Method in class com.hazelcast.pc.config.PipelineConfig
 
getSource() - Method in class com.hazelcast.pc.config.PipelineConfig
 
getStringOption(String, String) - Method in class com.hazelcast.security.ClusterLoginModule
 
getToken() - Method in interface com.hazelcast.rest.access.RestAuthenticationContext
 
getTokenDeserializer() - Method in class com.hazelcast.security.TokenDeserializerCallback
 
getTransform() - Method in class com.hazelcast.pc.config.PipelineConfig
 
getType() - Method in enum class com.hazelcast.enterprise.wan.WanFilterEventType
 
getType() - Method in class com.hazelcast.pc.config.StageConfig
 
getUsername() - Method in interface com.hazelcast.rest.access.RestAuthenticationContext
 
getWeaknesses() - Method in exception com.hazelcast.security.WeakSecretException
 
GssApiLoginModule - Class in com.hazelcast.security.loginimpl
Hazelcast GSS-API LoginModule implementation.
GssApiLoginModule() - Constructor for class com.hazelcast.security.loginimpl.GssApiLoginModule
 

H

hashCode() - Method in class com.hazelcast.security.HazelcastPrincipal
 
hasMoreIgnorePartResEx(NamingEnumeration<SearchResult>) - Method in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
HazelcastPrincipal - Class in com.hazelcast.security
 
HazelcastPrincipal() - Constructor for class com.hazelcast.security.HazelcastPrincipal
 
HazelcastPrincipal(String) - Constructor for class com.hazelcast.security.HazelcastPrincipal
 
HotRestartException - Exception in com.hazelcast.hotrestart
Exception type exposed to the client of the Hot Restart SPI.
HotRestartException() - Constructor for exception com.hazelcast.hotrestart.HotRestartException
 
HotRestartException(String) - Constructor for exception com.hazelcast.hotrestart.HotRestartException
 
HotRestartException(String, Throwable) - Constructor for exception com.hazelcast.hotrestart.HotRestartException
 
HotRestartException(Throwable) - Constructor for exception com.hazelcast.hotrestart.HotRestartException
 

I

IndexMutationDisallowedException - Exception in com.hazelcast.vector
Exception that indicates that the state found on this index disallows mutation.
IndexMutationDisallowedException(String) - Constructor for exception com.hazelcast.vector.IndexMutationDisallowedException
 
init(Properties, ClassLoader) - Method in interface com.hazelcast.enterprise.jet.cdc.RecordMappingFunction
Initializes this mapping function
initAuthentication() - Method in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
initAuthentication() - Method in class com.hazelcast.security.loginimpl.LdapLoginModule
 
INITIAL - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.DebeziumSnapshotMode
Perform a snapshot only upon initial startup of a connector.
INITIAL_ONLY - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.DebeziumSnapshotMode
Perform a snapshot and then stop before attempting to receive any logical changes.
initialize(Subject, CallbackHandler, Map<String, ?>, Map<String, ?>) - Method in class com.hazelcast.security.ClusterLoginModule
 
INSERT - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.Operation
Record insertion, sourced from the DB changelog.
isSkipIdentity() - Method in class com.hazelcast.security.ClusterLoginModule
 
isSkipRole() - Method in class com.hazelcast.security.ClusterLoginModule
 
ItemsSource - Class in com.hazelcast.pc.sources
 
ItemsSource() - Constructor for class com.hazelcast.pc.sources.ItemsSource
 
ItemStreamSource - Class in com.hazelcast.pc.sources
 
ItemStreamSource() - Constructor for class com.hazelcast.pc.sources.ItemStreamSource
 
ivecs(String, String) - Static method in class com.hazelcast.vector.jet.VectorSources
Creates legacy file source in ivecs format.
IVECS_FILE_FORMAT - Static variable in class com.hazelcast.vector.jet.IvecsFileFormat
Format id for ivecs.
IvecsFileFormat - Class in com.hazelcast.vector.jet
ivecs format definition for Unified File Connector
IvecsFileFormat() - Constructor for class com.hazelcast.vector.jet.IvecsFileFormat
 
ivecsFormat() - Static method in class com.hazelcast.vector.jet.VectorSources
Returns ivecs file format definition for use with Jet Unified File Connector (FileSources).

J

JdbcSink - Class in com.hazelcast.pc.sinks
 
JdbcSink() - Constructor for class com.hazelcast.pc.sinks.JdbcSink
 
JdbcSource - Class in com.hazelcast.pc.sources
 
JdbcSource() - Constructor for class com.hazelcast.pc.sources.JdbcSource
 
JetConfig - Class in com.hazelcast.pc.config
 
JetConfig() - Constructor for class com.hazelcast.pc.config.JetConfig
 
json() - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Sets the return type of the source to Map.Entry with key and value being SourceRecord's key and value, parsed to json string.
json() - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Sets the return type of the source to Map.Entry with key and value being SourceRecord's key and value, parsed to json string.
json() - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Sets the return type of the source to Map.Entry with key and value being SourceRecord's key and value, parsed to json string.

K

KafkaSink - Class in com.hazelcast.pc.sinks
 
KafkaSink() - Constructor for class com.hazelcast.pc.sinks.KafkaSink
 
KafkaSource - Class in com.hazelcast.pc.sources
 
KafkaSource() - Constructor for class com.hazelcast.pc.sources.KafkaSource
 
key() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord
Returns the key part of the CDC event.

L

LdapLoginModule - Class in com.hazelcast.security.loginimpl
JAAS Login module which uses LDAP protocol to verify credentials and load roles.
LdapLoginModule() - Constructor for class com.hazelcast.security.loginimpl.LdapLoginModule
 
LOADED - Enum constant in enum class com.hazelcast.enterprise.wan.WanFilterEventType
An event type indicating that the entry was loaded.
logger - Variable in class com.hazelcast.security.ClusterLoginModule
 
LoggerSink - Class in com.hazelcast.pc.sinks
 
LoggerSink() - Constructor for class com.hazelcast.pc.sinks.LoggerSink
 
login - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
login() - Method in class com.hazelcast.security.ClusterLoginModule
 
loginSucceeded - Variable in class com.hazelcast.security.ClusterLoginModule
 
logLdapContextProperties(Properties) - Method in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
logout() - Method in class com.hazelcast.security.ClusterLoginModule
 

M

map(IMap<? super K, ? super V>, FunctionEx<? super ChangeRecord, ? extends K>, FunctionEx<? super ChangeRecord, ? extends V>) - Static method in class com.hazelcast.enterprise.jet.cdc.CdcSinks
Returns a sink that applies the changes described by a Change Data Capture (CDC) stream to an IMap.
map(String, FunctionEx<? super ChangeRecord, ? extends K>, FunctionEx<? super ChangeRecord, ? extends V>) - Static method in class com.hazelcast.enterprise.jet.cdc.CdcSinks
Returns a sink that applies the changes described by a Change Data Capture (CDC) stream to an IMap.
MapJournalSource - Class in com.hazelcast.pc.sources
 
MapJournalSource() - Constructor for class com.hazelcast.pc.sources.MapJournalSource
 
MapSink - Class in com.hazelcast.pc.sinks
 
MapSink() - Constructor for class com.hazelcast.pc.sinks.MapSink
 
MapSource - Class in com.hazelcast.pc.sources
 
MapSource() - Constructor for class com.hazelcast.pc.sources.MapSource
 
mapUsingUserCode(UserCodeConfig) - Static method in class com.hazelcast.usercode.jet.UserCodeTransforms
A stage transforming method that allows the user-defined function to add to the pipeline stage.
mapUsingUserCode(UserCodeConfig, boolean, int) - Static method in class com.hazelcast.usercode.jet.UserCodeTransforms
A stage transforming method that allows the user-defined function to add to the pipeline stage.
mapUsingVectorSearch(VectorCollection<K, V>, SearchOptions, FunctionEx<T, VectorValues>, BiFunctionEx<T, SearchResults<K, V>, R>) - Static method in class com.hazelcast.vector.jet.VectorTransforms
A stage-transforming method that adds similarity search pipeline stage for streaming pipelines.
mapUsingVectorSearch(String, SearchOptions, FunctionEx<T, VectorValues>, BiFunctionEx<T, SearchResults<K, V>, R>) - Static method in class com.hazelcast.vector.jet.VectorTransforms
A stage-transforming method that adds similarity search pipeline stage for streaming pipelines.
mapUsingVectorSearchBatch(VectorCollection<K, V>, SearchOptions, FunctionEx<T, VectorValues>, BiFunctionEx<T, SearchResults<K, V>, R>) - Static method in class com.hazelcast.vector.jet.VectorTransforms
A stage-transforming method that adds similarity search pipeline stage for batch pipelines.
mapUsingVectorSearchBatch(String, SearchOptions, FunctionEx<T, VectorValues>, BiFunctionEx<T, SearchResults<K, V>, R>) - Static method in class com.hazelcast.vector.jet.VectorTransforms
A stage-transforming method that adds similarity search pipeline stage for batch pipelines.
MapWanEventFilter<K,V> - Interface in com.hazelcast.map.wan
WAN event filtering interface for IMap based wan replication events.
maxRecursionDepth - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
maybeApplyTimestamps(StreamSourceStage<T>, StageConfig) - Static method in interface com.hazelcast.pc.Source
 
mysql(String) - Static method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources
Creates a CDC source that streams change data from a MySQL database to Hazelcast Jet.
MySqlCdcSources - Class in com.hazelcast.enterprise.jet.cdc.mysql
Contains factory methods for creating change data capture sources based on MySQL databases.
MySqlCdcSources.Builder<T> - Class in com.hazelcast.enterprise.jet.cdc.mysql
Builder for configuring a CDC source that streams change data from a MySQL database to Hazelcast Jet.
MySqlSequenceExtractor - Class in com.hazelcast.enterprise.jet.cdc.mysql
 
MySqlSequenceExtractor() - Constructor for class com.hazelcast.enterprise.jet.cdc.mysql.MySqlSequenceExtractor
 

N

name - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
newValue() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord
Returns the new value of the record.
NO_DATA - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.DebeziumSnapshotMode
Never perform a snapshot and only receive logical changes.
nonNullValue() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord
Returns the value part of the CDC event.

O

of(String, EnumSet<WeakSecretError>) - Static method in exception com.hazelcast.security.WeakSecretException
 
oldValue() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord
Returns the old value of the record.
onAbort() - Method in class com.hazelcast.security.ClusterLoginModule
 
onCommit() - Method in class com.hazelcast.security.ClusterLoginModule
 
onInitialize() - Method in class com.hazelcast.security.ClusterLoginModule
 
onInitialize() - Method in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
onInitialize() - Method in class com.hazelcast.security.loginimpl.GssApiLoginModule
 
onInitialize() - Method in class com.hazelcast.security.loginimpl.LdapLoginModule
 
onLogin() - Method in class com.hazelcast.security.ClusterLoginModule
 
onLogin() - Method in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
onLogin() - Method in class com.hazelcast.security.loginimpl.DefaultLoginModule
 
onLogin() - Method in class com.hazelcast.security.loginimpl.GssApiLoginModule
 
onLogin() - Method in class com.hazelcast.security.loginimpl.LdapLoginModule
 
onLogin() - Method in class com.hazelcast.security.loginimpl.SimplePropertiesLoginModule
 
onLogin() - Method in class com.hazelcast.security.loginimpl.X509CertificateLoginModule
 
onLogout() - Method in class com.hazelcast.security.ClusterLoginModule
 
operation() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord
Returns the type of change this record describes (insert, delete or update).
Operation - Enum Class in com.hazelcast.enterprise.jet.cdc
Describes the nature of a CDC event, mainly the type of action performed on a database record: insertion, update and deletion.
optimizeAsync() - Method in interface com.hazelcast.vector.VectorCollection
Optimize the only index by fully removing nodes marked for deletion, trimming neighbor sets to the advertised degree, and updating the entry node as necessary.
optimizeAsync(String) - Method in interface com.hazelcast.vector.VectorCollection
Optimize the specified index by fully removing nodes marked for deletion, trimming neighbor sets to the advertised degree, and updating the entry node as necessary.
OPTION_KEYTAB_FILE - Static variable in class com.hazelcast.security.loginimpl.GssApiLoginModule
Option name which allows (together with the GssApiLoginModule.OPTION_PRINCIPAL) simplification of security realm configurations.
OPTION_PARSE_DN - Static variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
Login module option name - If the option is set to true, then it treats the value of the roleMappingAttribute as a DN and extracts only roleNameAttribute attribute values as role names.
OPTION_PASSWORD_ATTRIBUTE - Static variable in class com.hazelcast.security.loginimpl.LdapLoginModule
Login module option name - Credentials verification is done by new LDAP binds by default.
OPTION_PREFIX_PASSWORD - Static variable in class com.hazelcast.security.loginimpl.SimplePropertiesLoginModule
 
OPTION_PREFIX_ROLES - Static variable in class com.hazelcast.security.loginimpl.SimplePropertiesLoginModule
 
OPTION_PRINCIPAL - Static variable in class com.hazelcast.security.loginimpl.GssApiLoginModule
Option name which allows (together with the GssApiLoginModule.OPTION_KEYTAB_FILE) simplification of security realm configurations.
OPTION_RELAX_FLAGS_CHECK - Static variable in class com.hazelcast.security.loginimpl.GssApiLoginModule
Name of the option which allows disabling some of the checks on incoming token (e.g. passes authentication even if the mutual authentication is required by the token).
OPTION_ROLE_ATTRIBUTE - Static variable in class com.hazelcast.security.loginimpl.X509CertificateLoginModule
Login module option name under which role name attribute is stored.
OPTION_ROLE_CONTEXT - Static variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
Login module option name - LDAP Context in which assigned roles are searched.
OPTION_ROLE_FILTER - Static variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
Login module option name - LDAP search string which usually contains placeholder {memberDN} to be replaced by provided login name.
OPTION_ROLE_MAPPING_ATTRIBUTE - Static variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
Login module option name - Name of the LDAP attribute which contains either role name or role DN.
OPTION_ROLE_MAPPING_MODE - Static variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
Login module option name - Role mapping mode - it can have one of the following values: attribute - user object in the LDAP contains directly role name in the given attribute.
OPTION_ROLE_NAME_ATTRIBUTE - Static variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
This option either refers to a name of LDAP attribute within role object which contains the role name in case of "direct" and "reverse" roleMappingMode values.
OPTION_ROLE_RECURSION_MAX_DEPTH - Static variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
Login module option name - Sets max depth of role search recursion.
OPTION_ROLE_SEARCH_SCOPE - Static variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
LDAP search scope used for roleFilter search.
OPTION_ROLE_SEPARATOR - Static variable in class com.hazelcast.security.loginimpl.SimplePropertiesLoginModule
 
OPTION_SECURITY_REALM - Static variable in class com.hazelcast.security.loginimpl.GssApiLoginModule
Option name for referencing Security realm name in Hazelcast configuration.
OPTION_SECURITY_REALM - Static variable in class com.hazelcast.security.loginimpl.LdapLoginModule
Option name for referencing Security realm name in Hazelcast configuration.
OPTION_SKIP_AUTHENTICATION - Static variable in class com.hazelcast.security.loginimpl.LdapLoginModule
Login module option name - Allows disabling password verification and only takes care about filling HazelcastPrincipal instances into the Subject.
OPTION_SKIP_ENDPOINT - Static variable in class com.hazelcast.security.ClusterLoginModule
 
OPTION_SKIP_IDENTITY - Static variable in class com.hazelcast.security.ClusterLoginModule
 
OPTION_SKIP_ROLE - Static variable in class com.hazelcast.security.ClusterLoginModule
 
OPTION_USE_NAME_WITHOUT_REALM - Static variable in class com.hazelcast.security.loginimpl.GssApiLoginModule
Option name which allows cutting off the Kerberos realm part from authenticated name.
OPTION_USER_CONTEXT - Static variable in class com.hazelcast.security.loginimpl.LdapLoginModule
Login module option name - LDAP Context in which user objects are searched.
OPTION_USER_FILTER - Static variable in class com.hazelcast.security.loginimpl.LdapLoginModule
Login module option name - LDAP search string for retrieving user objects based on provided login name.
OPTION_USER_NAME_ATTRIBUTE - Static variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
Login module option name - LDAP Attribute name which value will be used as a name in ClusterIdentityPrincipal added to the JAAS Subject.
OPTION_USER_SEARCH_SCOPE - Static variable in class com.hazelcast.security.loginimpl.LdapLoginModule
Login module option name - LDAP search scope used for "userFilter" search.
options - Variable in class com.hazelcast.security.ClusterLoginModule
 

P

PackageProcessorException - Exception in com.hazelcast.pc.exceptions
 
PackageProcessorException() - Constructor for exception com.hazelcast.pc.exceptions.PackageProcessorException
 
PackageProcessorException(String) - Constructor for exception com.hazelcast.pc.exceptions.PackageProcessorException
 
PackageProcessorException(String, Throwable) - Constructor for exception com.hazelcast.pc.exceptions.PackageProcessorException
 
PackageProcessorException(Throwable) - Constructor for exception com.hazelcast.pc.exceptions.PackageProcessorException
 
parseFromDN - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
ParsingException - Exception in com.hazelcast.enterprise.jet.cdc
Exception to indicate that parsing CDC JSON data has failed irrecoverably.
ParsingException(String) - Constructor for exception com.hazelcast.enterprise.jet.cdc.ParsingException
Constructs a new exception with the specified detail message.
ParsingException(String, Throwable) - Constructor for exception com.hazelcast.enterprise.jet.cdc.ParsingException
Constructs a new exception with the specified detail message and Throwable as cause.
password - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
PipelineConfig - Class in com.hazelcast.pc.config
 
PipelineConfig() - Constructor for class com.hazelcast.pc.config.PipelineConfig
 
PipelineCreator - Class in com.hazelcast.pc
 
PLACEHOLDER_DN - Static variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
Placeholder string to be replaced by a user or role DN in the "roleFilter" option.
PLACEHOLDER_LOGIN - Static variable in class com.hazelcast.security.loginimpl.LdapLoginModule
Placeholder string to be replaced by provided login name in the "userFilter" option.
postgres(String) - Static method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources
Creates a CDC source that streams change data from a PostgreSQL database to Hazelcast Jet.
PostgresCdcSources - Class in com.hazelcast.enterprise.jet.cdc.postgres
Contains factory methods for creating change data capture sources based on PostgreSQL databases.
PostgresCdcSources.Builder<T> - Class in com.hazelcast.enterprise.jet.cdc.postgres
Builder for configuring a CDC source that streams change data from a PostgreSQL database to Hazelcast Jet.
PostgresSequenceExtractor - Class in com.hazelcast.enterprise.jet.cdc.postgres
 
PostgresSequenceExtractor() - Constructor for class com.hazelcast.enterprise.jet.cdc.postgres.PostgresSequenceExtractor
 
putAllAsync(Map<? extends K, VectorDocument<V>>) - Method in interface com.hazelcast.vector.VectorCollection
Inserts asynchronously the given map of key-document pairs.
putAsync(K, VectorDocument<V>) - Method in interface com.hazelcast.vector.VectorCollection
Asynchronously associates the given key with the value VectorDocument, returning the VectorDocument previously associated with the key if such an association existed.
putIfAbsentAsync(K, VectorDocument<V>) - Method in interface com.hazelcast.vector.VectorCollection
If the given key is not already associated with a VectorDocument, associates it with the given value and returns null, else returns the current value.
PythonTransform<R,T> - Class in com.hazelcast.pc.transforms
 
PythonTransform() - Constructor for class com.hazelcast.pc.transforms.PythonTransform
 

R

readData(ObjectDataInput) - Method in class com.hazelcast.security.HazelcastPrincipal
 
recordMappingFunction - Variable in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
 
RecordMappingFunction<R> - Interface in com.hazelcast.enterprise.jet.cdc
Function that maps given SourceRecord to some particular R type.
RecordPart - Interface in com.hazelcast.enterprise.jet.cdc
Represents the top-level component of a ChangeRecord, such as the key or the value.
registerSink(String, Sink) - Static method in class com.hazelcast.pc.PipelineCreator
 
registerSource(String, Source) - Static method in class com.hazelcast.pc.PipelineCreator
 
registerTransform(String, Transform) - Static method in class com.hazelcast.pc.PipelineCreator
 
remoteMap(String, ClientConfig, FunctionEx<? super ChangeRecord, ? extends K>, FunctionEx<? super ChangeRecord, ? extends V>) - Static method in class com.hazelcast.enterprise.jet.cdc.CdcSinks
removeAsync(K) - Method in interface com.hazelcast.vector.VectorCollection
Removes asynchronously the association of given key to a document, if such an association existed, returning the VectorDocument previously associated with the key if such an association existed.
REMOVED - Enum constant in enum class com.hazelcast.enterprise.wan.WanFilterEventType
An event type indicating that the entry was removed.
RestAuthenticationContext - Interface in com.hazelcast.rest.access
 
RestAuthorizationContext - Interface in com.hazelcast.rest.access
 
results() - Method in interface com.hazelcast.vector.SearchResults
 
roleContext - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
roleFilter - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
roleMappingAttribute - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
roleMappingMode - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
roleNameAttribute - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
roleSearchScope - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 

S

schema() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord
Returns the name of the schema containing the record's table.
searchAsync(VectorValues, SearchOptions) - Method in interface com.hazelcast.vector.VectorCollection
Perform asynchronously a similarity search according to the options in given searchOptions.
SearchResults<K,V> - Interface in com.hazelcast.vector
 
SecretStrengthPolicy - Interface in com.hazelcast.security
Specification of a secret strength policy validator.
sequence(Map<String, ?>) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlSequenceExtractor
 
sequence(Map<String, ?>) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresSequenceExtractor
 
sequence(Map<String, ?>) - Method in interface com.hazelcast.enterprise.jet.cdc.SequenceExtractor
 
SEQUENCE_CACHE_EXPIRATION_SECONDS - Static variable in class com.hazelcast.enterprise.jet.cdc.CdcSinks
Number of seconds for which the sink will remember the last seen sequence number for an input key (used to detect reordering).
SequenceExtractor - Interface in com.hazelcast.enterprise.jet.cdc
Utility that takes Debezium event headers and computes a sequence number we can use to ensure the ordering of ChangeRecord items.
sequenceSource() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord
Specifies the source descriptor of the record's sequence.
sequenceValue() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord
Specifies the numeric value part of the record's source sequence.
setAsync(K, VectorDocument<V>) - Method in interface com.hazelcast.vector.VectorCollection
Asynchronously associates the given key with the value VectorDocument.
setCertificates(Certificate[]) - Method in class com.hazelcast.security.CertificatesCallback
 
setClusterName(String) - Method in class com.hazelcast.security.ClusterNameCallback
 
setColumnIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Optional regular expressions that match the fully-qualified names of columns that should be excluded from change event message values.
setColumnIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Optional regular expressions that match the fully-qualified names of columns that should be excluded from change event message values.
setConfig(Config) - Method in class com.hazelcast.security.ConfigCallback
 
setCredentials(Credentials) - Method in class com.hazelcast.security.CredentialsCallback
 
setCustomSnapshotter(Class<?>) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Custom snapshotter that will be used by the connector.
setCustomSnapshotter(Class<?>) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Custom snapshotter that will be used by the connector.
setDatabaseAddress(String) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
IP address or hostname of the database server, has to be specified.
setDatabaseAddress(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
IP address or hostname of the database server, has to be specified.
setDatabaseAddress(String, int) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
IP address or hostname and the port of the database server, has to be specified.
setDatabaseAddress(String, int) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
IP address or hostname and the port of the database server, has to be specified.
setDatabaseClientId(int) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
A numeric ID of this database client, which must be unique across all currently-running database processes in the MySQL cluster.
setDatabaseCredentials(String, String) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Database user and password for connecting to the database server.
setDatabaseCredentials(String, String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Database user and password for connecting to the database server.
setDatabaseExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Optional regular expressions that match databases to be excluded from monitoring; any table not included in the exclude list will be monitored.
setDatabaseExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Optional regular expressions that match databases to be excluded from monitoring; any table not included in the exclude list will be monitored.
setDatabaseExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Optional regular expressions that match databases to be excluded from monitoring; any table not included in the exclude list will be monitored.
setDatabaseIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Optional regular expressions that match databases to be monitored; any database not included in the include list will be excluded from monitoring.
setDatabaseIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Optional regular expressions that match databases to be monitored; any database not included in the include list will be excluded from monitoring.
setDatabaseIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Optional regular expressions that match databases to be monitored; any database not included in the include list will be excluded from monitoring.
setDatabaseName(String) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
The name of the MySQL database from which to stream the changes.
setDatabaseName(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
The name of the PostgreSQL database from which to stream the changes.
setDatabasePassword(String) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Database user password for connecting to the database server.
setDatabasePassword(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Database user password for connecting to the database server.
setDatabasePort(int) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Optional port number of the database server, if unspecified defaults to the database specific default port (5432).
setDatabasePort(int) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Optional port number of the database server, if unspecified defaults to the database specific default port (5432).
setDatabaseUser(String) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Database user for connecting to the database server.
setDatabaseUser(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Database user for connecting to the database server.
setEndpoint(String) - Method in class com.hazelcast.security.EndpointCallback
 
setImageName(String) - Method in class com.hazelcast.usercode.UserCodeConfig
Sets name of the image that contains the user code.
setLogicalDecodingPlugIn(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
The name of the @see Postgres logical decoding plug-in installed on the server.
setModuleName(String) - Method in class com.hazelcast.usercode.UserCodeConfig
Sets module name of the transformation function in the provided user code resource or container image.
setName(String) - Method in class com.hazelcast.usercode.UserCodeConfig
Sets pipeline stage name of the user code mapping.
setPipeline(PipelineConfig) - Method in class com.hazelcast.pc.config.JetConfig
 
setProperty(String, boolean) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Sets a source property.
setProperty(String, boolean) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Sets a source property.
setProperty(String, boolean) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Sets a source property.
setProperty(String, int) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Sets a source property.
setProperty(String, int) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Sets a source property.
setProperty(String, int) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Sets a source property.
setProperty(String, long) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Sets a source property.
setProperty(String, long) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Sets a source property.
setProperty(String, long) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Sets a source property.
setProperty(String, String) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Sets a source property.
setProperty(String, String) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Sets a source property.
setProperty(String, String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Sets a source property.
setPublicationName(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
The name of the Postgres publication that will be used for CDC purposes.
setReplicationSlotDropOnStop(boolean) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Whether to drop the logical replication slot when the connector disconnects cleanly.
setReplicationSlotName(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
The name of the @see Postgres logical decoding slot (also called "replication slot") created for streaming changes from a plug-in and database instance.
setSchemaExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Optional regular expressions that match schema names to be excluded from monitoring ("schema" is used here to denote logical groups of tables).
setSchemaExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Optional regular expressions that match schema names to be excluded from monitoring ("schema" is used here to denote logical groups of tables).
setSchemaIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Optional regular expressions that match schema names to be monitored ("schema" is used here to denote logical groups of tables).
setSchemaIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Optional regular expressions that match schema names to be monitored ("schema" is used here to denote logical groups of tables).
setSink(Map<String, Object>) - Method in class com.hazelcast.pc.config.PipelineConfig
 
setSnapshotMode(DebeziumSnapshotMode) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Snapshot mode that will be used by the connector.
setSnapshotMode(DebeziumSnapshotMode) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Snapshot mode that will be used by the connector.
setSource(Map<String, Object>) - Method in class com.hazelcast.pc.config.PipelineConfig
 
setSslCertificateFile(String) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Specifies the (path to the) file containing the SSL Certificate for the database client.
setSslCertificateFile(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Specifies the (path to the) file containing the SSL Certificate for the database client.
setSslKeyFile(String) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Specifies the (path to the) file containing the SSL private key of the database client.
setSslKeyFile(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Specifies the (path to the) file containing the SSL private key of the database client.
setSslKeyFilePassword(String) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Specifies the password to be used to access the SSL key file, if specified.
setSslKeyFilePassword(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Specifies the password to be used to access the SSL key file, if specified.
setSslMode(String) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Specifies whether to use an encrypted connection to the database.
setSslMode(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Specifies whether to use an encrypted connection to the database.
setSslRootCertificateFile(String) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Specifies the file containing SSL certificate authority (CA) certificate(s).
setSslRootCertificateFile(String) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Specifies the file containing SSL certificate authority (CA) certificate(s).
setTableExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Optional regular expressions that match fully-qualified table identifiers for tables to be excluded from monitoring; any table not included in the exclude list will be monitored.
setTableExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Optional regular expressions that match fully-qualified table identifiers for tables to be excluded from monitoring; any table not included in the blacklist will be monitored.
setTableExcludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Optional regular expressions that match fully-qualified table identifiers for tables to be excluded from monitoring; any table not included in the blacklist will be monitored.
setTableIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Optional regular expressions that match fully-qualified table identifiers for tables to be monitored; any table not included in the whitelist will be excluded from monitoring.
setTableIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Optional regular expressions that match fully-qualified table identifiers for tables to be monitored; any table not included in the whitelist will be excluded from monitoring.
setTableIncludeList(String...) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Optional regular expressions that match fully-qualified table identifiers for tables to be monitored; any table not included in the whitelist will be excluded from monitoring.
setTokenDeserializer(TokenDeserializer) - Method in class com.hazelcast.security.TokenDeserializerCallback
 
setTransform(List<Map<String, Object>>) - Method in class com.hazelcast.pc.config.PipelineConfig
 
setUserDnAndGetAttributes() - Method in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
setUserDnAndGetAttributes() - Method in class com.hazelcast.security.loginimpl.LdapLoginModule
 
SHARED_STATE_IDENTITY - Static variable in class com.hazelcast.security.ClusterLoginModule
 
sharedState - Variable in class com.hazelcast.security.ClusterLoginModule
 
SimplePropertiesLoginModule - Class in com.hazelcast.security.loginimpl
Simple LoginModule which gets user/password/role configuration directly as login module options.
SimplePropertiesLoginModule() - Constructor for class com.hazelcast.security.loginimpl.SimplePropertiesLoginModule
 
sink(Object, StageConfig) - Method in interface com.hazelcast.pc.Sink
 
sink(Object, StageConfig) - Method in class com.hazelcast.pc.sinks.JdbcSink
 
sink(Object, StageConfig) - Method in class com.hazelcast.pc.sinks.KafkaSink
 
sink(Object, StageConfig) - Method in class com.hazelcast.pc.sinks.LoggerSink
 
sink(Object, StageConfig) - Method in class com.hazelcast.pc.sinks.MapSink
 
Sink - Interface in com.hazelcast.pc
 
size() - Method in interface com.hazelcast.vector.SearchResults
 
size() - Method in interface com.hazelcast.vector.VectorCollection
Returns the number of values in the vector collection.
source() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord
Returns full source field of input SourceRecord.
source(Pipeline, StageConfig) - Method in interface com.hazelcast.pc.Source
 
source(Pipeline, StageConfig) - Method in class com.hazelcast.pc.sources.FileSource
 
source(Pipeline, StageConfig) - Method in class com.hazelcast.pc.sources.ItemsSource
 
source(Pipeline, StageConfig) - Method in class com.hazelcast.pc.sources.ItemStreamSource
 
source(Pipeline, StageConfig) - Method in class com.hazelcast.pc.sources.JdbcSource
 
source(Pipeline, StageConfig) - Method in class com.hazelcast.pc.sources.KafkaSource
 
source(Pipeline, StageConfig) - Method in class com.hazelcast.pc.sources.MapJournalSource
 
source(Pipeline, StageConfig) - Method in class com.hazelcast.pc.sources.MapSource
 
source(Map<String, ?>, Map<String, ?>) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlSequenceExtractor
 
source(Map<String, ?>, Map<String, ?>) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresSequenceExtractor
 
source(Map<String, ?>, Map<String, ?>) - Method in interface com.hazelcast.enterprise.jet.cdc.SequenceExtractor
 
Source - Interface in com.hazelcast.pc
 
Sources - Class in com.hazelcast.enterprise.jet.pipeline
Contains factory methods for various types of pipeline sources.
StageConfig - Class in com.hazelcast.pc.config
 
subject - Variable in class com.hazelcast.security.ClusterLoginModule
 
SYNC - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.Operation
Just like Operation.INSERT, but coming from the initial DB snapshot (as opposed to the change log).

T

table() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord
Returns the name of the table this record is part of.
timestamp() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord
Specifies the moment when the change event occurred in the database.
toJson() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord
Returns the raw JSON string from the CDC event underlying this ChangeRecord.
toJson() - Method in interface com.hazelcast.enterprise.jet.cdc.RecordPart
Returns the raw JSON string that this object wraps.
TokenDeserializer - Interface in com.hazelcast.security
Allows to deserialize objects from TokenCredentials token bytes.
TokenDeserializerCallback - Class in com.hazelcast.security
This Callback is used to retrieve TokenDeserializer instance.
TokenDeserializerCallback() - Constructor for class com.hazelcast.security.TokenDeserializerCallback
 
toMap() - Method in interface com.hazelcast.enterprise.jet.cdc.RecordPart
Presents a parsed form of the underlying JSON message as a Map.
toObject(Class<T>) - Method in interface com.hazelcast.enterprise.jet.cdc.RecordPart
Maps the entire element to an instance of the specified class.
toString() - Method in class com.hazelcast.security.HazelcastPrincipal
 
toString() - Method in class com.hazelcast.usercode.UserCodeConfig
 
transform(GeneralStage<T>, StageConfig) - Method in interface com.hazelcast.pc.Transform
 
transform(GeneralStage<T>, StageConfig) - Method in class com.hazelcast.pc.transforms.PythonTransform
 
Transform<R,T> - Interface in com.hazelcast.pc
 

U

udp(String, int, String, StandardProtocolFamily, Integer, BiFunctionEx<byte[], SocketAddress, T>) - Static method in class com.hazelcast.enterprise.jet.pipeline.Sources
Returns a source that connects to the given UDP socket and emits items received from it.
UNSPECIFIED - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.Operation
ChangeRecord doesn't have an operation field, for example heartbeats.
UPDATE - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.Operation
Record update, sourced from the DB changelog.
UPDATED - Enum constant in enum class com.hazelcast.enterprise.wan.WanFilterEventType
An event type indicating that the related entry was created or updated.
userAttributes - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
UserCodeConfig - Class in com.hazelcast.usercode
UserCodeConfig() - Constructor for class com.hazelcast.usercode.UserCodeConfig
 
UserCodeConfig(String, String) - Constructor for class com.hazelcast.usercode.UserCodeConfig
 
UserCodeTransforms - Class in com.hazelcast.usercode.jet
Transforms which allow the user to call the user-defined function in one of the supported runtimes from inside a Jet pipeline.
userDN - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
userNameAttribute - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 

V

validate(String, CharSequence) - Method in interface com.hazelcast.security.SecretStrengthPolicy
Validate a secret.
value() - Method in interface com.hazelcast.enterprise.jet.cdc.ChangeRecord
Returns the value part of the CDC event.
valueOf(String) - Static method in enum class com.hazelcast.enterprise.jet.cdc.DebeziumSnapshotMode
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.hazelcast.enterprise.jet.cdc.Operation
Returns the enum constant of this class with the specified name.
valueOf(String) - Static method in enum class com.hazelcast.enterprise.wan.WanFilterEventType
Returns the enum constant of this class with the specified name.
values() - Static method in enum class com.hazelcast.enterprise.jet.cdc.DebeziumSnapshotMode
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.hazelcast.enterprise.jet.cdc.Operation
Returns an array containing the constants of this enum class, in the order they are declared.
values() - Static method in enum class com.hazelcast.enterprise.wan.WanFilterEventType
Returns an array containing the constants of this enum class, in the order they are declared.
vectorCollection(VectorCollection<K, V>, FunctionEx<? super T, ? extends K>, FunctionEx<? super T, ? extends V>, FunctionEx<? super T, VectorValues>) - Static method in class com.hazelcast.vector.jet.VectorSinks
Returns a sink that writes vector documents with metadata and vector values to a vector collection.
vectorCollection(VectorCollection<K, V>, FunctionEx<? super T, ? extends K>, FunctionEx<? super T, VectorDocument<? extends V>>) - Static method in class com.hazelcast.vector.jet.VectorSinks
Returns a sink that writes vector documents with metadata and vector values to a vector collection.
vectorCollection(String, FunctionEx<? super T, ? extends K>, FunctionEx<? super T, ? extends V>, FunctionEx<? super T, VectorValues>) - Static method in class com.hazelcast.vector.jet.VectorSinks
Returns a sink that writes vector documents with metadata and vector values to a vector collection.
vectorCollection(String, FunctionEx<? super T, ? extends K>, FunctionEx<? super T, VectorDocument<? extends V>>) - Static method in class com.hazelcast.vector.jet.VectorSinks
Returns a sink that writes vector documents with metadata and vector values to a vector collection.
VectorCollection<K,V> - Interface in com.hazelcast.vector
A mapping of keys to VectorDocuments.
VectorSinks - Class in com.hazelcast.vector.jet
Factory methods for Vector collection sinks
VectorSources - Class in com.hazelcast.vector.jet
Sources for loading and processing standard vector data formats.
VectorTransforms - Class in com.hazelcast.vector.jet
Transforms allowing to execute similarity search in Jet pipeline to enrich the stream.
verifyOptions() - Method in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 
visitedRoleDns - Variable in class com.hazelcast.security.loginimpl.BasicLdapLoginModule
 

W

WanFilterEventType - Enum Class in com.hazelcast.enterprise.wan
Event types to be used by CacheWanEventFilter and MapWanEventFilter instances.
WeakSecretException - Exception in com.hazelcast.security
Exception thrown when a weak secret is detected.
WeakSecretException(String) - Constructor for exception com.hazelcast.security.WeakSecretException
 
WHEN_NEEDED - Enum constant in enum class com.hazelcast.enterprise.jet.cdc.DebeziumSnapshotMode
Perform a snapshot when it is needed.
withAsyncEngine() - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Changes the engine used to async embedded engine.
withAsyncEngine() - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Changes the engine used to async embedded engine.
withAsyncEngine() - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Changes the engine used to async embedded engine.
withDefaultEngine() - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Changes the engine used to default embedded engine.
withDefaultEngine() - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Changes the engine used to default embedded engine.
withDefaultEngine() - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Changes the engine used to default embedded engine.
withErrorMaxRetries(int) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Sets the maximum retry count in case of errors.
withErrorMaxRetries(int) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Sets the maximum retry count in case of errors.
withErrorMaxRetries(int) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Sets the maximum retry count in case of errors.
withSequenceExtractor(Class<? extends SequenceExtractor>) - Method in class com.hazelcast.enterprise.jet.cdc.DebeziumCdcSources.Builder
Sets the SequenceExtractor class property.
withSequenceExtractor(Class<? extends SequenceExtractor>) - Method in class com.hazelcast.enterprise.jet.cdc.mysql.MySqlCdcSources.Builder
Sets the SequenceExtractor class property.
withSequenceExtractor(Class<? extends SequenceExtractor>) - Method in class com.hazelcast.enterprise.jet.cdc.postgres.PostgresCdcSources.Builder
Sets the SequenceExtractor class property.
write(Object, Sink<T>) - Static method in interface com.hazelcast.pc.Sink
 
writeData(ObjectDataOutput) - Method in class com.hazelcast.security.HazelcastPrincipal
 

X

X509CertificateLoginModule - Class in com.hazelcast.security.loginimpl
Hazelcast LoginModule implementation for use together with mutual TLS authentication.
X509CertificateLoginModule() - Constructor for class com.hazelcast.security.loginimpl.X509CertificateLoginModule
 
A B C D E F G H I J K L M N O P R S T U V W X 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form