Package | Description |
---|---|
org.apache.flink.runtime.blob | |
org.apache.flink.runtime.highavailability | |
org.apache.flink.runtime.highavailability.nonha |
Modifier and Type | Interface and Description |
---|---|
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.
|
Modifier and Type | Method and Description |
---|---|
static BlobServer |
BlobUtils.createBlobServer(Configuration configuration,
Reference<File> fallbackStorageDirectory,
BlobStore blobStore)
Creates the
BlobServer from the given configuration, fallback storage directory and
blob store. |
Constructor and Description |
---|
BlobServer(Configuration config,
File storageDir,
BlobStore blobStore) |
BlobServer(Configuration config,
Reference<File> storageDir,
BlobStore blobStore)
Instantiates a new BLOB server and binds it to a free network port.
|
Modifier and Type | Method and Description |
---|---|
BlobStore |
AbstractHaServices.createBlobStore() |
BlobStore |
HighAvailabilityServices.createBlobStore()
Creates the BLOB store in which BLOBs are stored in a highly-available fashion.
|
Modifier and Type | Method and Description |
---|---|
BlobStore |
AbstractNonHaServices.createBlobStore() |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.