Package | Description |
---|---|
org.apache.flink.runtime.blob | |
org.apache.flink.runtime.client |
Modifier and Type | Method and Description |
---|---|
protected BlobClient |
BlobServer.createClient() |
Modifier and Type | Method and Description |
---|---|
static void |
ClientUtils.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 |
ClientUtils.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 . |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.