FlinkImageBuilder |
FlinkImageBuilder.asJobManager() |
Use this image for building a JobManager.
|
FlinkImageBuilder |
FlinkImageBuilder.asTaskManager() |
Use this image for building a TaskManager.
|
FlinkImageBuilder |
FlinkImageBuilder.copyFile(Path localPath,
Path containerPath) |
Copies file into the image.
|
FlinkImageBuilder |
FlinkImageBuilder.setBaseImage(String baseImage) |
Sets base image.
|
FlinkImageBuilder |
FlinkImageBuilder.setConfiguration(org.apache.flink.configuration.Configuration conf) |
Sets Flink configuration.
|
FlinkImageBuilder |
FlinkImageBuilder.setFlinkDistPath(Path flinkDist) |
Sets the path of flink-dist directory.
|
FlinkImageBuilder |
FlinkImageBuilder.setFlinkHome(String flinkHome) |
Sets flink home.
|
FlinkImageBuilder |
FlinkImageBuilder.setImageNamePrefix(String imageNamePrefix) |
Sets the prefix name of building image.
|
FlinkImageBuilder |
FlinkImageBuilder.setJavaVersion(String javaVersion) |
Sets JDK version in the image.
|
FlinkImageBuilder |
FlinkImageBuilder.setLogProperties(Properties logProperties) |
Sets log4j properties.
|
FlinkImageBuilder |
FlinkImageBuilder.setTempDirectory(Path tempDirectory) |
Sets temporary path for holding temp files when building the image.
|
FlinkImageBuilder |
FlinkImageBuilder.setTimeout(Duration timeout) |
Sets timeout for building the image.
|
FlinkImageBuilder |
FlinkImageBuilder.useCustomStartupCommand(String command) |
Use a custom command for starting up the container.
|