Returns a BufferObjectDataOutput back to the pool. The implementation is free to not return the instance to the pool but just close it. @param out t

The indices of the fields from the right side of a join which are equi-join keys. The indices refer to fields of right table before applying projectio

Executes a {@link Callable} on a specific partition thread and returns a result. <p> This does <b>not</b> check if a given Hazelcast instance owns a s

Runs the given log action, or ignores it based on the `frequentLogPeriod` and `suppressLimit` parameters. The log action is first called N times up to

Normally, the {@code complete()} method is run repeatedly until it returns {@code true}. This is suitable for processors processing the input or for b

Runs the provided {@link Runnable} with the {@code Namespace} context of the {@code Namespace} context defined by the provided Namespace name if avail

Schedules the queue for destruction if the queue is empty. Destroys the queue immediately if the queue is empty and the {@link QueueConfig#getEmptyQue

Prepares a {@link HttpURLConnection#HTTP_BAD_REQUEST} response.

Send a response to the replica to retry the replica sync

Set the property to a {@code newValue}. @param propertyName system property to set @param newValue value to set @return instance of the rule

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 CP member priority. CP groups' leadership will be transferred to members with higher priorities within the CP group. @param cpMemberPriority

Set classname of a class to be used as {@link javax.cache.integration.CacheLoader}. @param cacheLoader classname to be used as {@link javax.cache.int

Set classname of a class to be used as {@link javax.cache.integration.CacheWriter}. @param cacheWriter classname to be used as {@link javax.cache.int

Sets the capacity of the ringbuffer. @param capacity the capacity @return the updated Config @throws java.lang.IllegalArgumentException if capacity s

If true, the database and collection existence checks will be performed on every reconnection.

Sets the class name of the Predicate. <p> If an implementation or sql was set, it will be removed. @param className the name of the class of the Pred

Configures the {@link CloseListener}. <p/> Can only be configured once. <p/> This call is thread safe. <p/> If the method is called when the socket al

Logical name that identifies and provides a namespace for the particular database server/cluster being monitored. The logical name should be unique ac

Set {@code true} to enable coalescing, otherwise set {@code false}. This setting is only valid if {@code QueryCacheConfig#delaySeconds} is greater tha

Sets the strategy for checking consistency of data between source and target cluster. Any inconsistency will not be reconciled, it will be merely repo

Sets the {@link WanConsumerConfig WAN consumer configuration} for this WAN replication. The WAN consumer is in charge of consuming (processing) incomi

Sets the period in seconds in which WAN tries to discover new target endpoints and reestablish connections to failed endpoints. @param discoveryPerio

Sets the period in milliseconds at which the windowed aggregation stage will emit partial results of all the windows that contain some data, but the w

Enables or disables the multicast discovery mechanism @param enabled {@code true} to enable, {@code false} to disable @return the updated MulticastCo

Sets the Persistence Encryption at Rest configuration. @param encryptionAtRestConfig the Encryption at Rest configuration @return PersistenceConfig

Sets the {@link IcmpFailureDetectorConfig}. The value can be {@code null} if this detector isn't needed. @param icmpFailureDetectorConfig the IcmpFai

Sets the maximum duration in nanoseconds that the WAN replication thread will be parked if there are no events to replicate. @param idleMaxParkNs max

Sets the minimum duration in nanoseconds that the WAN replication thread will be parked if there are no events to replicate. @param idleMinParkNs min

Sets the initial publisher state. @param initialPublisherState the state @return this configuration

Set the list of item listener configurations for this queue. @param listenerConfigs the list of item listener configurations to set for this queue @r

Sets the maximum number of WAN event batches being sent to the target cluster concurrently. <p> Setting this property to anything less than {@code 2}

Sets the maximum capacity of the {@link com.hazelcast.cp.CPMap}. @param maxSizeMb capacity of the {@link com.hazelcast.cp.CPMap} in MB @throws Illega

Sets the maximum number of endpoints that WAN will connect to when using a discovery mechanism to define endpoints. This property has no effect when s

Sets the server socket endpoint config for {@link ProtocolType#MEMCACHE memcache} protocol. If another {@code ServerSocketEndpointConfig} was previous

Sets the {@code MerkleTreeConfig} for this {@code MapConfig} @param merkleTreeConfig merkle tree config @return this {@code MapConfig} instance

Sets the percentage of native memory space to be used to store metadata and internal memory structures by the native memory manager. <p> <strong>This

Sets the minimum memory block size, in bytes, to be served by native memory manager. Allocation requests smaller than minimum block size are served wi

Sets the name of {@code QueryCache}. @param name the name of {@code QueryCache} @return this {@code QueryCacheConfig} instance

Sets the name of this WAN replication config. This name is used by the {@link WanReplicationRef} configuration. @param name the WAN replication confi

If {@code true}, previously assigned values for the affected keys will be sent to this cache entry listener implementation. Setting this attribute to

@param persistWanReplicatedData set {@code true} to enable persistence of replicated data into backing store, otherwis

Sets the logical timestamp for the given {@code replicaId}. This method is not thread safe and concurrent access must be synchronized externally. @par

Sets the delay after which auto-scaled jobs will restart if a new member is added to the cluster. The default is 10 seconds. Has no effect on jobs wit

Optional regular expressions that match schema names to be monitored ("schema" is used here to denote logical groups of tables). Any schema name not i

Sets the security configuration for this hazelcast instance. This includes configuration for security interceptors, permissions, etc. @param security

Sets if key-based coalescing is configured for this WAN publisher. When enabled, only the latest {@link WanEvent} of a key is sent to target. @return

Set the maximum number of TCP keep-alive probes to send before giving up and closing the connection if no response is obtained from the other side. Va

Set the number of seconds a connection needs to be idle before TCP begins sending out keep-alive probes. Valid values are 1 to 32767. <p/> This option

Set the number of seconds between keep-alive probes. Notice that this is the number of seconds between probes after the initial {@link #setSocketKeepI

Sets sql string for this config. <p> If a className or implementation was set, it will be removed. @param sql sql string for this config @return this

Set to enable/disable map level statistics for this map. <p> This setting is only for map level stats such as last access time to map, total number of

If {@code true}, this cache entry listener implementation will be called in a synchronous manner. @param synchronous {@code true} to have this cache

Optional regular expressions that match fully-qualified table identifiers for tables to be monitored; any table not included in the whitelist will be

Establish this tenant's thread-local context. The implementation can control the details of what kind of context to set and how to establish it. @ret

Sets the path of the resource @param url the path of the resource

Sets whether the WAN connection manager should connect to the endpoint on the private address returned by the discovery SPI. By default, this property

Decides whether the public or private IP should be used to connect to Hazelcast members. @param usePublicIp {@code true} for public IP, {@code false}

Setting {@link #writeCoalescing} is meaningful if you are using write-behind {@link MapStore}. <p> When {@link #writeCoalescing} is {@code true}, only

Decides if the OutOfMemoryError thrown will be handled by this OutOfMemoryHandler or not. If <code>true</code> is return, {@link #onOutOfMemory(OutOfM

Shutdown all instances started by this factory.

Return the number of partitions in the set.