Package cz.o2.proxima.direct.io.gcloud.storage

Class BulkGCloudStorageWriter

java.lang.Object

cz.o2.proxima.direct.io.blob.BulkBlobWriter<GCloudBlobPath.GCloudBlob,cz.o2.proxima.direct.io.gcloud.storage.GCloudStorageAccessor>

cz.o2.proxima.direct.io.gcloud.storage.BulkGCloudStorageWriter

All Implemented Interfaces:

AttributeWriterBase, BulkAttributeWriter, java.lang.AutoCloseable

@Stable
public class BulkGCloudStorageWriter
extends BulkBlobWriter<GCloudBlobPath.GCloudBlob,cz.o2.proxima.direct.io.gcloud.storage.GCloudStorageAccessor>

BulkAttributeWriter for gcloud storage.

Nested Class Summary

Nested classes/interfaces inherited from interface cz.o2.proxima.direct.core.AttributeWriterBase

AttributeWriterBase.Type

Nested classes/interfaces inherited from interface cz.o2.proxima.direct.core.BulkAttributeWriter

BulkAttributeWriter.Factory<T extends BulkAttributeWriter>

Constructor Summary

Constructors

Constructor	Description
BulkGCloudStorageWriter(cz.o2.proxima.direct.io.gcloud.storage.GCloudStorageAccessor accessor, Context context)

Method Summary

Modifier and Type	Method	Description
BulkAttributeWriter.Factory<?>	asFactory()	Convert instance of this writer to AttributeWriterBase.Factory suitable for serialization.
protected void	deleteBlobIfExists(GCloudBlobPath.GCloudBlob blob)	Delete specified blob.

Methods inherited from class cz.o2.proxima.direct.io.blob.BulkBlobWriter

close, getEntityDescriptor, getUri, rollback, updateWatermark, write

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface cz.o2.proxima.direct.core.AttributeWriterBase

bulk, online

Methods inherited from interface cz.o2.proxima.direct.core.BulkAttributeWriter

getType

Constructor Detail

BulkGCloudStorageWriter

public BulkGCloudStorageWriter(cz.o2.proxima.direct.io.gcloud.storage.GCloudStorageAccessor accessor,
                               Context context)

Method Detail

deleteBlobIfExists

protected void deleteBlobIfExists(GCloudBlobPath.GCloudBlob blob)

Description copied from class: BulkBlobWriter

Delete specified blob.

Specified by:

deleteBlobIfExists in class BulkBlobWriter<GCloudBlobPath.GCloudBlob,cz.o2.proxima.direct.io.gcloud.storage.GCloudStorageAccessor>

asFactory

public BulkAttributeWriter.Factory<?> asFactory()

Description copied from interface: AttributeWriterBase

Convert instance of this writer to AttributeWriterBase.Factory suitable for serialization.

Returns:

the AttributeWriterBase.Factory representing this reader