com.hazelcast.jet.core

Class JetProperties

java.lang.Object

com.hazelcast.jet.core.JetProperties

public final class JetProperties
extends Object

Defines the names and default values for internal Hazelcast Jet properties.

Since:

Jet 3.2

Field Summary

Fields

Modifier and Type	Field and Description
static HazelcastProperty	JET_IDLE_COOPERATIVE_MAX_MICROSECONDS The maximum time in microseconds the cooperative worker threads will sleep if none of the tasklets made any progress.
static HazelcastProperty	JET_IDLE_COOPERATIVE_MIN_MICROSECONDS The minimum time in microseconds the cooperative worker threads will sleep if none of the tasklets made any progress.
static HazelcastProperty	JET_IDLE_NONCOOPERATIVE_MAX_MICROSECONDS The maximum time in microseconds the non-cooperative worker threads will sleep if none of the tasklets made any progress.
static HazelcastProperty	JET_IDLE_NONCOOPERATIVE_MIN_MICROSECONDS The minimum time in microseconds the non-cooperative worker threads will sleep if none of the tasklets made any progress.
static HazelcastProperty	JOB_RESULTS_MAX_SIZE Maximum number of job results to keep in the cluster, the oldest results will be automatically deleted after this size is reached.
static HazelcastProperty	JOB_RESULTS_TTL_SECONDS Maximum number of time in seconds the job results will be kept in the cluster.
static HazelcastProperty	JOB_SCAN_PERIOD Jet will periodically check for new jobs to start and perform cleanup of unused resources.
static HazelcastProperty	PROCESSOR_CUSTOM_LIB_DIR The directory containing jars, that can be used to specify custom classpath for a stage in a pipeline.

Method Summary

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

JOB_SCAN_PERIOD

public static final HazelcastProperty JOB_SCAN_PERIOD

Jet will periodically check for new jobs to start and perform cleanup of unused resources. This property configures how often this check and cleanup will be done. Value is in milliseconds.

Since:

Jet 3.2

JOB_RESULTS_TTL_SECONDS

public static final HazelcastProperty JOB_RESULTS_TTL_SECONDS

Maximum number of time in seconds the job results will be kept in the cluster. They will be automatically deleted after this period is reached.

Default value is 7 days.

Since:

Jet 3.2

JOB_RESULTS_MAX_SIZE

public static final HazelcastProperty JOB_RESULTS_MAX_SIZE

Maximum number of job results to keep in the cluster, the oldest results will be automatically deleted after this size is reached.

Default value is 1,000 jobs.

Since:

Jet 3.2

JET_IDLE_COOPERATIVE_MIN_MICROSECONDS

public static final HazelcastProperty JET_IDLE_COOPERATIVE_MIN_MICROSECONDS

The minimum time in microseconds the cooperative worker threads will sleep if none of the tasklets made any progress. Lower values increase idle CPU usage but may result in decreased latency. Higher values will increase latency and very high values (>10000µs) will also limit the throughput.

The default is value is 25µs.

Note: the underlying LockSupport.parkNanos(long) call may actually sleep longer depending on the operating system (up to 15000µs on Windows). See the Hazelcast blog post about this subject for more details.

See also: JET_IDLE_COOPERATIVE_MAX_MICROSECONDS

Since:

Jet 3.2

JET_IDLE_COOPERATIVE_MAX_MICROSECONDS

public static final HazelcastProperty JET_IDLE_COOPERATIVE_MAX_MICROSECONDS

The maximum time in microseconds the cooperative worker threads will sleep if none of the tasklets made any progress. Lower values increase idle CPU usage but may result in decreased latency. Higher values will increase latency and very high values (>10000µs) will also limit the throughput.

The default is value is 500µs.

Note: the underlying LockSupport.parkNanos(long) call may actually sleep longer depending on the operating system (up to 15000µs on Windows). See the Hazelcast blog post about this subject for more details.

See also: JET_IDLE_COOPERATIVE_MIN_MICROSECONDS

Since:

Jet 3.2

JET_IDLE_NONCOOPERATIVE_MIN_MICROSECONDS

public static final HazelcastProperty JET_IDLE_NONCOOPERATIVE_MIN_MICROSECONDS

The minimum time in microseconds the non-cooperative worker threads will sleep if none of the tasklets made any progress. Lower values increase idle CPU usage but may result in decreased latency. Higher values will increase latency and very high values (>10000µs) will also limit the throughput.

The default is value is 25µs.

Note: the underlying LockSupport.parkNanos(long) call may actually sleep longer depending on the operating system (up to 15000µs on Windows). See the Hazelcast blog post about this subject for more details.

See also: JET_IDLE_NONCOOPERATIVE_MAX_MICROSECONDS

Since:

Jet 3.2

JET_IDLE_NONCOOPERATIVE_MAX_MICROSECONDS

public static final HazelcastProperty JET_IDLE_NONCOOPERATIVE_MAX_MICROSECONDS

The maximum time in microseconds the non-cooperative worker threads will sleep if none of the tasklets made any progress. Lower values increase idle CPU usage but may result in decreased latency. Higher values will increase latency and very high values (>10000µs) will also limit the throughput.

The default is value is 5000µs.

Note: the underlying LockSupport.parkNanos(long) call may actually sleep longer depending on the operating system (up to 15000µs on Windows). See the Hazelcast blog post about this subject for more details.

See also: JET_IDLE_NONCOOPERATIVE_MIN_MICROSECONDS

Since:

Jet 3.2

PROCESSOR_CUSTOM_LIB_DIR

public static final HazelcastProperty PROCESSOR_CUSTOM_LIB_DIR

The directory containing jars, that can be used to specify custom classpath for a stage in a pipeline. The default value is `custom-lib`, relative to the current directory.

Since:

5.0