Package | Description |
---|---|
org.apache.flink.tests.util.flink |
Modifier and Type | Method and Description |
---|---|
static FlinkContainer.FlinkContainerBuilder |
FlinkContainer.builder() |
FlinkContainer.FlinkContainerBuilder |
FlinkContainer.FlinkContainerBuilder.javaVersion(String javaVersion)
Specifies which OpenJDK version to use.
|
FlinkContainer.FlinkContainerBuilder |
FlinkContainer.FlinkContainerBuilder.numTaskManagers(int numTaskManagers)
The expected number of TaskManagers to start.
|
FlinkContainer.FlinkContainerBuilder |
FlinkContainer.FlinkContainerBuilder.withFlinkConfiguration(Configuration flinkConfiguration)
Additional Flink configurations for the cluster.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.