Returns the set of keys in the multimap. <p> <b>Warning:</b> The collection is <b>NOT</b> backed by the map, so changes to the map are <b>NOT</b> refl

The indices of the fields from the left side of a join which are equi-join keys.

Returns an immutable collection locally owned values contained in this map. <p> <b>Warning:</b> <p> The collection is <b>NOT</b> backed by the map, so

Locks the key on the partition owner and returns the value with the version. Does not invokes maploader if the key is missing in memory. @param key

Maps aliased discovery strategy configs into discovery strategy configs.

Convenience for {@link #mapWithEntryProcessor(int, String, FunctionEx, FunctionEx)} when the maximum number of async operations is not specified.

Merges the given {@link CacheMergeTypes} via the given {@link SplitBrainMergePolicy}. @param mergingEntry the {@link CacheMergeTypes} instance to

Called when the migration process finishes. This event denotes ending of migration process which is started by {@link #migrationStarted(MigrationState

Computes the remainder of the division of <code>a</code> by <code>b</code>. <code>a</code> has to be a non-negative integer and <code>b</code> has to

Helper method to create new {@link MongoDataConnection} with given name and connection string.

Return empty Iterable if argument is null

Called after receiving a new event. Will change the queue state to <em>active</em>. @param queueIndex index of the queue on which the event was recei

Offers a task to be executed on this {@link Reactor}. <p/> This method is thread-safe. @param task the task to execute. @return true if the task was

Offers an item. @param item the item to offer. @return true if the item was accepted, false otherwise. @throws NullPointerException if item is null.

Called when the channel is closed. @param channel the channel closed.

This method is called when an one of the methods of the {@link com.hazelcast.core.EntryListener} is not overridden. It can be practical if you want to

Observes an error event from the {@link Observable} it is registered with, in the form of an exception that reflects the underlying cause. <p> After t

Constructs and returns a join clause with the supplied left-hand and right-hand key extractor functions, and with an identity right-hand projection fu

Callback method when a member has left the cluster, and what the cluster's state is as the member leaves. This is used to track crashed members and ma

Invoked when a partition lost is detected @param event The event object that contains the partition ID and the number of replicas that is lost

Creates an <b>or</b> predicate that will perform the logical <b>or</b> operation on the given {@code predicates}. <p> If the given {@code predicates}

Returns a meta-supplier that wraps the provided one and adds a logging layer to each processor it creates. For each item the wrapped processor adds to

Triggered once the available addresses are collected by a discovery plugin or fixed address list. Once this event is fired, the client will attempt to

Returns a traverser which prepends an additional item in front of all the items of this traverser.

Prioritizes a COPY / SHIFT UP migration against - a non-conflicting MOVE migration on a hotter index, - a non-conflicting SHIFT DOWN migration to a co

Return a function that maps an input {@link JetSqlRow} to an {@link ObjectArrayKey}, extracting the fields given in {@code indices}. @param indices t

Notifies the WAN subsystem of a map entry removal on a replica owner. @param mapName the map name @param key the key of the removed entry

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

Puts the supplied object reference at the supplied offset from the supplied object's base address. @param base the owner object where the reference

Reads a date field consisting of year, month of the year and day of the month to LocalDate @param fieldName name of the field @return the LocalDate v

Reads a decimal which is arbitrary precision and scale floating-point number to BigDecimal @param fieldName name of the field @return the BigDecimal

Reads a long attribute from OperatingSystemMXBean. @param attributeName name of the attribute @param defaultValue default value if the attribute val

Reads a time field consisting of hour, minute, seconds and nanos parts to LocalTime @param fieldName name of the field @return the LocalTime value re

Reads a timestamp field consisting of year, month of the year, day of the month, hour, minute, seconds, nanos parts to LocalDateTime @param fieldName

Reads a timestamp with timezone field consisting of year, month of the year, day of the month, offset seconds, hour, minute, seconds, nanos parts to O

Returns the offset reader to use for the given data length. @param dataLength to get the offset reader. @return the offset reader.

Registers (i.e. stores) the connection for the given primaryAddress. Once this call finishes every subsequent call to {@link #get(Address)} will retur

Release a retained data connection. Must be called after every {@link #retain()} call, otherwise the data connection will leak.

Removes a ClientListener. Can safely be called with a non existing ID, or when the ClientListener already is removed. @param registrationId ID of th

Removes the specified MembershipListener. <p> If the same MembershipListener is registered multiple times, it needs to be removed multiple times. Thi

Removes the specified map partition lost listener. <p> Returns silently if there is no such listener was added before. @param id ID of registered lis

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

Called when a partition replica migration is failed. @param event the event for the partition replica migration

Resets the record store to it's initial state. Used in replication operations.