Package org.apache.flink.connector.testutils.source

Class TestingTaskInfo.Builder

java.lang.Object

org.apache.flink.connector.testutils.source.TestingTaskInfo.Builder

Enclosing class:

TestingTaskInfo

public static class TestingTaskInfo.Builder
extends Object

Builder for TestingTaskInfo.

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
org.apache.flink.api.common.TaskInfo	build()
TestingTaskInfo.Builder	setAllocationIDAsString(String allocationIDAsString)
TestingTaskInfo.Builder	setAttemptNumber(int attemptNumber)
TestingTaskInfo.Builder	setIndexOfThisSubtask(int indexOfThisSubtask)
TestingTaskInfo.Builder	setMaxNumberOfParallelSubtasks(int maxNumberOfParallelSubtasks)
TestingTaskInfo.Builder	setNumberOfParallelSubtasks(int numberOfParallelSubtasks)
TestingTaskInfo.Builder	setTaskName(String taskName)
TestingTaskInfo.Builder	setTaskNameWithSubtasks(String taskNameWithSubtasks)

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

setTaskName

public TestingTaskInfo.Builder setTaskName(String taskName)

setMaxNumberOfParallelSubtasks

public TestingTaskInfo.Builder setMaxNumberOfParallelSubtasks(int maxNumberOfParallelSubtasks)

setIndexOfThisSubtask

public TestingTaskInfo.Builder setIndexOfThisSubtask(int indexOfThisSubtask)

setNumberOfParallelSubtasks

public TestingTaskInfo.Builder setNumberOfParallelSubtasks(int numberOfParallelSubtasks)

setAttemptNumber

public TestingTaskInfo.Builder setAttemptNumber(int attemptNumber)

setTaskNameWithSubtasks

public TestingTaskInfo.Builder setTaskNameWithSubtasks(String taskNameWithSubtasks)

setAllocationIDAsString

public TestingTaskInfo.Builder setAllocationIDAsString(String allocationIDAsString)

build

public org.apache.flink.api.common.TaskInfo build()