Returns the size of the distributed queue instance with the specified name @param queueName name of the distributed queue @return the size of the dist

Sleeps for the given amount of time and after that, sets stop to true. <p> If stop is changed to true while sleeping, the calls returns before waiting

Returns an aggregate operation that accumulates the items into an {@code ArrayList}. <p> This sample takes a stream of words and outputs a single list

Convert the given input into logical input. @param rel Original input. @return Logical input.

Returns the String representation of the handler. <p>Useful for persisting and/or communicating this info. A {@link ScheduledTaskHandler} can be cons

Executed on the master node before allowing a new member to join from {@link com.hazelcast.internal.cluster.impl.ClusterJoinManager#handleJoinRequest(

Declares that the source will extract timestamps from the stream items. <p> <b>Issue with sparse events</b> <p> Event time progresses only through the

Returns a supplier of processors for {@link KafkaSinks#kafka(Properties, String, FunctionEx, FunctionEx)}.

Writes a nullable boolean. @param fieldName name of the field. @param value to be written.

Returns the MurmurHash3_x86_32 hash of a block inside a byte array.

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

Adds a custom WAN publisher implementation configuration to this WAN replication. @param config the WAN publisher configuration @return this config

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

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

Attaches a stage that performs the given aggregate operation over all the items it receives from this stage as well as {@code stage1} and {@code stage

Registers the {@link AggregateOperation2#accumulateFn1()} accumulate} primitive for stream-1, returning the arity-2 variant of the builder. @param ac

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 items

Asserts that a wrong text protocol method call using given {@link TestUrl} closes the connection without returning any response (e.g. a call to a disa

Causes the current thread to wait until the latch has counted down to zero, or an exception is thrown, or the specified waiting time elapses. <p> If t

Called before migration process starts, on both source and destination members. <p> Service can take actions required before migration. Migration proc

Binds this AsyncServerSocket to the localAddress address. This method is equivalent to calling {@link #bind(SocketAddress, int)} with an Integer.MAX_V

Calculates 64-bit stamp value for the given partitions. Stamp is calculated by hashing the individual partition versions using MurmurHash3. @param pa

Utility method for executing code within the context of the Namespace associated with IMaps - if one does not exist, this code is executed as if it we

Returns the number of items this pipe can hold at a time.

Tests the supplied object to see if it is not a type of the supplied class. @param type the type that is not of the supplied class. @param ob

Tests if a {@code value} is positive, that is strictly larger than 0 (value &gt; 0). @param value the value tested to see if it is positive. @par

Gets a child scalar node's value by its index <p> See {@link YamlScalar} for the possible types <p> Please note that if the scalar's type is not the e

Returns the number of the children that the collection has @return the number of the children

Clears the property. @param propertyName system property to clear @return instance of the rule

Closes an AutoClosable quietly. <p/> If the closable is null, the call is ignored. <p/> If {@link AutoCloseable#close()} throws an exception, it is ig

Checks whether an element exist in this queue. @param e item to be checked @return <code>true</code> if exists, <code>false</code> otherwise

Creates database with given name and returns jdbc url that can be used to connect to the database