Sets the metrics collection frequency in seconds. The same interval is used for collection for Management Center and for JMX publisher. By default, me

Overrides the default name of the Python function that transforms Jet pipeline data. The default name is {@value #HANDLER_FUNCTION_DEFAULT}. It must b

Associates the provided User Code Namespace Name with this structure for {@link ClassLoader} awareness. <p> The behaviour of setting this to {@code nu

Shuts down this OperationExecutor. Any pending tasks are discarded.

Current size of accumulator. @return returns current size of accumulator.

Creates a new job from given Pipeline Adds this.getClass to config so any lambdas used in a test class can be deserialized when run in remote cluster

Does binary search in a way similar to Arrays.binarySearch, but treats values as unsigned.

Adds the reliable topic configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be o

Adds the split-brain protection configuration. The configuration is saved under the config name defined by {@link SplitBrainProtectionConfig#getName()

Asserts that the previous stage emitted the expected items in any order, but nothing else. If the assertion fails, the job will fail with an {@link As

Asserts that the number of event journal entries for the partition {@link #partitionId} is equal to the given {@code size}. @param adapter the adapte

alternative implementation of {@link org.assertj.core.api.AbstractIterableAssert#doesNotContain(Object...)} that does not rely on an implementation of

Returns a bounded (batch) source constructed directly from the given Core API processor meta-supplier. @param sourceName user-friendly source name @p

Check the state of a condition @throws IllegalStateException if condition is false

Creates a new {@code MemberMap} including given members. @return a new {@code MemberMap}

Creates a description out of a JsonValue. The parser must be pointing to the start of the input. @throws IOException

true if the listener is de-registered, false otherwise

True if this set did not already contain the specified element and the element is added, returns false otherwise.

the number of key-value mappings in this map

list of all data in queue

Ensures that there is a mapping from the given key to a slot in the array. The returned object contains the slot value block address and whether a new

Returns the number of available processors. <p> Returned value is either equal to {@link Runtime#availableProcessors()} or an overridden value by call

Provides access to index options specific to bitmap indexes. @return the bitmap index options associated with this index config.

Returns the current endpoints. @return the endpoints.

Returns the total number of hits into the index. <p> The returned value may be greater than the one returned by {@link #getQueryCount} since a single

Returns remote address of this Connection. @return the remote address. The returned value could be <code>null</code> if the connection is not alive.

Returns the parent. @return the parent

Returns the Persistence configuration for this hazelcast instance @return persistence configuration

Returns the total latency (in nanoseconds) of update operations performed on the index. <p> To compute the average latency divide the returned value b

Gets the WAN target replication reference. @return the WAN target replication reference

Returns unique id of the CP group

Creates a new AsyncServerSocketBuilder. <p/> This method is thread-safe. @return the created AsyncServerSocketBuilder. @throws IllegalStateException

Exposes individual output queues to the testing code. @param ordinal ordinal of the bucket

Reads the current available value as a double. If the underlying probe provides a long value, then the value will be converted to a floating point va

Removes the registration from this registry. @param id key for reaching the item from this registry. @return removed registry entry.

Enables or disables {@link Diagnostics} to see internal performance metrics and cluster related information. <p> The performance monitor logs all metr

Set the {@link javax.cache.configuration.Factory} for the {@link javax.cache.expiry.ExpiryPolicy}. If {@code null} is specified the default {@link jav

Sets the instance name uniquely identifying the hazelcast instance created by this configuration. This name is used in different scenarios, such as id

Applies the user defined {@code EntryProcessor} to the entry mapped by the {@code key}. Returns immediately with a {@link CompletionStage} representin

Returns the name of the tag at the given index. @param index The index @see #tagValue(int) @see #tagCount() @see #readTags(BiConsumer) @throws IndexO

Convert the given trait set to physical convention. @param traitSet Original trait set. @return New trait set with physical convention and provided d

Excludes the given target for this metric. <p> Note: The excluded targets are not part of the textual representation of the metric returned by {@link

Writes a collection to an {@link ObjectDataOutput}. The collection's size is written to the data output, then each object in the collection is seriali

Collects a value passed as an argument @param value value to be collected

Adds {@code addedCount} partitions. Added partitions will be initially considered <em>active</em> and having watermark value equal to the last emitted