Package | Description |
---|---|
org.apache.flink.connector.testframe.container |
Modifier and Type | Method and Description |
---|---|
static FlinkContainersSettings |
FlinkContainersSettings.basedOn(Configuration config)
FlinkContainersConfig based on provided Flink configuration. |
FlinkContainersSettings |
FlinkContainersSettings.Builder.build()
Returns a
FlinkContainersConfig built from the parameters previously set. |
static FlinkContainersSettings |
FlinkContainersSettings.defaultConfig()
FlinkContainersConfig based on defaults. |
Modifier and Type | Method and Description |
---|---|
static FlinkContainerTestEnvironment |
FlinkContainerTestEnvironment.fromSettings(FlinkContainersSettings settings) |
FlinkContainers.Builder |
FlinkContainers.Builder.withFlinkContainersSettings(FlinkContainersSettings flinkContainersSettings)
Allows to optionally provide Flink containers settings.
|
Constructor and Description |
---|
FlinkContainerTestEnvironment(FlinkContainersSettings settings) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.