com.google.cloud

Class BaseWriteChannel<ServiceOptionsT extends ServiceOptions<?,?,ServiceOptionsT>,EntityT extends Serializable>

java.lang.Object

com.google.cloud.BaseWriteChannel<ServiceOptionsT,EntityT>

Type Parameters:

ServiceOptionsT - the service options used by the channel to issue RPC requests

EntityT - the entity this channel writes data to. Possibly with additional configuration

All Implemented Interfaces:

Restorable<WriteChannel>, WriteChannel, Closeable, AutoCloseable, Channel, WritableByteChannel

public abstract class BaseWriteChannel<ServiceOptionsT extends ServiceOptions<?,?,ServiceOptionsT>,EntityT extends Serializable>
extends Object
implements WriteChannel

Base implementation for a WriteChannel.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	BaseWriteChannel.BaseState<ServiceOptionsT extends ServiceOptions<?,?,ServiceOptionsT>,EntityT extends Serializable>

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BaseWriteChannel(ServiceOptionsT options, EntityT entity, String uploadId)

Method Summary

Methods

Modifier and Type	Method and Description
protected byte[]	buffer()
RestorableState<WriteChannel>	capture() Captures the write channel state so that it can be saved and restored afterwards.
protected int	chunkSize()
void	chunkSize(int chunkSize) Sets the minimum size that will be written by a single RPC.
void	close()
protected int	defaultChunkSize()
protected EntityT	entity()
protected abstract void	flushBuffer(int length, boolean last) Writes length bytes of buffer() to the uploadId() URL.
boolean	isOpen()
protected int	limit()
protected int	minChunkSize()
protected ServiceOptionsT	options()
protected int	position()
protected void	restore(BaseWriteChannel.BaseState state) Restores the state of the current write channel given a BaseWriteChannel.BaseState object.
protected abstract BaseWriteChannel.BaseState.Builder<ServiceOptionsT,EntityT>	stateBuilder() Creates a BaseWriteChannel.BaseState.Builder for the current write channel.
protected String	uploadId()
int	write(ByteBuffer byteBuffer)

Methods inherited from class java.lang.Object

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

Constructor Detail

BaseWriteChannel

protected BaseWriteChannel(ServiceOptionsT options,
                EntityT entity,
                String uploadId)

Method Detail

minChunkSize

protected int minChunkSize()

defaultChunkSize

protected int defaultChunkSize()

flushBuffer

protected abstract void flushBuffer(int length,
               boolean last)

Writes length bytes of buffer() to the uploadId() URL.

Parameters:

length - the number of bytes to write from buffer()

last - if true the resumable session is closed

options

protected ServiceOptionsT options()

entity

protected EntityT entity()

uploadId

protected String uploadId()

position

protected int position()

buffer

protected byte[] buffer()

limit

protected int limit()

chunkSize

protected int chunkSize()

chunkSize

public final void chunkSize(int chunkSize)

Description copied from interface: WriteChannel

Sets the minimum size that will be written by a single RPC. Written data will be buffered and only flushed upon reaching this size or closing the channel.

Specified by:

chunkSize in interface WriteChannel

write

public final int write(ByteBuffer byteBuffer)
                throws IOException

Specified by:

write in interface WritableByteChannel

Throws:

IOException

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Channel

close

public final void close()
                 throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Channel

Throws:

IOException

stateBuilder

protected abstract BaseWriteChannel.BaseState.Builder<ServiceOptionsT,EntityT> stateBuilder()

Creates a BaseWriteChannel.BaseState.Builder for the current write channel.

capture

public RestorableState<WriteChannel> capture()

Description copied from interface: WriteChannel

Captures the write channel state so that it can be saved and restored afterwards. The original WriteChannel and the restored one should not both be used. Closing one channel causes the other channel to close; subsequent writes will fail.

Specified by:

capture in interface Restorable<WriteChannel>

Specified by:

capture in interface WriteChannel

Returns:

a RestorableState object that contains the write channel state and can restore it afterwards.

restore

protected void restore(BaseWriteChannel.BaseState state)

Restores the state of the current write channel given a BaseWriteChannel.BaseState object.