Uses of Class
org.apache.flink.fs.gs.storage.GSBlobIdentifier

Packages that use GSBlobIdentifier

Package	Description
org.apache.flink.fs.gs.storage
org.apache.flink.fs.gs.utils

Uses of GSBlobIdentifier in org.apache.flink.fs.gs.storage

Methods in org.apache.flink.fs.gs.storage that return GSBlobIdentifier

Modifier and Type	Method	Description
static GSBlobIdentifier	GSBlobIdentifier.fromBlobId(com.google.cloud.storage.BlobId blobId)	Construct an abstract blob identifier from a Google BlobId.

Methods in org.apache.flink.fs.gs.storage that return types with arguments of type GSBlobIdentifier

Modifier and Type	Method	Description
List<GSBlobIdentifier>	GSBlobStorage.list(String bucketName, String prefix)	Lists all the blobs in a bucket matching a given prefix.
List<GSBlobIdentifier>	GSBlobStorageImpl.list(String bucketName, String objectPrefix)

Methods in org.apache.flink.fs.gs.storage with parameters of type GSBlobIdentifier

Modifier and Type	Method	Description
void	GSBlobStorage.compose(List<GSBlobIdentifier> sourceBlobIdentifiers, GSBlobIdentifier targetBlobIdentifier)	Composes multiple blobs into one.
void	GSBlobStorageImpl.compose(List<GSBlobIdentifier> sourceBlobIdentifiers, GSBlobIdentifier targetBlobIdentifier)
void	GSBlobStorage.copy(GSBlobIdentifier sourceBlobIdentifier, GSBlobIdentifier targetBlobIdentifier)	Copies from a source blob id to a target blob id.
void	GSBlobStorageImpl.copy(GSBlobIdentifier sourceBlobIdentifier, GSBlobIdentifier targetBlobIdentifier)
void	GSBlobStorage.createBlob(GSBlobIdentifier blobIdentifier)	Create an empty blob.
void	GSBlobStorageImpl.createBlob(GSBlobIdentifier blobIdentifier)
Optional<GSBlobStorage.BlobMetadata>	GSBlobStorage.getMetadata(GSBlobIdentifier blobIdentifier)	Gets blob metadata.
Optional<GSBlobStorage.BlobMetadata>	GSBlobStorageImpl.getMetadata(GSBlobIdentifier blobIdentifier)
GSBlobStorage.WriteChannel	GSBlobStorage.writeBlob(GSBlobIdentifier blobIdentifier)	Creates a write channel with the default chunk size.
GSBlobStorage.WriteChannel	GSBlobStorage.writeBlob(GSBlobIdentifier blobIdentifier, org.apache.flink.configuration.MemorySize chunkSize)	Creates a write channel with the specified chunk size.
GSBlobStorage.WriteChannel	GSBlobStorageImpl.writeBlob(GSBlobIdentifier blobIdentifier)
GSBlobStorage.WriteChannel	GSBlobStorageImpl.writeBlob(GSBlobIdentifier blobIdentifier, org.apache.flink.configuration.MemorySize chunkSize)

Method parameters in org.apache.flink.fs.gs.storage with type arguments of type GSBlobIdentifier

Modifier and Type	Method	Description
void	GSBlobStorage.compose(List<GSBlobIdentifier> sourceBlobIdentifiers, GSBlobIdentifier targetBlobIdentifier)	Composes multiple blobs into one.
void	GSBlobStorageImpl.compose(List<GSBlobIdentifier> sourceBlobIdentifiers, GSBlobIdentifier targetBlobIdentifier)
List<Boolean>	GSBlobStorage.delete(Iterable<GSBlobIdentifier> blobIdentifiers)	Deletes blobs.
List<Boolean>	GSBlobStorageImpl.delete(Iterable<GSBlobIdentifier> blobIdentifiers)

Uses of GSBlobIdentifier in org.apache.flink.fs.gs.utils

Methods in org.apache.flink.fs.gs.utils that return GSBlobIdentifier

Modifier and Type	Method	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. gs://bucket/foo/bar yields a blob with bucket name "bucket" and object name "foo/bar".

Methods in org.apache.flink.fs.gs.utils with parameters of type GSBlobIdentifier

Modifier and Type	Method	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. .inprogress/foo/bar/abc for the final blob with object name "foo/bar" and temporary object id "abc".
static String	BlobUtils.getTemporaryObjectNameWithEntropy(GSBlobIdentifier finalBlobIdentifier, UUID temporaryObjectId)	Returns a temporary object name with entropy, formed by adding the temporary object id to the temporary object partial name in both start and end of path, i.e. abc.inprogress/foo/bar/abc for the final blob with object name "foo/bar" and temporary object id "abc".
static String	BlobUtils.getTemporaryObjectPartialName(GSBlobIdentifier finalBlobIdentifier)	Returns a temporary object partial name, i.e. .inprogress/foo/bar/ for the final blob with object name "foo/bar".