Adds a single parameter value to the end of the parameter values list. @param value parameter value @return this instance for chaining @see #setParam

Collects all the received items into a list and runs the {@code assertFn} every time a new item is received. An {@link AssertionError} thrown from the

Asserts the size of a {@link NearCache}. @param context the {@link NearCacheTestContext} to retrieve the owned entry count from @param expectedS

Returns a fluent-API builder with which you can create a {@linkplain BatchSource batch source} for a Jet pipeline. The source will use {@linkplain Pro

clears all internal data without publishing any events

Compares the provided {@link Comparable} instances. <p> Special numeric comparison logic is used for {@link Double}, {@link Long}, {@link Float}, {@li

A generic Kafka Connect source provides ability to plug any Kafka Connect source for data ingestion to Jet pipelines. <p> You need to add the Kafka Co

Converts the {@code inputRel} into a {@code Vertex} by visiting it and create an edge from the input vertex into {@code thisVertex}. @param configure

Creates the {@link NearCacheTestContext} used by the Near Cache tests. <p> The backing {@link DataStructureAdapter} will be populated with {@value #DE

Creates a new or replaces an existing DataConnection with the given parameters. @param name name of the DataConnection @param type type of

Determines the local parallelism value for the vertex by looking at its local parallelism and meta supplier's preferred local parallelism. <p> If none

Enables all REST endpoint groups.

Finds existing Map config. @param name name of the config @return Map config or {@code null} when requested Map configuration does not exist

@return not-{@code null} {@link AuditlogService} instance

Base directory for all Persistence stores. Can be an absolute or relative path to the node startup directory.

Reads the char value from given address. @param address the address where the char value will be read from @return the char value that was read

Looks for a Namespace associated {@link MapResourceClassLoader} defined by the provided {@code Namespace} name, and returns it if available. If not av

Gets the configured list of alternative client configurations. @return the list of configured ClientConfigs

Get connection manager

Returns a not-{@code null} set of enabled REST endpoint groups.

Gets the eviction configuration for this {@link com.hazelcast.cache.ICache}. @return the eviction configuration

Creates or returns a cluster-wide unique ID generator. Generated IDs are {@code long} primitive values and are k-ordered (roughly ordered). IDs are in

@return the gcpConfig join configuration

@return the global serializer configuration @see com.hazelcast.config.GlobalSerializerConfig

Gets the address of the master member. <p> This value can be null if no master is elected yet. <p> The value can change over time. @return the addres

Maximum number of retry attempt that should be made before giving up. <p> A value of 0 should be interpreted as "never retry". Action is performed onc

Gets the maximum number of rolling files to keep on disk. The DiagnosticsLogFile uses a rolling file approach to prevent using too much disk space. <p

Returns the metrics collection config.

Returns the mode in which the persistent memory should be used. @return the mode

Returns the NUMA node the persistent memory mounted to the given directory is attached to. @return the NUMA node of the persistent memory

Returns the index stats associated with this index.

Returns the maximum number of ports allowed to try to bind on. @return the maximum number of ports allowed to try to bind on @see #setPortCount(int)

Returns {@link PublisherContext} for this context. @return {@link PublisherContext} @see PublisherContext

Get the RingbufferStore (load and store ringbuffer items from/to a database) configuration. @return the ringbuffer store configuration

Returns the {@link RoutingPolicy} in effect on the edge.

Returns the {@link EventServiceSegment} for the {@code service}. If the segment is {@code null} and {@code forceCreate} is {@code true}, the segment i

Returns the time when the job was submitted to the cluster. <p> The time is assigned by reading {@code System.currentTimeMillis()} of the coordinator

Returns the name of the task. @return the task name

Gets the uuid of this member. @return the uuid of this member (the returned value will never be {@code null})

Indexes a given document to an index with given name

Removes the value associated with the given {@code key} and increases the invalidation statistics. @param key the key of the value will be invalidate

Checks if there currently is a migration going on in this partition. <p> The returned value could be stale when it is returned. @return {@code true}