Package org.apache.flink.kubernetes.operator.artifact

Class ArtifactManager

java.lang.Object

org.apache.flink.kubernetes.operator.artifact.ArtifactManager

public class ArtifactManager
extends java.lang.Object

Manage the user artifacts.

Constructor Summary

Constructors

Constructor	Description
ArtifactManager(FlinkConfigManager configManager)

Method Summary

Modifier and Type	Method	Description
java.io.File	fetch(java.lang.String jarURI, org.apache.flink.configuration.Configuration flinkConfiguration, java.lang.String targetDirStr)
java.lang.String	generateJarDir(io.fabric8.kubernetes.api.model.ObjectMeta meta, FlinkSessionJobSpec spec)

Methods inherited from class java.lang.Object

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

Constructor Detail

ArtifactManager

public ArtifactManager(FlinkConfigManager configManager)

Method Detail

fetch

public java.io.File fetch(java.lang.String jarURI,
                          org.apache.flink.configuration.Configuration flinkConfiguration,
                          java.lang.String targetDirStr)
                   throws java.lang.Exception

Throws:

java.lang.Exception

generateJarDir

public java.lang.String generateJarDir(io.fabric8.kubernetes.api.model.ObjectMeta meta,
                                       FlinkSessionJobSpec spec)