Class FileSystemBasedArtifactFetcher
- java.lang.Object
-
- org.apache.flink.kubernetes.operator.artifact.FileSystemBasedArtifactFetcher
-
- All Implemented Interfaces:
ArtifactFetcher
public class FileSystemBasedArtifactFetcher extends java.lang.Object implements ArtifactFetcher
Leverage the flink filesystem plugin to fetch the artifact.
-
-
Field Summary
Fields Modifier and Type Field Description static FileSystemBasedArtifactFetcher
INSTANCE
static org.slf4j.Logger
LOG
-
Constructor Summary
Constructors Constructor Description FileSystemBasedArtifactFetcher()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description java.io.File
fetch(java.lang.String uri, org.apache.flink.configuration.Configuration flinkConfiguration, java.io.File targetDir)
Fetch the resource from the uri to the targetDir.
-
-
-
Field Detail
-
LOG
public static final org.slf4j.Logger LOG
-
INSTANCE
public static final FileSystemBasedArtifactFetcher INSTANCE
-
-
Method Detail
-
fetch
public java.io.File fetch(java.lang.String uri, org.apache.flink.configuration.Configuration flinkConfiguration, java.io.File targetDir) throws java.lang.Exception
Description copied from interface:ArtifactFetcher
Fetch the resource from the uri to the targetDir.- Specified by:
fetch
in interfaceArtifactFetcher
- Parameters:
uri
- The artifact to be fetched.flinkConfiguration
- Flink configuration.targetDir
- The target dir to put the artifact.- Returns:
- The path of the fetched artifact.
- Throws:
java.lang.Exception
- Error during fetching the artifact.
-
-