Writes the given double value to given address. @param address the address where the double value will be written to @param x the double value

Returns the size of the array holding the concurrent queues. Initially (when the conveyor is constructed) each array slot should point to a distinct c

Reads from the event journal. The returned future may throw {@link UnsupportedOperationException} if the cluster version is lower than 3.9 or there is

Sets the function Jet will call upon receiving an item. The function receives two arguments: the context object (as provided by the {@link #createFn})

Registers a listener on all cluster nodes. @param serviceName service name @param topic topic name @param listener listener instance @return

Resets the observed state by this PN counter. This method may be used after a method invocation has thrown a {@link ConsistencyLostException} to reset

Resets this accumulator. After return of this call, accumulator will be in its initial state.

Prevents the data connection from being closed. It is useful when the processor wants to avoid the data connection from being closed while it is obtai

Rollback the migration process for this service, on both source and destination members. This method will be called when migration process fails at an

Prepares a {@link HttpURLConnection#HTTP_NOT_FOUND} response.

Transactional implementation of {@link IMap#set(Object, Object)}. <p> The object to be set will be accessible only in the current transaction context

Sets index attributes. @param attributes Index attributes. @return This instance for chaining.

Sets base directory for all Persistence stores. Can be an absolute or relative path to the node startup directory. @param baseDir home directory @ret

Sets the class name of the serializer implementation. @param className the class name of the serializer implementation @return SerializationConfig

Optional regular expressions that match database names to be monitored; any database name not included in the whitelist will be excluded from monitori

Sets a decimal which is arbitrary precision and scale floating-point number. <p> It is legal to set the field again only when Builder is created with

Sets the deprecated name of this property. Useful if compatibility needs to be provided on property names. This method is thread-safe, but is expecte

Sets whether hot restart is enabled on related data structure. @return DataPersistenceConfig

@param globalSerializerConfig configuration of serializer that will be used if no other serializer is applicable @return

Sets the merge policy sent to the WAN replication target to merge replicated entries with existing target entries. The default merge policy is {@link

Enable multithreaded message handling. When enabled any thread from events thread pool can be used for incoming message processing. Otherwise, only on

It is legal to set the field again only when Builder is created with {@link GenericRecord#newBuilderWithClone()}. Otherwise, it is illegal to set to t

Sets index page size to given non-negative value. @param pageSize page size of the index

Sets the values for statement parameters. <p> You may define parameter placeholders in the statement with the {@code "?"} character. For every placeho

Sets the partition ID. @param partitionId the ID of the partition. @return the updated Operation. @see #getPartitionId()

Registers the given Compact serializers. <p> For the classes returned by the serializers' {@link CompactSerializer#getCompactClass()} method, Compact

Sets the comma separated list of target cluster members, e.g. {@code 127.0.0.1:5701, 127.0.0.1:5702}. If you don't know the addresses of the target cl

Sets a timestamp with timezone field consisting of year, month of the year and day of the month, offset seconds, hour, minute, seconds, nanos parts. <

Sets the Vault access token. @param token the access token @return the updated {@link VaultSecureStoreConfig} instance @throws IllegalArgumentExcepti

Sets the type of the {@link DataConnection}

Enables or disables deduplication. @param useDeduplication True to enable deduplication, false to disable. @return this VectorIndexConfig instance

Returns a builder object that offers a step-by-step fluent API to build a custom {@link Sink} for the Pipeline API. It allows you to keep a single-thr

Returns number of items in the ringbuffer (meaning the number of items between the {@link #headSequence()} and {@link #tailSequence()}). @return the

Returns the number of elements in this array. @return the number of elements in this array

This is the second phase of a two-phase commit. Jet calls it after the snapshot was successfully saved on all other processors in the job on all clust

Prepares the transactions for commit after the snapshot is completed. If the processor doesn't use transactions, it can just return {@code true} or re

Returns the queue to which snapshot is written. It contains serialized data, if you need deserialized data, you might prefer to use {@link #drainSnaps

Strips the trailing slash from the input string, if it is present @return the string with trailing slash removed

Subtracts the supplied value from this accumulator, throwing an exception in the case of integer overflow.

Matches a {@link Measurement} which contains the specified tag and the tag has the specified value. @param tag the tag to match @param value the va