@param factoryId factory ID of portableFactory to be registered @param portableFactoryClass portableFactory class to be registered @return

Adds a ClientReliableTopicConfig. @param reliableTopicConfig the ClientReliableTopicConfig to add @return configured {@link com.hazelcast.client.conf

Returns an aggregate operation that is a composite of two independent aggregate operations, each one accepting its own input. You need this kind of op

Returns a supplier of processors for a vertex that aggregates events into a sliding window in a single stage (see the {@link Processors class Javadoc}

Checks if migration tasks are allowed. This can include partition state and partition data sync tasks. The migration is not allowed during membership

Takes a generic {@link YamlNode} instance and returns it cast to {@link YamlScalar} if the type of the node is a descendant of {@link YamlScalar}. @p

Takes a generic {@link YamlNode} instance and returns it cast to {@link YamlSequence} if the type of the node is a descendant of {@link YamlSequence}.

Asserts that the previous stage emitted all of the given items in any order. If the assertion fails, the job will fail with an {@link AssertionError}

Asserts that no errors were raised in processor's init and close methods. Such errors normally are being "eaten" by the framework, so won't cause typi

@param allowedSnapshotsCount snapshot id that should be used to restore or -1 if the job should not be restored

Returns an aggregate operation that finds the arithmetic mean (aka. average) of the {@code long} values it obtains by applying {@code getLongValueFn}

Returns a file format for Avro files.

Awaits successful initialization; if the initialization fails, throws an exception.

Returns an edge between two vertices. The ordinal of the edge is 0 at both ends. Equivalent to {@code from(source).to(destination)}. @param source

Returns current count of bytes read from the Channel. The read values might not reflect the most recent value. @return count of read bytes

Indicates if the plugin can be enabled at runtime. @return true if the plugin can be enabled at runtime, false otherwise.

Cancel all scheduled executions

Cancels the scheduled executions for the given key and value if present. The method returns the number of cancelled scheduled entries. @param key t

Catches metric value from a source object with a {@link ProbeFunction}. @param collectionId The identifier of the metric collection cycle

Change cluster state, if current state is not already the desired one. Retries up to 3 times. The cluster state change is transient, so if persistence

Validates the given {@link CacheSimpleConfig}. @param cacheSimpleConfig the {@link CacheSimpleConfig} to check @param mergePolicyProvider the {@lin

Says whether the given integer is valid as the value of {@link #localParallelism(int) localParallelism}.

Checks if the provided {@code mergeTypes} satisfy the requirements of a given merge policy. @param mergeTypes the provided merge types @par

Gets a child scalar node by its name @param name the name of the child node @return the child scalar node with the given name if exists, {@code null}