org.apache.flink.tests.util.flink

Class FlinkContainer.FlinkContainerBuilder

java.lang.Object

org.apache.flink.tests.util.flink.FlinkContainer.FlinkContainerBuilder

Enclosing class:

FlinkContainer

public static class FlinkContainer.FlinkContainerBuilder
extends Object

A builder for a FlinkContainer.

Constructor Summary

Constructors

Constructor and Description
FlinkContainerBuilder()

Method Summary

Modifier and Type	Method and Description
FlinkContainer	build()
FlinkContainer.FlinkContainerBuilder	javaVersion(String javaVersion) Specifies which OpenJDK version to use.
FlinkContainer.FlinkContainerBuilder	numTaskManagers(int numTaskManagers) The expected number of TaskManagers to start.

Methods inherited from class java.lang.Object

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

Constructor Detail

FlinkContainerBuilder

public FlinkContainerBuilder()

Method Detail

numTaskManagers

public FlinkContainer.FlinkContainerBuilder numTaskManagers(int numTaskManagers)

The expected number of TaskManagers to start. All TaskManagers are created in the same container along with the JobManager

javaVersion

public FlinkContainer.FlinkContainerBuilder javaVersion(String javaVersion)

Specifies which OpenJDK version to use. If not provided explicitly, the image version will be derived based on the version of the java that runs the test.

build

public FlinkContainer build()