@return an iterator that represents a result of intersection of the given iterators.

Converts a JSON string to an Object. The returned object will differ according to the content of the string: <ul> <li>content is a JSON object, re

Returns this JSON value as a <code>long</code> value, assuming that this value represents a JSON number that can be interpreted as Java <code>long</co

Collects all the received items in a list and once the upstream stage is completed, it executes the assertion supplied by {@code assertFn}. If no item

Checks if objects in database matches listed rows.

Returns the role for the map key loader based on the passed parameters. The partition owner of the map name partition is the sender. The first replica

Waits until the client is disconnected from the cluster or the timeout expires. Does not wait if the client is already shutting down or shutdown. @pa

@param <I> type of the input object. @return an aggregator that calculates the sum of the input values. Does NOT accept null input values. Accepts onl

@param <I> type of the input object. @return an aggregator that calculates the average of the input values. Does NOT accept null input values. Accepts

Creates a bitset from the given metric targets. The bitset is used internally for caching target sets. @param targets The targets to create the bitse

Returns the number of buckets in this outbox. This is equal to the number of output edges of the vertex and does not include the snapshot bucket.

Set the supplier function for BulkRequest, defaults to new {@link BulkRequest#BulkRequest()} <p> For example, to modify the BulkRequest used to index

Makes the changes visible to others and acknowledges consumed items. <p> This method is called in exactly-once mode; in at-least-once mode it's called

Called when the Metric contains a {@code double} value. @param descriptor metric descriptor @param value metric value

Copies the contents of the {@code src} backed by an on-heap buffer to {@code dst}. The {@code dst} can be backed by either on-heap or off-heap buffer.

Create copy of the src array. @return copy of the original array