A helper method that will return the {@link Set} of {@link Binary} keys for the elements that are contained in the specified bucket from the given bac

Return the {@link CachingScheme} for a given cache name. If the caching scheme is a near cache then return the back scheme. @param sName the cache

Finds document chunks across all stores matching the search criteria. <p/> This method performs parallel searches across all configured stores and agg

Based on the provided Annotation Class scan the resources this ClassAnnotationSeeker is scoped by its {@link Dependencies} and return a {@link List} o

Find a dead (recycled) member with the specified Id and UID.

Return a File representing the PackagerEntry by searching the CLASSPATH for a directory that contains the entry by pathname. Note: we use this ONLY t

Find the point at which a Node with the specified index would be inserted. <p> If the tree is empty then null is returned. If the index already exists

Find a cluster member that is running the MBeanServer. @param proxy the {@link MBeanServerProxy}. @return the member id of a cluster member that i

Return the {@link OPToken} mapped to the next token in the {@link OPParser}'s token stream. @param parser the OPParser providing the token stream @

Find method with the specified name and description. @param sName method name @param sDesc method description @return method with the specified na

Find a queue that is associated with the smallest number of WorkSlots and is different from the specified queue. This method should only be called whi

Given the passed key, determine if this Node or a child Node matches that key, and if so then return the associated Node. @param binKey the key to m

Find the {@link Session} instances with the given scope name across all {@link Coherence} instances. @param sScope the scope name of the {@link Sess

Return the current active span, or try to find the span in the current {@link Context}. @return the current active span, or try to find the span in t

Search the supplied member set and return the member which this member has the most issues communicating with or null if everyone is perfect.

Mark myself as finished.

Wait for the specified worker to finish starting. This method is called while the daemon is in the STARTING state. The caller must be synchronized on

Decrement the use count for this block and check if it is now zero.

A {@link Predicate} to determine if a result container can be finished early avoiding further accumulation of results using the container. <p> Should

Fire the vetoable change event for an attribute. Assumption is that most of the time there are zero listeners, occasionally there may be one listener

Add a transformer that converts first letter of the input string to uppercase to the chain. @return this {@code NameTransformerChain}

Create a default {@link Coherence} client instance, creating it if it does not already exist. <p> If using the default Coherence cache configuration f

Returns a {@link Builder} instance that can build a {@link Coherence} instance using the specified {@link CoherenceConfiguration}. <p> The {@link Cohe

Returns a stream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the prov

Returns a stream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the prov

Returns a stream consisting of the results of replacing each element of this stream with the contents of a mapped stream produced by applying the prov

Create a single dimensional array containing all elements of the specified array of arrays. @param aaoFrom an array of arrays to copy from @param cT

Flush the response. It may or may not be sent to the client immediately depending upon if there are pending responses ahead of this response. @param

Obtain a {@link CompletableFuture} that will be complete when all the currently outstanding operations complete. The returned {@link CompletableFuture

Called once the Ack has reached its capacity. When an Ack is flushed, some tracking information associated with the recipient member is added to the

Flushes the bytes accumulated by the write(int) method. @exception IOException if an I/O error occurs

Determine which cached entries are impacted by the updated jcs and remove them from the cache. We have to walk each cached entry's class hierarchy to

Flush cooperative poll notifications as a keyed-mailbox drainer reaches its idle boundary.

Flush cooperative poll notifications after a direct one-shot task or, when configured, after every wrapper execution.

Flush the event collector.

Obtain a {@link CompletableFuture} that will be complete when all the currently outstanding add operations complete. <p> If this method is called in r

Apply a function across each element in the bag. @param consumer the consumer

Performs an action for each element of this stream. <p> This is a <em>terminal operation</em>. @param action a non-interfering action to perform on t

Returns a {@link Comparator} that can sort {@link ServiceLoader.Provider} instances based on whether the class they provide is annotated with the {@li

Indicate the future write operations must be synchronous.

Returns a shared, Coherence-managed {@link ForkJoinPool} instance. <p> Parallelism (the number of FJP worker threads) defaults to the number of availa

Produce a label name. @return the label name

Format all of the fields of an object into a human readable string. This method is called recursively to format nested objects. @param oTarget the o

Helper method used for reporting.

Helper method for cluster name logging. @return a String containing a word 'cluster' optionally followed by the ClusterName property

Generate a log message containing the keys from the specified set of entries. @param setBinEntries set of {@link Entry Entries} @param sHeader

Create the formatted metric name @param sName the name to format @return the formatted metric name

Format an array of offsets to be readable in a dump. @param an the array of offsets @return a String containing the offsets in a readable fashion

Format a single field, recursing if the object doesn't declare toString() in the object itself (i.e. toString in all super objects is not checked). @

@param ach format into this char array @param nOffset the code offset being displayed @param cDecDigits the number of digits to display t

Convert the specified refresh policy value to a human-readable string. @param nPolicy refresh policy in integer format @return converted refresh po

@return a human-readible description of the given Service state

Return flow control statistics for communication between the local Member and the parent Member.

Return a human readable name for the specified status value. @param iStatus the status value to format @return a human readable status name

Format the passed String as UTF-8 into the passed byte array. @param s the String to format @param ab the byte array to format into @param of the of

Return the virtual-thread name prefix for a new worker.

Free this Entry block. Note that this has the effect of closing the block.

Create RawDateTime from the specified object. @param o an object to create RawDateTime from. @return a RawDateTime value @throws IllegalArgumentEx

Converts a byte array into a Base64 decoded string. @param ab byte array to decode @return Base64 decoding of buffer

Translate the passed Binary object into an Object object. @param bin the Binary object to deserialize @return the deserialized object

Convert the specified number of bits to units of this {@link Rate}. @param cBits The number of bits. @return The number of units of this {@link Ra

Create a {@link PublishResult} from a protobuf publish result. @param response the {@link TopicServiceResponse} containing the result @param seria

Create a {@link SubscriberId} from a {@link EnsureSubscriberResponse}. @param response the {@link EnsureSubscriberResponse} to obtain the subscriber

Convert a name from a REST standards compatible name to attribute name. @param sName the service name to be normalized @return the REST compatible

Populate the DefaultPeerDependencies object from the given XML configuration. @param xml the XML parent element that contains the child Peer elem

Populate the {@link TracingShim.Dependencies} object from the XML configuration. @param xml the {@code <tracing-config>} XML element @param deps t

Executes the various phases of generating a POF Configuration file. The following phases describe the lifecycle of this class: <ol> <li><b>ensureC

Generate a new unique Channel identifier. If the ConnectionManager that created this Channel is a ConnectionAcceptor, the returned value will be in t

For a given schema file name, return the full path the file will reside in. This method uses forward slash (/) as a path separator. @param sFileName

Generates a unique name for the interceptor. The unique name will be generated by appending a {@code '$'} following by an increasing integer. @return

Return the specified number of unique ports for this machine. @param cPort the number of unique ports to generate; must be <= 1 @return the specifi

{@inheritDoc}

Returns the value to which this map maps the specified key. Returns <tt>null</tt> if the map contains no mapping for this key. @param oKey key whos

Return the state for a service. @param sService the service name @return the service state, or {@code null}

Return the value stored at the specified index. @param lIndex a long index value @return the object stored at the specified index, or null

Find the specified key in the map and return the value associated with it. @param binKey a Binary key @return the value associated with the specifi

{@inheritDoc}