Package com.hazelcast.jet.config

Class DeltaJobConfig

java.lang.Object

com.hazelcast.jet.config.DeltaJobConfig

All Implemented Interfaces:

DataSerializable, IdentifiedDataSerializable

public class DeltaJobConfig
extends Object
implements IdentifiedDataSerializable

Contains a configuration change for JobConfig. All options are initially unchanged, options for which the set-method is called will be changed when this delta is applied, others will be unaffected.

Contains only a subset of options - those that can be changed after the job was submitted.

Since:

5.3

See Also:

• Job.updateConfig(DeltaJobConfig)
• JobConfig

Constructor Summary

Constructors

Constructor	Description
DeltaJobConfig()

Method Summary

Modifier and Type	Method	Description
void	applyTo(JobConfig config)	Applies the changes represented by this instance to the specified configuration.
boolean	equals(Object o)
int	getClassId()	Returns type identifier for this class.
int	getFactoryId()	Returns DataSerializableFactory factory ID for this class.
int	hashCode()
void	readData(ObjectDataInput in)	Reads fields from the input stream
DeltaJobConfig	setAutoScaling(boolean enabled)
DeltaJobConfig	setMaxProcessorAccumulatedRecords(long maxProcessorAccumulatedRecords)
DeltaJobConfig	setMetricsEnabled(boolean enabled)
DeltaJobConfig	setSnapshotIntervalMillis(long snapshotInterval)
DeltaJobConfig	setSplitBrainProtection(boolean isEnabled)
DeltaJobConfig	setStoreMetricsAfterJobCompletion(boolean storeMetricsAfterJobCompletion)
DeltaJobConfig	setSuspendOnFailure(boolean suspendOnFailure)
DeltaJobConfig	setTimeoutMillis(long timeoutMillis)
String	toString()
void	writeData(ObjectDataOutput out)	Writes object fields to output stream

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

DeltaJobConfig

public DeltaJobConfig()

Method Details

setSnapshotIntervalMillis

@Nonnull
public DeltaJobConfig setSnapshotIntervalMillis(long snapshotInterval)

Returns:

this instance for fluent API

See Also:

• JobConfig.setSnapshotIntervalMillis(long)

setAutoScaling

public DeltaJobConfig setAutoScaling(boolean enabled)

Returns:

this instance for fluent API

See Also:

• JobConfig.setAutoScaling(boolean)

setSuspendOnFailure

public DeltaJobConfig setSuspendOnFailure(boolean suspendOnFailure)

Returns:

this instance for fluent API

See Also:

• JobConfig.setSuspendOnFailure(boolean)

setSplitBrainProtection

@Nonnull
public DeltaJobConfig setSplitBrainProtection(boolean isEnabled)

Returns:

this instance for fluent API

See Also:

• JobConfig.setSplitBrainProtection(boolean)

setMetricsEnabled

@Nonnull
public DeltaJobConfig setMetricsEnabled(boolean enabled)

Returns:

this instance for fluent API

See Also:

• JobConfig.setMetricsEnabled(boolean)

setStoreMetricsAfterJobCompletion

public DeltaJobConfig setStoreMetricsAfterJobCompletion(boolean storeMetricsAfterJobCompletion)

Returns:

this instance for fluent API

See Also:

• JobConfig.setStoreMetricsAfterJobCompletion(boolean)

setMaxProcessorAccumulatedRecords

public DeltaJobConfig setMaxProcessorAccumulatedRecords(long maxProcessorAccumulatedRecords)

Returns:

this instance for fluent API

See Also:

• JobConfig.setMaxProcessorAccumulatedRecords(long)

setTimeoutMillis

public DeltaJobConfig setTimeoutMillis(long timeoutMillis)

Returns:

this instance for fluent API

See Also:

• JobConfig.setTimeoutMillis(long)

applyTo

public void applyTo(JobConfig config)

Applies the changes represented by this instance to the specified configuration.

getFactoryId

@PrivateApi
public int getFactoryId()

Description copied from interface: IdentifiedDataSerializable

Returns DataSerializableFactory factory ID for this class.

Specified by:

getFactoryId in interface IdentifiedDataSerializable

Returns:

factory ID

getClassId

@PrivateApi
public int getClassId()

Description copied from interface: IdentifiedDataSerializable

Returns type identifier for this class. It should be unique per DataSerializableFactory.

Specified by:

getClassId in interface IdentifiedDataSerializable

Returns:

type ID

writeData

@PrivateApi
public void writeData(ObjectDataOutput out)
               throws IOException

Description copied from interface: DataSerializable

Writes object fields to output stream

Specified by:

writeData in interface DataSerializable

Parameters:

out - output

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the output stream has been closed.

readData

@PrivateApi
public void readData(ObjectDataInput in)
              throws IOException

Description copied from interface: DataSerializable

Reads fields from the input stream

Specified by:

readData in interface DataSerializable

Parameters:

in - input

Throws:

IOException - if an I/O error occurs. In particular, an IOException may be thrown if the input stream has been closed.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object