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.
attachStorage(VectorCollectionStorage) - Method in interface com.hazelcast.vector.VectorCollectionService
Attaches previously created storage to the service and makes it visible via VectorCollectionService.getStorage(java.lang.String, int) or VectorCollectionService.getStorageOrNull(java.lang.String, int).

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
 
close() - Method in class io.github.jbellis.jvector.graph.HazelcastGraphIndexView
 
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
 
create(OnHeapGraphIndex<float[]>) - Static method in class io.github.jbellis.jvector.graph.HazelcastGraphIndexView
 
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
 
createStorage(String, int) - Method in interface com.hazelcast.vector.VectorCollectionService
Creates VectorCollectionStorage but does not make it visible to others via VectorCollectionService.getStorage(java.lang.String, int) or VectorCollectionService.getStorageOrNull(java.lang.String, int).
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
 
entryNode() - Method in class io.github.jbellis.jvector.graph.HazelcastGraphIndexView
 
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.
getAllExistingVectorCollectionNames() - Method in interface com.hazelcast.vector.VectorCollectionService
 
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.
getIdUpperBound() - Method in class io.github.jbellis.jvector.graph.HazelcastGraphIndexView
 
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.
getNeighborsIterator(int) - Method in class io.github.jbellis.jvector.graph.HazelcastGraphIndexView
 
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
 
getSearcher(String, SearchOptions) - Method in interface com.hazelcast.vector.VectorCollectionService
Provides searcher instance for given collection and options.
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
 
getStatistics(String) - Method in interface com.hazelcast.vector.VectorCollectionService
Provides statistics object instance for given vector collection.
getStorage(String, int) - Method in interface com.hazelcast.vector.VectorCollectionService
Returns storage for vector collection partition, creating it if needed
getStorageOrNull(String, int) - Method in interface com.hazelcast.vector.VectorCollectionService
Returns storage for vector collection partition or null if the collection or partition does not exist.
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
 
getVector(int) - Method in class io.github.jbellis.jvector.graph.HazelcastGraphIndexView
 
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
 
HazelcastGraphIndexView - Class in io.github.jbellis.jvector.graph
 
HazelcastPrincipal - Class in com.hazelcast.security
 
HazelcastPrincipal() - Constructor for class com.hazelcast.security.HazelcastPrincipal
 
HazelcastPrincipal(String) - Constructor for class com.hazelcast.security.HazelcastPrincipal
 
heapBytesUsed(String) - Method in interface com.hazelcast.vector.VectorCollectionService
Returns the estimated number of bytes used on the JVM heap by the designated collection.
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.
io.github.jbellis.jvector.graph - package io.github.jbellis.jvector.graph
This package contains overridden functionality for JVector.
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
 
liveNodes() - Method in class io.github.jbellis.jvector.graph.HazelcastGraphIndexView
 
LOADED - Enum constant in enum class com.hazelcast.enterprise.wan.WanFilterEventType
An event type indicating that the entry was loaded.
localSize(String) - Method in interface com.hazelcast.vector.VectorCollectionService
 
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.
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.
SERVICE_NAME - Static variable in interface com.hazelcast.vector.VectorCollectionService
service name
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.
size() - Method in class io.github.jbellis.jvector.graph.HazelcastGraphIndexView
 
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
 
toString() - Method in class io.github.jbellis.jvector.graph.HazelcastGraphIndexView
 
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.
VectorCollectionService - Interface in com.hazelcast.vector
 
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