Returns true if the instance has started

@return true if current partition thread is executing this step runner now, false otherwise.

@return true if the calling thread is currently executing the {@link AbstractMessageTask#run()} method, false otherwise.

@param version other version to compare to @return {@code true} if this version is unknown or if this version is less than {@code version}

Indicates whether the event is generated by the user via {@link Job#suspend()}, {@link Job#resume()}, {@link Job#restart()}, {@link Job#cancel()}, {@l

Returns {@code true} if this operation is marked as a mutating operation. If this method returns {@code false}, the operation still might be mutating

Tests if the configuration file provided is a YAML file. The test is based on the file extension. @param configURL configuration URL to test. @return

Returns a batch source which iterates through the supplied iterable and then terminates. The source is distributed - a slice of the items is emitted o

Returns a streaming source that generates events created by the {@code generatorFn}s. It emits the data from different generators in parallel, but pre

{@inheritDoc}

Returns the job name of the job the snapshot was originally exported from.

Invoked upon job status change. <ol> <li> This listener observes that the status is transitioned to {@link JobStatus#SUSPENDED SUSPENDED}/{@link

A source to read all files in a directory in a batch way. The source expects the content of the files as <a href="https://en.wikipedia.org/wiki/JSON_s

Initiates the building of a sink that publishes messages into Amazon Kinesis Data Streams (KDS). <p> The basic unit of data stored in KDS is the <em>r

Adds {@code addend} to the counter, using {@code lazySet}. Useful for incrementing {@linkplain com.hazelcast.internal.metrics.Probe probes} if only on

@param backupCount number of backups of a maps' partition @return predicate to find all map partitions which are expected to have fewer backups than g

Maintains a watermark that lags behind the real time by the given amount. Doesn't consider the event timestamp at all. @param lag the desired differe

Returns an aggregate operation that computes a linear trend over the items. It will produce a {@code double}-valued coefficient that approximates the

Appends first before second step. <p> After append, new step execution order: <p>first step will be executed first, <p>second step will be executed se

Converts a list to a string putting {@code toString()} of each element on a separate line. It is useful to transform list inputs to {@code assertEqual

Triggers key and value loading if there is no ongoing or completed key loading task, otherwise does nothing. The actual loading is done on a separate

Get the load factor beyond which the map will increase size. @return load factor for when the map should increase size.

Get the load factor beyond which the map will increase size. @return load factor for when the map should increase size.

Unzips the JAR archive and processes individual entries using {@link #readStreamAndPutCompressedToMap(String, Map, InputStream)}.

Loads the keys into the Near Cache.

Loads value of key. If necessary loads it by extracting from {@link MetadataAwareValue} @return loaded value from map-store as a BiTuple which holds

@param o object to test, may be null @return <code>true</code> if o has been loaded by the current classloader or one of its descendants.