Returns true only if the member is the last known master by {@code InternalPartitionServiceImpl} and {@code ClusterServiceImpl}. <p> Last known master

Returns whether event involves primary replica migration. @param event migration event @return true if migration involves primary replica, false othe

Returns whether time-based purging is enabled for this CPMap. @return {@code true} if purge is enabled, {@code false} otherwise @see #setPurgeEnabled

Tells whether {@link #setSplitBrainProtection(boolean) split brain protection} is enabled.

@return {@code true} if statistics gathering is enabled on the executor task (default), {@code false} otherwise

@return {@code true} if statistics gathering is enabled on the executor task (default), {@code false} otherwise

Returns whether this node represents a scalar value. @return false if this is an array or object, true otherwise

@param version other version to compare to @return {@code true} if this version is unknown or if this version is less than or equal to {@code version}

@return true, if the job has been cancelled based on a user request, false otherwise (also while the job is running).

Iterable for the single specified partition {@link ICache} @param fetchSize batch fetching size @param partitionId partition ID of the entrie

Starts iteration on this storage starting from the given member using the given iterator. @param member the member to start the iteration from. @pa

Returns a sink that publishes messages to Apache Kafka topic(s). It transforms each received item to a {@code ProducerRecord} using the supplied mappi

@return key part 1 of current slot. @throws IllegalStateException if the cursor is invalid.

@return key part 2 of current slot. @throws IllegalStateException if the cursor is invalid.

Returns the clock time in milliseconds of the most recent read using this connection. @return the clock time of the most recent read

Converts a JSON string to a {@link Map}.

A stage-transforming method that adds a "map using Python" pipeline stage. Use it with {@code stage.apply(PythonService.mapUsingPython(pyConfig))}. Se

Bit mask used to compute the slot index.

Called when the migration process starts. A migration process consists of a group of partition replica migrations which are planned together. <p> When

Creates a new {@link ClientConfig} instance configured to use the provided {@link RoutingMode}. @param routingMode the {@link RoutingMode} to use for

Starts a new open source {@link HazelcastInstance} of the given version. @param version the version string e.g. "3.8". Must correspond to a released

Creates a new instance of {@link BackupAccessor} for a given map. <p> It access a first backup replica. @param cluster all instances in the cluster @

Returns a new observable with a randomly generated name @since Jet 4.0

Creates a new ThreadAffinity based on a system property. If no property is set, then affinity is disabled. @param property the name of the system pr

Divide value by factor, take the smallest integer greater than or equal to the result, multiply that integer by factor, and return it. @param value

We make sure that this method can not be called from multiple threads per invocation at the same time Only ones that can set a null on `sentConnection

Reconstructs a {@link ScheduledTaskHandler} from a URN String. @param urn The URN of the handler as retrieved from {@link #toUrn()} @return A {@link

Called when an error was detected. @param channel the Channel that ran into an error. It could be that the Channel is null if error

Selects a member when one of the selectors succeed @param selectors {@link MemberSelector} instances to iterate @return a {@link MemberSelector} that

Returns the path of the node from the root of the YAML structure. @return the path of the node

Polls a single item or null if no items available. @return the polled item or null.

Polls pending MC events. @return polled events

Assign a discriminator to each scan in the plan. This is essentially hack to make the scans unique. We need this because in the MEMO structure, the pl

Validates, verifies, and maps {@code properties} with the given {@code propertyDefinitions}. @param properties properties from the Hazelcast

Returns an operation to replicate service data and/or state for a specific partition replica on another cluster member. <p> This method will be called

Projection with optional filter predicate for a single row. Returns {@code null} if the row is rejected by the predicate.

Publishes all messages asynchronously to all subscribers of this topic. @param messages the messages to publish asynchronously to all subscribers of

This method will create a wrapper object using the given {@link CacheEntryView} and place it to wan replication queues. <p> Cache operations which rem

Associates the specified value with the specified key in the cache using a custom {@link javax.cache.expiry.ExpiryPolicy}. @param key The ke

Associates the supplied value with the supplied tag. The tag must not be {@code null}, but the value may be, and in that case the tag will be associat

{@inheritDoc}

Writes the char value as volatile to given object by its offset. @param address address to access @param x the char value to be written

Writes the double value as volatile to given object by its offset. @param address address to access @param x the double value to be written

Writes the float value as volatile to given object by its offset. @param address address to access @param x the float value to be written

Removes the mapping for a key from this cache if it is present. <p> More formally, if this cache contains a mapping from key <tt>k</tt> to value <tt>v

Writes the int value as volatile to given object by its offset. @param address address to access @param x the int value to be written

Writes the long value as volatile to given object by its offset. @param address address to access @param x the long value to be written

Writes the short value as volatile to given object by its offset. @param address address to access @param x the short value to be written

Fills a buffer from an {@link InputStream}. If it doesn't contain any more data, returns {@code false}. If it contains some data, but not enough to fi

Reads a 16-bit two's complement signed integer. <p> This method can also read a nullable int16, as long as it is not {@code null}. If a {@code null} v

Reads a value of a static field. In case of any exceptions it returns null.