Class FileSystemBasedArtifactFetcher

  • All Implemented Interfaces:
    ArtifactFetcher

    public class FileSystemBasedArtifactFetcher
    extends java.lang.Object
    implements ArtifactFetcher
    Leverage the flink filesystem plugin to fetch the artifact.
    • 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.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • FileSystemBasedArtifactFetcher

        public FileSystemBasedArtifactFetcher()
    • 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 interface ArtifactFetcher
        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.