public enum ClientUtils extends Enum<ClientUtils>
Modifier and Type | Method and Description |
---|---|
static void |
extractAndUploadJobGraphFiles(JobGraph jobGraph,
SupplierWithException<BlobClient,IOException> clientSupplier)
Extracts all files required for the execution from the given
JobGraph and uploads
them using the BlobClient from the given Supplier . |
static void |
uploadJobGraphFiles(JobGraph jobGraph,
Collection<Path> userJars,
Collection<Tuple2<String,Path>> userArtifacts,
SupplierWithException<BlobClient,IOException> clientSupplier)
Uploads the given jars and artifacts required for the execution of the given
JobGraph
using the BlobClient from the given Supplier . |
static ClientUtils |
valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static ClientUtils[] |
values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
public static ClientUtils[] values()
for (ClientUtils c : ClientUtils.values()) System.out.println(c);
public static ClientUtils valueOf(String name)
name
- the name of the enum constant to be returned.IllegalArgumentException
- if this enum type has no constant with the specified nameNullPointerException
- if the argument is nullpublic static void extractAndUploadJobGraphFiles(JobGraph jobGraph, SupplierWithException<BlobClient,IOException> clientSupplier) throws FlinkException
JobGraph
and uploads
them using the BlobClient
from the given Supplier
.jobGraph
- jobgraph requiring filesclientSupplier
- supplier of blob client to upload files withFlinkException
- if the upload failspublic static void uploadJobGraphFiles(JobGraph jobGraph, Collection<Path> userJars, Collection<Tuple2<String,Path>> userArtifacts, SupplierWithException<BlobClient,IOException> clientSupplier) throws FlinkException
JobGraph
using the BlobClient
from the given Supplier
.jobGraph
- jobgraph requiring filesuserJars
- jars to uploaduserArtifacts
- artifacts to uploadclientSupplier
- supplier of blob client to upload files withFlinkException
- if the upload failsCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.