DefaultKubernetesArtifactUploader (Flink : Kubernetes 2.1.1-cp2 API)

java.lang.Object
- org.apache.flink.kubernetes.artifact.DefaultKubernetesArtifactUploader

All Implemented Interfaces:: KubernetesArtifactUploader

public class DefaultKubernetesArtifactUploader
extends Object
implements KubernetesArtifactUploader

Default KubernetesArtifactUploader implementation.

Constructor Summary

Constructors
Constructor Description

DefaultKubernetesArtifactUploader()

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`void`	`uploadAll(org.apache.flink.configuration.Configuration config)`	Uploads all `local://` schemed artifact that is present, according to the given configuration.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - DefaultKubernetesArtifactUploader
```
public DefaultKubernetesArtifactUploader()
```
- Method Detail
  - uploadAll
```
public void uploadAll(org.apache.flink.configuration.Configuration config)
               throws Exception
```
    Description copied from interface: KubernetesArtifactUploader
    
    Uploads all local:// schemed artifact that is present, according to the given configuration. Any remote artifact remains as it was passed originally.
    Takes the job JAR from the PipelineOptions.JARS config and any additional artifacts from the ArtifactFetchOptions.ARTIFACT_LIST config. After the upload, replaces the URIs of any local JAR in these configs to point to the remotely available one.
    Requires KubernetesConfigOptions.LOCAL_UPLOAD_TARGET to point to a valid, existing DFS directory with read and write permissions.
    
    Specified by:
    
    uploadAll in interface KubernetesArtifactUploader
    
    Parameters:
    
    config - given Flink configuration
    
    Throws:
    
    Exception - when the upload process fails