Splits String value with comma "," used as a separator. The whitespaces around values are trimmed. @param input string to split @return {@code null}

Starts this OperationExecutor.

This method is called when the member received {@link SnapshotPhase2Operation}.

Returns suspicion level about the tracked member. Returned value is mostly implementation dependent. <code>0</code> indicates no suspicion at all. @pa

Sets the topic to write the messages to, if you write all messages to a single topic. If you write each message to a different topic, use {@link #toRe

Releases the lock if the lock is currently held by the current thread. @throws IllegalMonitorStateException if the lock is not held by the cu

Returns the name of the associated vertex.

Wakes up the inbound pipeline and lets it start reading again from the network. <p> Even if there is no data to be read, it will cause at least one pr

Adds the executor configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be obtaine

Inserts collection of elements to the front of this queue. @param collection collection of elements to be inserted in front of this queue.

@param fieldName name of the field that will be added to this class definition @return itself for chaining @throws HazelcastSerializationException if

Registers an {@link Observer} to this {@code Observable}. It will receive all events currently in the backing {@link Ringbuffer} and then continue rec

Increments the put time accumulator. @param duration the time taken in nanoseconds.

Adds the queue configuration. The configuration is saved under the config name, which may be a pattern with which the configuration will be obtained i

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

Adds the given WAN {@code EndpointConfig} to the endpoints configuration. When the argument is an {@link EndpointConfig}, then it configures network

Attaches a stage that performs the given aggregate operation over all the items it receives from both this stage and {@code stage1} you supply. This v

Registers the {@link AggregateOperation1#accumulateFn() accumulate} primitive for stream-0. Also selects the fixed-arity variant of the aggregate oper

@return this configuration as a {@link CacheConfig}

Takes a generic {@link YamlNode} instance and returns it cast to {@link YamlMapping} if the type of the node is a descendant of {@link YamlMapping}.

Asserts the size of a {@link NearCache}. @param context the {@link NearCacheTestContext} to retrieve the stats from @param expectedSize the expe

Submits the tasklets for execution and returns a future which gets completed when the execution of all the tasklets has completed. If an exception occ

Builds a Reactor based on the configuration of this {@link ReactorBuilder}. <p/> This method can be called multiple times. So a single ReactorBuilder

@return creates and returns a new ClassDefinition

Returns the capacity of this CircularQueue. @return the capacity.

Tests if the newAsyncBackupCount count is valid. @param currentBackupCount the current number of backups @param newAsyncBackupCount the new number o

Returns a builder object that offers a step-by-step fluent API to create an aggregate operation that accepts multiple inputs. You must supply this kin

Connects asynchronously to some address. <p/> This method is not thread-safe. <p/> This method should be called after {@link #start()}. @param addres

Copies memory from given source address to given destination address as given size. @param srcAddress the source address to be copied from @param de

Creates a {@link JsonPattern} for given query path. If the path matches a terminal value in the schema, then the schema is returned. Otherwise, this m