Index
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 memberConfig
. - 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 ornull
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 beingSourceRecord
'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 beingSourceRecord
'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 beingSourceRecord
'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 theroleMappingAttribute
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 theVectorDocument
previously associated with thekey
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 aVectorDocument
, associates it with the givenvalue
and returnsnull
, 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 particularR
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
-
Returns a sink equivalent to
CdcSinks.map(java.lang.String, com.hazelcast.function.FunctionEx<? super com.hazelcast.enterprise.jet.cdc.ChangeRecord, ? extends K>, com.hazelcast.function.FunctionEx<? super com.hazelcast.enterprise.jet.cdc.ChangeRecord, ? extends V>)
, but for a map in a remote Hazelcast cluster identified by the suppliedClientConfig
. - 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 theVectorDocument
previously associated with thekey
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 inputSourceRecord
. - 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 retrieveTokenDeserializer
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
-
Represents configuration for
UserCodeTransforms.mapUsingUserCode(UserCodeConfig)
} - 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
VectorDocument
s. - 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
andMapWanEventFilter
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
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form