Converts given bson timest1amp to unix epoch.

Sets the localParallelism for the Processor @param localParallelism localParallelism, defaults to 1

Sets the localProcessorIndex for the Processor @param localProcessorIndex localProcessorIndex, defaults to 0

Locates the configuration file in the working directory. @return true if the configuration file is found in the working directory @throws HazelcastEx

Locates the configuration file on the classpath. @return true if the configuration file is found on the classpath @throws HazelcastException if there

Validates the requested cluster state change and sets a {@code ClusterStateLock}.

Acquires the lock unless the current thread is {@linkplain Thread#interrupt interrupted}. <p> When the caller already holds the lock and the current l

Return the log 2 result for this int. @param value the int value @return the log 2 result for value

Logs a warning if the {@code member} hasn't sent a heartbeat in {@link #HEART_BEAT_INTERVAL_FACTOR} heartbeat intervals and there is no live connectio

Logs metadata about the instance to the configured instance tracking output.

Returns a {@link StreamSource} that emits an ever-increasing sequence of {@code Long} numbers with native timestamps that are exactly the same amount

Looks up the User Code Namespace name associated with the specified set name. This starts by looking for an existing {@link ListContainer} and checkin

Looks up the User Code Namespace name associated with the specified set name. This starts by looking for an existing {@link SetContainer} and checking

Looks up the User Code Namespace name associated with the specified reliable topic name. This is done by checking the Node's config tree directly. @p

Looks up the User Code Namespace Name associated with the specified map name. This starts by looking for an existing {@link RingbufferContainer} and c

If the queue is full, try to flush some items. Return true, if there's some space in the queue after this call.

Same as {@link #mapJournal(String, JournalInitialPosition)}, but returns {@link JournalSourceEntry}, which provides information about whether dropped

Asynchronous version of {@link #mapUsingServiceP}: the {@code mapAsyncFn} returns a {@code CompletableFuture<R>} instead of just {@code R}. <p> The fu

Marks the passed {@link Address} as unhealthy, which prevents it from being offered as a viable endpoint in some {@link DiscoveryStrategy} implementat

Marks this CRDT as migrated. A migrated CRDT can no longer be mutated. For this CRDT to be marked as migrated, the provided {@code vectorClock} must b

Marks the given partition as unindexed by the given indexes. @param partitionId the ID of the partition to mark as unindexed. @param indexes the

Marks the replication status of the schema as {@link SchemaReplicationStatus#REPLICATED}. <p> It assumes that there is already a replication registere

Get the current master ID. @throws IllegalStateException if the master isn't known

Returns an aggregate operation that computes the greatest item according to the given {@code comparator}. <p> This sample takes a stream of people and

Selects the value of either the merging or the existing {@link MergingValue} which should be merged. <p> Note that the existing {@link MergingValue} i

Merge the two HyperLogLog structures in one. Estimations from both are taken into consideration and the unified estimate should be similar to the dist

Merges the source YAML document into the target YAML document <p> If a given source node is not found in the target, it will be attached If a given so

Configures the function to extract IDs from the messages, if exactly-once guarantee is used. If a lower guarantee is used, this function is not used.

Private API. Use {@link SourceProcessors#readFilesP} instead.

Use {@link SinkProcessors#writeJdbcP}.

Don't modify the returned list!