Package | Description |
---|---|
org.apache.flink.tests.util.flink.container |
Modifier and Type | Method and Description |
---|---|
static FlinkContainersBuilder |
FlinkContainers.builder()
Creates a builder for
FlinkContainers . |
FlinkContainersBuilder |
FlinkContainersBuilder.dependsOn(org.testcontainers.containers.GenericContainer<?> container)
Lets Flink cluster depending on another container, and bind the network of Flink cluster to
the dependent one.
|
FlinkContainersBuilder |
FlinkContainersBuilder.enableZookeeperHA()
Enables high availability service.
|
<T> FlinkContainersBuilder |
FlinkContainersBuilder.setConfiguration(ConfigOption<T> option,
T value)
Sets a single configuration of the cluster.
|
FlinkContainersBuilder |
FlinkContainersBuilder.setConfiguration(Configuration conf)
Sets configurations of the cluster.
|
FlinkContainersBuilder |
FlinkContainersBuilder.setEnvironmentVariable(String key,
String value)
Sets environment variable to containers.
|
FlinkContainersBuilder |
FlinkContainersBuilder.setLogger(org.slf4j.Logger logger)
Sets a logger to the cluster in order to consume STDOUT of containers to the logger.
|
FlinkContainersBuilder |
FlinkContainersBuilder.setLogProperties(Properties logProperties)
Sets log4j properties.
|
FlinkContainersBuilder |
FlinkContainersBuilder.setLogProperty(String key,
String value)
Sets log4j property.
|
FlinkContainersBuilder |
FlinkContainersBuilder.setNetwork(org.testcontainers.containers.Network network)
Sets network of the Flink cluster.
|
FlinkContainersBuilder |
FlinkContainersBuilder.setNumTaskManagers(int numTaskManagers)
Sets number of TaskManagers.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.