Returns the address of this CP member. It is same with the address of {@link Cluster#getLocalMember()}. <p> This Address can be changed, and the CP me

Returns the key of the entry. @return the key of the entry

Puts (associates) a value with the given {@code key}. @param key the key of the value will be stored @param keyData the key as {@link Data} o

Gets the value associated with {@code key} @param key non-null key of the entry @return null if {@code key} had no association, otherwise the value as

Returns the Cluster that this Hazelcast instance is part of. Cluster interface allows you to add a listener for membership events and to learn more ab

Returns the ID of this job.

Creates or returns the distributed queue instance with the specified name. @param name name of the distributed queue @param <E> queue item type @retu

Obtains a {@link ILogger logger} for the given {@code clazz}. @param clazz the class to obtain the logger for. @return the obtained logger.

Returns the ID of the partition. This value will never change and will always be greater to or equal to 0 and smaller than the partition-count. @retu

@param fieldName name of the field @return the long value read @throws IOException in case of any exceptional case

Adds a {@link MapListener} for this map. <p> To receive an event, you should implement a corresponding {@link MapListener} sub-interface for that even

Returns the first instance.

Shuts down this HazelcastInstance. For more information see {@link com.hazelcast.core.LifecycleService#shutdown()}.

Returns elements of the given {@code coll} in a new {@code List}, mapped using the given {@code mapFn}.

Returns a descriptive name for this sink.

Returns the {@link JoinConfig}. @return the join

Gets the name that identifies this metric. The returned value will never change and never be null. @return the name of the metric.

Stops the database

This method takes the unparsed argument object as an input and returns the parsed output that will be used by the {@link ValueExtractor}. @param inpu

Builds the {@link AsyncSocket}. @return the opened AsyncSocket. @throws IllegalStateException when the builder isn't properly configured or when

Writes an outbound frame, so it can be received by the other side of the connection. No guarantees are made that the frame is going to be received on

Reads the current available value as a long. If the underlying probe provides a double value, then the value will be rounded using {@link Math#round(

Returns class loader that internally used for objects. @return classLoader

Returns the current time in ms for the configured {@link ClockImpl}

Returns a unique UUID for this client. @return a unique UUID for this client

Creates a new HazelcastInstance (a new node in a cluster). This method allows you to create and run multiple instances of Hazelcast cluster members on

{@inheritDoc} <p> <b>Warning 1:</b> <p> This method returns a clone of the original value, so modifying the returned value does not change the actual

Writes a primitive boolean. @param fieldName name of the field @param value int value to be written @throws IOException in case of any exceptiona

Non-boxing variant of next().

@since Jet 3.0 @deprecated Use {@link HazelcastInstance#getCacheManager()} instead.

@param fieldName name of the field @return the boolean value read @throws IOException in case of any exceptional case

Appends a new member to the end of this object, with the specified name and the JSON representation of the specified <code>int</code> value. <p> This

Initialize the given object instance. This is intended for repopulating select fields and methods for deserialized instances. It is also possible to p

Gets the count of stored records. @return the count of stored records

Release the resources associated with the query result. <p> The query engine delivers the rows asynchronously. The query may become inactive even befo

Retrieves and removes the head of this inbox, or returns {@code null} if it is empty.

Returns a traverser over the given single item. <p> You can use {@link ResettableSingletonTraverser} for less GC litter, if you can reuse the traverse

Creates or returns the distributed multimap instance with the specified name. @param name name of the distributed multimap @param <K> type of the mul

Called after all the inbound edges' streams are exhausted. If it returns {@code false}, it will be invoked again until it returns {@code true}. For ex

Assigns the partition owners of the given Hazelcast instances. @param instances the given Hazelcast instances

Creates an <b>always true</b> predicate that will pass all items. @param <K> the type of keys the predicate operates on. @param <V> the type of values

Gets the value associated with the given {@code key}. @param key the key of the requested value @return the value associated with the given {@code ke

Returns the time in nanoseconds from when this NanoClock was created. @return the time in nanoseconds.

{@inheritDoc} <p> <b>Warning 1:</b> <p> This method uses {@code hashCode} and {@code equals} of the binary form of the {@code key}, not the actual imp

Checks if the {@link Level#FINEST} level is enabled. @return true if enabled, false otherwise

Sets the preferred local parallelism (number of processors per Jet cluster member) this stage will configure its DAG vertices with. Jet always uses th

Begins a transaction. @throws IllegalStateException if a transaction already is active.

Makes a copy (or clone) of the config object.

@return name of sql catalog object.

Uses {@code formatFn} to stringify each item of the given stream, sorts the strings, then outputs them line by line. <p> If you supply the optional {@

Filters a packet inspecting its content and/or endpoint and decides whether this packet should be filtered. @param endpoint target endpoint which pac

Checks that the {@code object} implements {@link Serializable} or {@link DataSerializable}. In case of {@code Serializable}, it additionally checks it

Produces a result set containing entries whose attribute values are equal to the given value. @param value the value to compare against. @return the

Opens cache if available (not destroyed). If cache is already open, does nothing. @throws IllegalStateException if cache is already destroyed

Commits a transaction. @throws TransactionException if no transaction is active or the transaction could not be committed.

@return the return query data type of this expression.

Convenient method to add an index to this map with the given type and attributes. Attributes are indexed in ascending order. <p> @param type In

Adds an edge to this DAG. The vertices it connects must already be present in the DAG. It is an error to connect an edge to a vertex at the same ordin

Returns the name of the service

Creates a predicate that will pass items that match the given SQL 'where' expression. The following operators are supported: {@code =}, {@code <}, {@c