Package | Description |
---|---|
org.apache.flink.fs.gs.storage | |
org.apache.flink.fs.gs.utils |
Modifier and Type | Method and Description |
---|---|
static GSBlobIdentifier |
GSBlobIdentifier.fromBlobId(com.google.cloud.storage.BlobId blobId)
Construct an abstract blob identifier from a Google BlobId.
|
Modifier and Type | Method and Description |
---|---|
List<GSBlobIdentifier> |
GSBlobStorageImpl.list(String bucketName,
String objectPrefix) |
List<GSBlobIdentifier> |
GSBlobStorage.list(String bucketName,
String prefix)
Lists all the blobs in a bucket matching a given prefix.
|
Modifier and Type | Method and Description |
---|---|
void |
GSBlobStorageImpl.compose(List<GSBlobIdentifier> sourceBlobIdentifiers,
GSBlobIdentifier targetBlobIdentifier) |
void |
GSBlobStorage.compose(List<GSBlobIdentifier> sourceBlobIdentifiers,
GSBlobIdentifier targetBlobIdentifier)
Composes multiple blobs into one.
|
void |
GSBlobStorageImpl.copy(GSBlobIdentifier sourceBlobIdentifier,
GSBlobIdentifier targetBlobIdentifier) |
void |
GSBlobStorage.copy(GSBlobIdentifier sourceBlobIdentifier,
GSBlobIdentifier targetBlobIdentifier)
Copies from a source blob id to a target blob id.
|
void |
GSBlobStorageImpl.createBlob(GSBlobIdentifier blobIdentifier) |
void |
GSBlobStorage.createBlob(GSBlobIdentifier blobIdentifier)
Create an empty blob.
|
Optional<GSBlobStorage.BlobMetadata> |
GSBlobStorageImpl.getMetadata(GSBlobIdentifier blobIdentifier) |
Optional<GSBlobStorage.BlobMetadata> |
GSBlobStorage.getMetadata(GSBlobIdentifier blobIdentifier)
Gets blob metadata.
|
GSBlobStorage.WriteChannel |
GSBlobStorageImpl.writeBlob(GSBlobIdentifier blobIdentifier) |
GSBlobStorage.WriteChannel |
GSBlobStorage.writeBlob(GSBlobIdentifier blobIdentifier)
Creates a write channel with the default chunk size.
|
GSBlobStorage.WriteChannel |
GSBlobStorageImpl.writeBlob(GSBlobIdentifier blobIdentifier,
MemorySize chunkSize) |
GSBlobStorage.WriteChannel |
GSBlobStorage.writeBlob(GSBlobIdentifier blobIdentifier,
MemorySize chunkSize)
Creates a write channel with the specified chunk size.
|
Modifier and Type | Method and Description |
---|---|
void |
GSBlobStorageImpl.compose(List<GSBlobIdentifier> sourceBlobIdentifiers,
GSBlobIdentifier targetBlobIdentifier) |
void |
GSBlobStorage.compose(List<GSBlobIdentifier> sourceBlobIdentifiers,
GSBlobIdentifier targetBlobIdentifier)
Composes multiple blobs into one.
|
List<Boolean> |
GSBlobStorageImpl.delete(Iterable<GSBlobIdentifier> blobIdentifiers) |
List<Boolean> |
GSBlobStorage.delete(Iterable<GSBlobIdentifier> blobIdentifiers)
Deletes blobs.
|
Modifier and Type | Method and Description |
---|---|
static GSBlobIdentifier |
BlobUtils.getTemporaryBlobIdentifier(GSBlobIdentifier finalBlobIdentifier,
UUID temporaryObjectId,
GSFileSystemOptions options)
Resolves a temporary blob identifier for a provided temporary object id and the provided
options.
|
static GSBlobIdentifier |
BlobUtils.parseUri(URI uri)
Parses a blob id from a Google storage uri, i.e.
|
Modifier and Type | Method and Description |
---|---|
static GSBlobIdentifier |
BlobUtils.getTemporaryBlobIdentifier(GSBlobIdentifier finalBlobIdentifier,
UUID temporaryObjectId,
GSFileSystemOptions options)
Resolves a temporary blob identifier for a provided temporary object id and the provided
options.
|
static String |
BlobUtils.getTemporaryBucketName(GSBlobIdentifier finalBlobIdentifier,
GSFileSystemOptions options)
Returns the temporary bucket name.
|
static String |
BlobUtils.getTemporaryObjectName(GSBlobIdentifier finalBlobIdentifier,
UUID temporaryObjectId)
Returns a temporary object name, formed by appending the temporary object id to the temporary
object partial name, i.e.
|
static String |
BlobUtils.getTemporaryObjectPartialName(GSBlobIdentifier finalBlobIdentifier)
Returns a temporary object partial name, i.e.
|
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.