Package | Description |
---|---|
org.apache.flink.runtime.blob | |
org.apache.flink.runtime.webmonitor | |
org.apache.flink.runtime.webmonitor.handlers |
Modifier and Type | Interface and Description |
---|---|
interface |
BlobStore
A blob store.
|
interface |
BlobStoreService
Service interface for the BlobStore which allows to close and clean up its data.
|
Modifier and Type | Class and Description |
---|---|
class |
FileSystemBlobStore
Blob store backed by
FileSystem . |
class |
VoidBlobStore
A blob store doing nothing.
|
Constructor and Description |
---|
BlobCache(InetSocketAddress serverAddress,
Configuration blobClientConfig,
BlobView blobView)
Instantiates a new BLOB cache.
|
Constructor and Description |
---|
WebRuntimeMonitor(Configuration config,
LeaderRetrievalService leaderRetrievalService,
BlobView blobView,
akka.actor.ActorSystem actorSystem) |
Constructor and Description |
---|
TaskManagerLogHandler(JobManagerRetriever retriever,
scala.concurrent.ExecutionContextExecutor executor,
scala.concurrent.Future<String> localJobManagerAddressPromise,
scala.concurrent.duration.FiniteDuration timeout,
TaskManagerLogHandler.FileMode fileMode,
Configuration config,
boolean httpsEnabled,
BlobView blobView) |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.