JobMapTaskXattrs

data class JobMapTaskXattrs(val consumerSize: Int? = null, val dispatcherSize: Int? = null, val pageSize: Int? = null, val queueSize: Int? = null, val taskAttemptInterval: Int? = null, val taskMaxAttempt: Int? = null)

Constructors

Link copied to clipboard
constructor(consumerSize: Int? = null, dispatcherSize: Int? = null, pageSize: Int? = null, queueSize: Int? = null, taskAttemptInterval: Int? = null, taskMaxAttempt: Int? = null)

Types

Link copied to clipboard
object Companion

Properties

Link copied to clipboard
val consumerSize: Int? = null

The number of threads to execute a single trigger. The default value is 5.

Link copied to clipboard
val dispatcherSize: Int? = null

The number of subtask distribution threads. The default value is 5.

Link copied to clipboard
val pageSize: Int? = null

The number of sub-tasks pulled by a parallel task at a time. The default value is 100.

Link copied to clipboard
val queueSize: Int? = null

The upper limit of the sub-task queue cache. The default value is 10000.

Link copied to clipboard

Subtask failure retry interval.

Link copied to clipboard
val taskMaxAttempt: Int? = null

The number of failed sub-task retries.