Notifies the service of a published event. @param event the published event @param listener the listener registered for this event

Main entry point for filtering events according to given filter. @param filter the event filter @param dataKey the event entry key @para

Move all items from all queues (except the snapshot queue) to the {@code target} list of collections. Queue N is moved to collection at target N etc.

Deserialize and move all items from the snapshot queue to the {@code target} collection and make the outbox available to accept more items. Also calls

Called by the drainer thread to signal that it is done draining the queue.

Picks right empty collection type, like {@link java.util.Collections#emptySet()} or {@link java.util.Collections#emptyList()} )} depending on the {@li

Retrieves POD addresses from the specified {@code namespace} and the given {@code endpointName}. @param endpointName endpoint name @return all POD ad

Checks the provided long and double values for equality. <p> The method fully avoids magnitude and precision losses while performing the equality chec

Describes the error that has led to the suspension of the job. Throws {@link UnsupportedOperationException} if job was not suspended due to an error.

Escapes the vertex name for graphviz by prefixing the quote character with backslash.

Returns the Eventloop for this {@link Reactor}. <p/> This method is thread-safe. But Eventloop should only be touched by the Eventloop thread because

Executes the task on every partition thread. @param task the task the execute. @throws java.lang.NullPointerException if task is null.

Returns {@code true} if local member is the caller. <p> <b>Note:</b> On the caller member this method always returns {@code true}. It's meant to be us

Checks if the key exist in memory without trying to load data from map-loader

Checks if EC2 environment was explicitly configured in the Hazelcast configuration. <p> Hazelcast may run inside ECS, but use EC2 discovery when: <ul>

Returns the map name in which an exported snapshot with the given `name` is stored. It's {@code "_jet.exportedSnapshot.<name>"}.

Returns a map of per-table candidates, structured as mapName -> [columnName -> RexLiteralOrDynamicParam] where every innermost map represents a single

@return extracted {@code PartitionAwareOperationFactory} from supplied operation factory or null

Activates the {@link RoutingPolicy#FANOUT FANOUT} routing policy. @since Jet 4.4

Returns the key name in the form {@code file.<id>}

Returns a read-only {@link IMap} configuration for the given name. <p> The name is matched by pattern to the configuration and by stripping the partit

Finds existing Reliable Topic config. @param name name of the config @return Reliable Topic config or {@code null} when requested Reliable Topic conf

Extract the JsonValue that is stored in attributePath in input. This method validates expectedPattern using attributePath while extraction. If expecte

Returns the frame offset. For example, with {@code frameLength = 10} and {@code frameOffset = 5} the frames will start at 5, 15, 25...

Transforms the provided {@link JsonObject} int a map of name/value pairs. @param object the JSON object @return map from JSON name to value

Called to create a mapping from member {@link Address} to the {@link ProcessorSupplier} that will be sent to that member. Jet calls this method with a

Obtains a list of {@link IndexRegistry} for the given map local to the node associated with it. <p> There may be more than one indexes instance associ

@return the associated {@link MemoryAllocator}

Updates the PN counter state for this replica and returns the value before the update. The {@code delta} parameter must be greater than or equal to 0.

Gets the number of synchronous backups. @return number of synchronous backups