Class FileSystemBasedArtifactFetcher

  • All Implemented Interfaces:

    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 fetch​(java.lang.String uri, org.apache.flink.configuration.Configuration flinkConfiguration, 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 fetch​(java.lang.String uri,
                                  org.apache.flink.configuration.Configuration flinkConfiguration,
                           throws java.lang.Exception
        Description copied from interface: ArtifactFetcher
        Fetch the resource from the uri to the targetDir.
        Specified by:
        fetch in interface ArtifactFetcher
        uri - The artifact to be fetched.
        flinkConfiguration - Flink configuration.
        targetDir - The target dir to put the artifact.
        The path of the fetched artifact.
        java.lang.Exception - Error during fetching the artifact.