@return serialization service

Returns the number of update operations performed on the index.

Creates a <b>greater than</b> predicate that will pass items if the value stored under the given item {@code attribute} is greater than the given {@co

Creates a {@link GenericRecordBuilder} allows to create a new object. This method is a convenience method to get a builder, without creating the schem

Reads a list from the given {@link ObjectDataInput}. It is expected that the next int read from the data input is the list's size, then that many obje

Associates the specified value with the specified key. The mapping will be available to the job while it's executing in the Jet cluster. @param key k

Sets the maximum size of the Queue. @param maxSize set the maximum size of the Queue to this value @return the Queue configuration @throws IllegalArg

For the client side, the jar is uploaded to a random cluster member and then this member runs the main method to start the job. The jar should have a

@see Short#toUnsignedInt(short)

Adds an interceptor for this map. <p> Added interceptor will intercept operations and execute user defined methods. They will cancel operations if the

Returns the breadth-first order of the leaf that a given {@code hash} belongs to @param hash The hash for which the leaf order to be calculated @par

Returns the total number of Other Operations @return number of other operations

Returns the class name of the {@link SplitBrainMergePolicy}. @return the class name of the merge policy

Creates or returns the reliable topic instance with the specified name. @param name name of the reliable topic @param <E> the type of the topic messa

Returns the ReplicatedMapConfig for the given name, creating one if necessary and adding it to the collection of known configurations. <p> The configu

Returns the type of membership change. @return membership event type

Returns true, if the job is user-cancelled. Returns false, if it completed normally or failed due to another error. Jobs running in clusters before ve

Returns a source that fetches entries from a local Hazelcast {@code IMap} with the specified name and emits them as {@code Map.Entry}. It leverages da

Offers the item to the outbox bucket at the supplied ordinal. <p> Emitted items should not be subsequently mutated because the same instance might be

Returns a tumbling window definition with the given parameters. In a tumbling window the incoming items are grouped by fixed size, contiguous and non-

Declares that the stream will use the source's native timestamps. This is typically the message timestamp that the external system assigns as event's

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

Adds an index attribute with the given. @param attribute Attribute name. @return This instance for chaining.

Adds a new item to the list or votes for the given item if it already exists. If the {@link #maxSize} is reached, half of the list is removed. <p> Whe

Returns this JSON value as {@link JsonArray}, assuming that this value represents a JSON array. If this is not the case, an exception is thrown. @ret

@return compact serialization config @since 5.2

Returns the per-index statistics map keyed by the index name.

Returns the number of insert operations performed on the index.

@return Index name.

@return config object used by {@link NearCache} instance.

Returns the address of the owner of this partition. <p> If no owner has been set yet, null is returned. So be careful with assuming that a non {@code

Get current configuration of User Code Deployment. @return User Code Deployment configuration @since 3.8

Invokes an {@link Operation} on the specified {@code target} member, on behalf of the service defined by the provided {@code serviceName}, expecting a

Predicate to compare expected and actual output. Parameters to the {@code BiPredicate} are the list of expected items and the list of actual processor

Same as {@link #put(Object, Object, long, TimeUnit)} except that the map store, if defined, will not be called to load/store/persist the entry. <p> Th

Code to run at this step by using the provided state

Sets if local entries are also cached in the Near Cache. <p> This is useful when the in-memory format of the Near Cache is different from the backing

Tries to put the given key and value into this map within a specified timeout value. If this method returns false, it means that the caller thread cou

Returns the union of two MetricTarget collections as a Set. Set objects are returned from a preliminary warmed up cache, so this method has no memory

Updates the existing entry mapping in this index by remapping it from the given old value to the new given value. <p> The update operation is logicall

Validates the given value according to the defined validation logic and throws a ValidationException if configuration does not meet the requirements o

Declares that the source will assign the time of ingestion as the event timestamp. It will call {@code System.currentTimeMillis()} at the moment it ob

Writes a list to an {@link ObjectDataOutput}. The list's size is written to the data output, then each object in the list is serialized. @param items

Adds a new {@link QueryCacheConfig} to this {@code MapConfig}. @param queryCacheConfig the config to be added @return this {@code MapConfig} instance

Registers the {@link AggregateOperation#combineFn() combine} primitive. <p> The given function must be stateless and {@linkplain Processor#isCooperati

Returns a given key as a broadcast key. <p> Note: Several processor instances can use the returned {@code BroadcastKey} with the same {@code key} to s

A primitive that transforms the accumulator into a result of the aggregation. Unlike {@link #finishFn() finish} primitive, this operation must not: <u

Obtain the {@link ICacheManager} that provides access to JSR-107 (JCache) caches configured on a Hazelcast cluster. <p> Note that this method does not

Gets the index of the partition replica that current member owns currently, before migration starts. This index will be in range of [0,6] if current m

WARNING this method should not be called from static context.