com.google.cloud.hadoop.gcsio.testing

Class InMemoryObjectReadChannel

java.lang.Object

com.google.cloud.hadoop.gcsio.GoogleCloudStorageReadChannel

com.google.cloud.hadoop.gcsio.testing.InMemoryObjectReadChannel

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, java.nio.channels.ByteChannel, java.nio.channels.Channel, java.nio.channels.ReadableByteChannel, java.nio.channels.SeekableByteChannel, java.nio.channels.WritableByteChannel

public class InMemoryObjectReadChannel
extends GoogleCloudStorageReadChannel

A SeekableByteChannel based on GoogleCloudStorageReadChannel that supports reading from in-memory byte stream.

Field Summary

Fields inherited from class com.google.cloud.hadoop.gcsio.GoogleCloudStorageReadChannel

DEFAULT_BACKOFF_INITIAL_INTERVAL_MILLIS, DEFAULT_BACKOFF_MAX_ELAPSED_TIME_MILLIS, DEFAULT_BACKOFF_MAX_INTERVAL_MILLIS, DEFAULT_BACKOFF_MULTIPLIER, DEFAULT_BACKOFF_RANDOMIZATION_FACTOR

Constructor Summary

Constructors

Constructor and Description
InMemoryObjectReadChannel(byte[] channelContents) Creates a new instance of InMemoryObjectReadChannel.
InMemoryObjectReadChannel(byte[] channelContents, GoogleCloudStorageReadOptions readOptions) Creates a new instance of InMemoryObjectReadChannel with readOptions plumbed into the base class.

Method Summary

Modifier and Type	Method and Description
protected java.io.InputStream	openStreamAndSetMetadata(long newPosition) Opens the underlying byte array stream, sets its position to currentPosition and sets size to size of the byte array.

Methods inherited from class com.google.cloud.hadoop.gcsio.GoogleCloudStorageReadChannel

close, closeReadChannel, createRequest, getEncoding, getMetadata, isOpen, position, position, read, setMaxRetries, setSize, setSize, size, truncate, validatePosition, write

Methods inherited from class java.lang.Object

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

Constructor Detail

InMemoryObjectReadChannel

public InMemoryObjectReadChannel(byte[] channelContents)
                          throws java.io.IOException

Creates a new instance of InMemoryObjectReadChannel.

Throws:

java.io.IOException

InMemoryObjectReadChannel

public InMemoryObjectReadChannel(byte[] channelContents,
                                 GoogleCloudStorageReadOptions readOptions)
                          throws java.io.IOException

Creates a new instance of InMemoryObjectReadChannel with readOptions plumbed into the base class.

Throws:

java.io.IOException

Method Detail

openStreamAndSetMetadata

protected java.io.InputStream openStreamAndSetMetadata(long newPosition)
                                                throws java.io.IOException

Opens the underlying byte array stream, sets its position to currentPosition and sets size to size of the byte array.

Overrides:

openStreamAndSetMetadata in class GoogleCloudStorageReadChannel

Parameters:

newPosition - position to seek into the new stream.

Throws:

java.io.IOException - on IO error