Returns event timestamp as milliseconds from the epoch. @return event timestamp in millis

Returns the {@link InboundPipeline} that belongs to this Channel. <p> This method is thread-safe, but most methods on the {@link InboundPipeline} are

Invokes the given {@link InvocationOnMock} and returns a non-proxied result. <p> This method is used to retrieve the result to create another mock. @

Returns whether persistence enabled on this member. @return true if persistence enabled, false otherwise

Checks if the {@link NearCacheConfig#isInvalidateOnChange()} of a {@link NearCacheConfig} is {@code true}. @param nearCacheConfig the {@link NearCach

Returns {@code true}, if joining of a new member is allowed in this state. @return {@code true} if joining of a new member is allowed in this state.

Returns true if the node with {@code nodeOrder} is a leaf in a tree with {@code depth} levels @param nodeOrder The order of the node to test @param d

Tests if an argument is not null. @param argument the argument tested to see if it is not null. @param argName the argument name (used in message if

Returns true if this Data is created from a {@link com.hazelcast.nio.serialization.Portable} object, false otherwise. @return true if source object i

@return {@code true} when recovery process is completed and all members reached final state, otherwise {@code false}.

Returns a file format for text files where each line is a {@code String} data item. It uses the UTF-8 character encoding.

If this instance uuid and its addresses has been registered before, it returns the addresses corresponding to this instance uuid. @param uuid instance

Lists all existing {@link NearCache} instances. @return all existing {@link NearCache} instances

Populates Hazelcast {@link ClientConfig} object from an external configuration file. <p> It tries to load Hazelcast Client configuration from a list o

Sets the number of processors corresponding to this vertex that will be created on each member. <p> If the value is {@value #LOCAL_PARALLELISM_USE_DEF

Acquires the lock. <p> When the caller already holds the lock and the current lock() call is reentrant, the call can fail with {@link LockAcquireLimit

Logs a message at the given level. @param level the log level @param message the message to log

This ExceptionHandler rethrows {@link java.util.concurrent.ExecutionException}s and logs {@link com.hazelcast.core.MemberLeftException}s to the log.

Set the function to map SearchHit to a pipeline item <p> For example, to map a SearchHit to a value of a field `productId`: <pre>{@code builder.mapToI

Marks the replication status of the schema as {@link SchemaReplicationStatus#PREPARED} if it is not marked yet. @param schema to set the status.

Returns a projection that extracts the value of the given {@code attributePaths}. The attribute values will be returned as an {@code Object[]} array f

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

Static factory to retrieve a type 4 (pseudo randomly generated) UUID. <p> The {@code UUID} is generated using a cryptographically strong pseudo random

Returns the partition assignment used by this job. This is the assignment partitioned edges will use and the assignment processors dealing with Hazelc

For each object that implements {@link StaticMetricsProvider} the {@link StaticMetricsProvider#provideStaticMetrics(MetricsRegistry)} is called. @par

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

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

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

@param name for the executor service @param poolSize the maximum number of threads to allow in the pool @param queueCapacity the queue t

Registers a local only listener. @param serviceName service name @param topic topic name @param listener listener instance @return event reg

Finish the pending operations and release the associated resources. If a transaction was begun, must not commit or roll it back, the transaction can b

{@code Serializable} variant of {@link Comparator#reversed() java.util.Comparator#reversed()}

Set the search request supplier function <p> The connector executes this search request to retrieve documents from Elasticsearch. <p> For example, to

Sends given String (as UTF-8) to the server. @see #sendData(byte[])

@return old value

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 the blacklist filter. @param blackList the blacklist filter to set @return this configuration

Sets the cursor buffer size (measured in the number of rows). <p> When a statement is submitted for execution, a {@link SqlResult} is returned as a re

Sets the full class name of the extractor in a String format, e.g. {@code com.example.car.SpeedExtractor}. @param extractorClassName the full class n

Sets the MemberGroupType. A @{link MemberGroupType#CUSTOM} indicates that custom groups are created. With the {@link MemberGroupType#HOST_AWARE} group

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 the maximum number of rolling files to keep on disk. The DiagnosticsLogFile uses a rolling file approach to prevent using too much disk space. <p

Sets the metadata policy. See {@link MetadataPolicy} for more information. @param metadataPolicy the metadata policy

Prepares an HTTP response with no content and the provided status line and response headers. @param statusCode the HTTP response status code @param h

Sets the server socket endpoint config for {@link ProtocolType#REST REST} protocol. If another {@code ServerSocketEndpointConfig} was previously set,

Only used for Hot Restart, HDRecord

Sets what happens if the job execution fails: <ul> <li> If enabled, the job will be suspended. It can later be {@linkplain Job#resume() resumed}

The maximum number of seconds for each entry to stay in the map. Entries that are older than timeToLiveSeconds will be automatically evicted from the

Shutdowns <tt>NodeExtension</tt>. Called on <tt>Node.shutdown()</tt> right after setting the state to PASSIVE.