Package | Description |
---|---|
org.apache.flink.runtime.blob | |
org.apache.flink.runtime.execution.librarycache | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobgraph | |
org.apache.flink.runtime.jobmanager.slots | |
org.apache.flink.runtime.jobmaster | |
org.apache.flink.runtime.jobmaster.message | |
org.apache.flink.runtime.messages |
This package contains the messages that are sent between actors, like the
JobManager and
TaskManager to coordinate the distributed operations. |
Modifier and Type | Method and Description |
---|---|
BlobKey |
BlobClient.put(byte[] value)
Uploads the data of the given byte array to the BLOB server in a content-addressable manner.
|
BlobKey |
BlobClient.put(byte[] value,
int offset,
int len)
Uploads data from the given byte array to the BLOB server in a content-addressable manner.
|
BlobKey |
BlobClient.put(InputStream inputStream)
Uploads the data from the given input stream to the BLOB server in a content-addressable manner.
|
Modifier and Type | Method and Description |
---|---|
static List<BlobKey> |
BlobClient.uploadJarFiles(ActorGateway jobManager,
scala.concurrent.duration.FiniteDuration askTimeout,
Configuration clientConfig,
List<Path> jars)
Retrieves the
BlobServer address from the JobManager and uploads
the JAR files to it. |
static List<BlobKey> |
BlobClient.uploadJarFiles(InetSocketAddress serverAddress,
Configuration clientConfig,
List<Path> jars)
Uploads the JAR files to a
BlobServer at the given address. |
Modifier and Type | Method and Description |
---|---|
int |
BlobKey.compareTo(BlobKey o) |
void |
VoidBlobStore.delete(BlobKey blobKey) |
void |
FileSystemBlobStore.delete(BlobKey blobKey) |
void |
BlobStore.delete(BlobKey blobKey)
Tries to delete a blob from storage.
|
void |
BlobService.delete(BlobKey key)
This method deletes the file associated with the provided blob key.
|
void |
BlobServer.delete(BlobKey key)
This method deletes the file associated to the blob key if it exists in the local storage
of the blob server.
|
void |
BlobClient.delete(BlobKey key)
Deletes the BLOB identified by the given BLOB key from the BLOB server.
|
void |
BlobCache.delete(BlobKey key)
Deletes the file associated with the given key from the BLOB cache.
|
void |
BlobCache.deleteGlobal(BlobKey key)
Deletes the file associated with the given key from the BLOB cache and
BLOB server.
|
InputStream |
BlobClient.get(BlobKey blobKey)
Downloads the BLOB identified by the given BLOB key from the BLOB server.
|
void |
VoidBlobStore.get(BlobKey blobKey,
File localFile) |
void |
FileSystemBlobStore.get(BlobKey blobKey,
File localFile) |
void |
BlobView.get(BlobKey blobKey,
File localFile)
Copies a blob to a local file.
|
URL |
BlobService.getURL(BlobKey key)
This method returns the URL of the file associated with the provided blob key.
|
URL |
BlobServer.getURL(BlobKey requiredBlob)
Method which retrieves the URL of a file associated with a blob key.
|
URL |
BlobCache.getURL(BlobKey requiredBlob)
Returns the URL for the BLOB with the given key.
|
void |
VoidBlobStore.put(File localFile,
BlobKey blobKey) |
void |
FileSystemBlobStore.put(File localFile,
BlobKey blobKey) |
void |
BlobStore.put(File localFile,
BlobKey blobKey)
Copies the local file to the blob store.
|
Modifier and Type | Method and Description |
---|---|
File |
LibraryCacheManager.getFile(BlobKey blobKey)
Returns a file handle to the file identified by the blob key.
|
File |
FallbackLibraryCacheManager.getFile(BlobKey blobKey) |
File |
BlobLibraryCacheManager.getFile(BlobKey blobKey) |
Modifier and Type | Method and Description |
---|---|
void |
LibraryCacheManager.registerJob(JobID id,
Collection<BlobKey> requiredJarFiles,
Collection<URL> requiredClasspaths)
Registers a job with its required jar files and classpaths.
|
void |
FallbackLibraryCacheManager.registerJob(JobID id,
Collection<BlobKey> requiredJarFiles,
Collection<URL> requiredClasspaths) |
void |
BlobLibraryCacheManager.registerJob(JobID id,
Collection<BlobKey> requiredJarFiles,
Collection<URL> requiredClasspaths) |
void |
LibraryCacheManager.registerTask(JobID id,
ExecutionAttemptID execution,
Collection<BlobKey> requiredJarFiles,
Collection<URL> requiredClasspaths)
Registers a job task execution with its required jar files and classpaths.
|
void |
FallbackLibraryCacheManager.registerTask(JobID id,
ExecutionAttemptID execution,
Collection<BlobKey> requiredJarFiles,
Collection<URL> requiredClasspaths) |
void |
BlobLibraryCacheManager.registerTask(JobID jobId,
ExecutionAttemptID task,
Collection<BlobKey> requiredJarFiles,
Collection<URL> requiredClasspaths) |
Modifier and Type | Method and Description |
---|---|
Collection<BlobKey> |
JobInformation.getRequiredJarFileBlobKeys() |
Collection<BlobKey> |
ExecutionGraph.getRequiredJarFiles()
Returns a list of BLOB keys referring to the JAR files required to run this job
|
Constructor and Description |
---|
ExecutionGraph(ScheduledExecutorService futureExecutor,
Executor ioExecutor,
JobID jobId,
String jobName,
Configuration jobConfig,
SerializedValue<ExecutionConfig> serializedConfig,
Time timeout,
RestartStrategy restartStrategy,
FailoverStrategy.Factory failoverStrategyFactory,
List<BlobKey> requiredJarFiles,
List<URL> requiredClasspaths,
SlotProvider slotProvider,
ClassLoader userClassLoader) |
JobInformation(JobID jobId,
String jobName,
SerializedValue<ExecutionConfig> serializedExecutionConfig,
Configuration jobConfiguration,
Collection<BlobKey> requiredJarFileBlobKeys,
Collection<URL> requiredClasspathURLs) |
Modifier and Type | Method and Description |
---|---|
List<BlobKey> |
JobGraph.getUserJarBlobKeys()
Returns a set of BLOB keys referring to the JAR files required to run this job.
|
Modifier and Type | Method and Description |
---|---|
void |
JobGraph.addBlob(BlobKey key)
Adds the BLOB referenced by the key to the JobGraph's dependencies.
|
Modifier and Type | Method and Description |
---|---|
Future<BlobKey> |
TaskManagerGateway.requestTaskManagerLog(Time timeout)
Request the task manager log from the task manager.
|
Future<BlobKey> |
ActorTaskManagerGateway.requestTaskManagerLog(Time timeout) |
Future<BlobKey> |
TaskManagerGateway.requestTaskManagerStdout(Time timeout)
Request the task manager stdout from the task manager.
|
Future<BlobKey> |
ActorTaskManagerGateway.requestTaskManagerStdout(Time timeout) |
Modifier and Type | Method and Description |
---|---|
Future<BlobKey> |
RpcTaskManagerGateway.requestTaskManagerLog(Time timeout) |
Future<BlobKey> |
RpcTaskManagerGateway.requestTaskManagerStdout(Time timeout) |
Modifier and Type | Method and Description |
---|---|
Collection<BlobKey> |
ClassloadingProps.getRequiredJarFiles() |
Constructor and Description |
---|
ClassloadingProps(int blobManagerPort,
Collection<BlobKey> requiredJarFiles,
Collection<URL> requiredClasspaths)
Constructor of ClassloadingProps.
|
Modifier and Type | Method and Description |
---|---|
Collection<BlobKey> |
JobManagerMessages.ClassloadingProps.requiredJarFiles() |
Constructor and Description |
---|
ClassloadingProps(Integer blobManagerPort,
Collection<BlobKey> requiredJarFiles,
Collection<URL> requiredClasspaths) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.